consumers

Some features may not work without JavaScript. Please try enabling it if you encounter problems.

A simple, flexible way to parallelize processing in Python.

These details have not been verified by PyPI

Project links

Homepage

Project description

Consumers is a simple, flexible way to parallelize processing in Python.

Documentation

https://consumers.readthedocs.io

Example

from consumers import Pool


def concatenate(letters):
    return ''.join(letters)


with Pool(concatenate, 2) as pool:
    for letter in 'abcdef':
        pool.put(letter)

print(pool.results)

Results

('bdf', 'ace')

Hashes for consumers-0.6.1.tar.gz
Algorithm	Hash digest
SHA256	`58e6177a5ddf703ae437b5d0043dd8df4558334601af3ba20cfcd44a59b6746a`
MD5	`0b31deabd6645eb6310a6cc5e41c0d00`
BLAKE2b-256	`d9e666345f1963dacb8df3d7ebdd67de2b486fc342271f80838617d4e4bff2ec`

Hashes for consumers-0.6.1-py3-none-any.whl
Algorithm	Hash digest
SHA256	`a33355efa3c881b3b579f04addc8b8c8c9b9953b51e4f617b3aaeda993ce6e7b`
MD5	`6e6e69d1122fe32ce8625cd15e92329b`
BLAKE2b-256	`40cb9fe518f478751117c614ff1c9ac85127f0864cb305d96df52c5658005418`