Skip to main content

Wrapper for queue based producer/consumers parallel tasks execution

Project description

Python 3.7 Code style: black

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


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

multiconsumers-queue-0.1.2.tar.gz (4.9 kB view details)

Uploaded Source

Built Distribution

multiconsumers_queue-0.1.2-py3-none-any.whl (5.7 kB view details)

Uploaded Python 3

File details

Details for the file multiconsumers-queue-0.1.2.tar.gz.

File metadata

  • Download URL: multiconsumers-queue-0.1.2.tar.gz
  • Upload date:
  • Size: 4.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.0.2 CPython/3.7.6 Linux/5.3.0-46-generic

File hashes

Hashes for multiconsumers-queue-0.1.2.tar.gz
Algorithm Hash digest
SHA256 90dc576364c2a53935d1f380e74b1207cf3bc9b9921301e323768fbfd7e54d6b
MD5 d0a18d62b0768d69c379ccfdf8903602
BLAKE2b-256 4ed8a140cef58bf4125d43212796ab46c8efc63283b46d298fab9c830db76653

See more details on using hashes here.

File details

Details for the file multiconsumers_queue-0.1.2-py3-none-any.whl.

File metadata

File hashes

Hashes for multiconsumers_queue-0.1.2-py3-none-any.whl
Algorithm Hash digest
SHA256 c0dc1c341abb840acdca6817f4b74f89afae44ff71dfd21f9b6ac465dcd9b5e8
MD5 6f774a4f05d53e520361b14df312e60e
BLAKE2b-256 632031fea2aeb03090371bb6d7ab619d75064895fbbdd3a1f37acb23c0dac9ca

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page