pypushflow.concurrent.multiprocessing.MProcessPool

class pypushflow.concurrent.multiprocessing.MProcessPool(context=None, max_workers=None, **kw)

Bases: BasePool

Pool of daemonic processes (they cannot have sub-processes).

Parameters:

• context (Optional[str]) –

• max_workers (Optional[int]) –

apply_async(fn, callback=None, error_callback=None, args=(), kwargs=None)

Parameters:

• fn (Callable) –

• callback (Optional[Callable]) –

• error_callback (Optional[Callable]) –

Return type:

ApplyResult

close()

Prevents any more tasks from being submitted to the pool.

interrupt()

Stop all running tasks

Return type:

None

join(timeout=None)

Wait for the workers to exit.

Parameters:

timeout (Optional[Number]) –

Return type:

bool

shutdown(block=False, timeout=None, interrupt=False)

Cleanup all resources. Waits for tasks to finish unless interrupt=True.

Parameters:

• block (bool) –

• timeout (Optional[Number]) –

• interrupt (bool) –

Return type:

None