EvictingQueue- queue with evicting, non-blocking puts, blocking gets with timeouts, and iteration semanticsStoppableThread- thread with cancellation semanticsStore- callback executor with thread-safe writers
Read the docs for examples and the API reference.
pip install theta-alkasmIn a virtual environment:
$ poetry install
$ poetry check
$ poetry run pytest
$ poetry run black theta
$ poetry run mypy theta