MultiprocessingParallelizer
Parallelizes using a process pool and a runner function that represents a “main loop”.
SendRecvQueuePair: SendRecvQueuePair
PoolCommunicator: PoolCommunicator
__init__(self, worker=False, pool: <bound method BaseContext.Pool of <multiprocessing.context.DefaultContext instance>> = None, context=None, manager=None, logger=None, contract=None, comm=None, rank=None, allow_restart=True, initialization_timeout=0.5, **kwargs):
get_nprocs(self):
get_id(self):
@property
comm(self):
Returns the communicator used by the paralellizer
:returns:MultiprocessingParallelizer.PoolCommunicator
__getstate__(self):
__setstate__(self, state):
apply(self, func, *args, comm=None, main_kwargs=None, **kwargs):
Applies func to args in parallel on all of the processes
func:Anyargs:Anykwargs:Any:returns:_
get_pool_context(pool):
get_pool_nprocs(pool):
initialize(self, allow_restart=None):
finalize(self, exc_type, exc_val, exc_tb):
@property
on_main(self):
from_config(**kw):