alphatwirl.concurrently.MultiprocessingDropbox¶
-
class
alphatwirl.concurrently.
MultiprocessingDropbox
(**kwargs)[source]¶ 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
()