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.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 90dc576364c2a53935d1f380e74b1207cf3bc9b9921301e323768fbfd7e54d6b |
|
MD5 | d0a18d62b0768d69c379ccfdf8903602 |
|
BLAKE2b-256 | 4ed8a140cef58bf4125d43212796ab46c8efc63283b46d298fab9c830db76653 |
Close
Hashes for multiconsumers_queue-0.1.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c0dc1c341abb840acdca6817f4b74f89afae44ff71dfd21f9b6ac465dcd9b5e8 |
|
MD5 | 6f774a4f05d53e520361b14df312e60e |
|
BLAKE2b-256 | 632031fea2aeb03090371bb6d7ab619d75064895fbbdd3a1f37acb23c0dac9ca |