pypushflow.concurrent.thread.ThreadPool¶
- class pypushflow.concurrent.thread.ThreadPool(max_workers=None, **kw)[source]¶
Bases:
BasePool
- Parameters:
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
- join(timeout=None)[source]¶
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