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