pypushflow.concurrent.base.BasePool

class pypushflow.concurrent.base.BasePool(wait_on_exit=True, wait_on_exit_timeout=None, interrupt_on_exit=False, **_)

Bases: object

Parameters:

• wait_on_exit (bool) –

• wait_on_exit_timeout (Optional[Number]) –

• interrupt_on_exit (bool) –

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

Parameters:

• fn (Callable) –

• callback (Optional[Callable]) –

• error_callback (Optional[Callable]) –

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]) –

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