alphatwirl.concurrently.MultiprocessingDropbox

class alphatwirl.concurrently.MultiprocessingDropbox(**kwargs)

A drop box for task packages.

The tasks will be executed in multiprocessing

The original implementation of this class has been released as an independent package: https://github.com/alphatwirl/mantichora

The current implementation uses mantichora.

Parameters:nprocesses (int) – The number of processes

__init__(**kwargs)

Methods

__init__(**kwargs)
close()
open()
poll()
put(package)
put_multiple(packages)
receive()
receive_one()
terminate()