concurrency.base

Base Execution Pool.

Module Contents

Classes

BasePool(self,limit=None,putlocks=True,forking_enable=True,callbacks_propagate=tuple,app=None,**options) Task pool.

Functions

apply_target(target,args=tuple,kwargs=dict,callback=None,accept_callback=None,pid=None,getpid=None,propagate=tuple,monotonic=monotonic,**_) Apply function within pool context.
apply_target(target, args=tuple, kwargs=dict, callback=None, accept_callback=None, pid=None, getpid=None, propagate=tuple, monotonic=monotonic, **_)

Apply function within pool context.

class BasePool(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=tuple, app=None, **options)

Task pool.

__init__(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=tuple, app=None, **options)
on_start()
did_start_ok()
flush()
on_stop()
register_with_event_loop(loop)
on_apply(*args, **kwargs)
on_terminate()
on_soft_timeout(job)
on_hard_timeout(job)
maintain_pool(*args, **kwargs)
terminate_job(pid, signal=None)
restart()
stop()
terminate()
start()
close()
on_close()
apply_async(target, args=list, kwargs=dict, **options)

Equivalent of the apply() built-in function.

Callbacks should optimally return as soon as possible since otherwise the thread which handles the result will get blocked.

_get_info()
info()
active()
num_processes()