Wrapper for queue based producer/consumers parallel tasks execution
Project description
multiconsumers-queue-cli
Wrapper for queue based producer/consumers parallel tasks execution
Futures:
- graceful shutdown by ^C
- producer/consumer errors handling out of the box
- scheduled tasks statistics logging
Examples:
- with ThreadPoolExecutor for I/O bound tasks
Usage: cli-threads.py [OPTIONS] Demo script with ThreadPoolExecutor Options: --workers INTEGER How many workers will be started [default: 5] --limit INTEGER How many items can be produced [default: 50] --logging-level TEXT Logging level [default: INFO] --help Show this message and exit.
References:
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for multiconsumers-queue-0.1.4.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 227e25cc7d2dd8427c4bbb7dea58ecb7d72553721621827bff9f4b2b3332c82b |
|
MD5 | f696c5b00491f4d8a71a928bea51d9c1 |
|
BLAKE2b-256 | 954282bab14dad9d0923734d8bc961de6c990dc120574cb11b3cea9c075ed43b |
Close
Hashes for multiconsumers_queue-0.1.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6587f695831f380ca7037a45ea084155ed84fb0fc05dc205e60908b334ec9027 |
|
MD5 | 792c64931fadac72d4342ef953348fef |
|
BLAKE2b-256 | 812b770697cabaefef6c366329656fbb912d5651919a62c04220df850c0b0318 |