celery.concurrency.gevent¶

Gevent execution pool.

class celery.concurrency.gevent.TaskPool(*args, **kwargs)[исходный код]¶

GEvent Pool.

class Timer(*args, **kwargs)¶

clear()¶

property queue¶

Snapshot of underlying datastructure.

grow(n=1)[исходный код]¶

is_green = True¶

set to true if pool uses greenlets.

property num_processes¶

on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, apply_target=<function apply_target>, **_)[исходный код]¶

on_start()[исходный код]¶

on_stop()[исходный код]¶

shrink(n=1)[исходный код]¶

signal_safe = False¶

set to true if the pool can be shutdown from within a signal handler.

task_join_will_block = False¶