alphatwirl.concurrently.MultiprocessingDropbox

class alphatwirl.concurrently.MultiprocessingDropbox(**kwargs)

A drop box for task packages.

The tasks will be executed in multiprocessing

Parameters:

• nprocesses (int) – The number of processes
• progressbar (bool) – Progress bars from atpbar can be used in spawned processes if True.

__init__(**kwargs)

Methods

__init__(**kwargs)
close()
open()
poll()	Return pairs of task indices and results of finished tasks.
put(package)
put_multiple(packages)
receive()	Return pairs of task indices and results.
receive_one()	Return a pair of a package index and a result.
terminate()