pypushflow.concurrent.process.ProcessPool¶
- class pypushflow.concurrent.process.ProcessPool(context=None, max_workers=None, **kw)[source]¶
Bases:
BasePool
Pool of non-daemonic processes (they can 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