concurrency.gevent

Gevent execution pool.

Module Contents

Classes

Timer(self,*args,**kwargs)
TaskPool(self,*args,**kwargs) GEvent Pool.

Functions

apply_timeout(target,args=tuple,kwargs=dict,callback=None,accept_callback=None,pid=None,timeout=None,timeout_callback=None,Timeout=Timeout,apply_target=None,**rest)
apply_timeout(target, args=tuple, kwargs=dict, callback=None, accept_callback=None, pid=None, timeout=None, timeout_callback=None, Timeout=Timeout, apply_target=None, **rest)
class Timer(*args, **kwargs)
__init__(*args, **kwargs)
_enter(eta, priority, entry, **kwargs)
_entry_exit(g)
clear()
queue()
class TaskPool(*args, **kwargs)

GEvent Pool.

__init__(*args, **kwargs)
on_start()
on_stop()
on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, apply_target=None, **_)
grow(n=1)
shrink(n=1)
num_processes()