pypushflow.concurrent.process.ProcessPool#

class pypushflow.concurrent.process.ProcessPool(context=None, max_workers=None, **kw)[source]#

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)[source]#
Parameters:

  • fn (Callable)

  • callback (Optional[Callable])

  • error_callback (Optional[Callable])

Return type:

Future

close()[source]#

Prevents any more tasks from being submitted to the pool.

interrupt()[source]#

Stop all running tasks

Return type:

None

join(timeout=None)[source]#

Wait for the workers to exit.

Parameters:

timeout (Optional[Number])

Return type:

bool

shutdown(block=False, timeout=None, interrupt=False)[source]#

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

Parameters:

  • block (bool)

  • timeout (Optional[Number])

  • interrupt (bool)

Return type:

None