celery.concurrency.eventlet¶

Eventlet execution pool.

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

Eventlet Task Pool.

class Timer(*args, **kwargs)¶

Eventlet Timer.

cancel(tref)¶

clear()¶

property queue¶

Snapshot of underlying datastructure.

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

is_green = True¶

set to true if pool uses greenlets.

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

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¶

terminate_job(pid, signal=None)[исходный код]¶