你正在阅读 Celery 3.1 的文档。开发版本文档见:
此处.
celery.concurrency.gevent† (experimental)
gevent pool implementation.
-
class celery.concurrency.gevent.TaskPool(*args, **kwargs)[源代码]
-
class Timer(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)
-
class Schedule(*args, **kwargs)
-
clear()
-
queue None
-
TaskPool.Timer.ensure_started()
-
TaskPool.Timer.start()
-
TaskPool.Timer.stop()
-
TaskPool.grow(n=1)[源代码]
-
TaskPool.is_green = True
-
TaskPool.num_processes None[源代码]
-
TaskPool.on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, **_)[源代码]
-
TaskPool.on_start()[源代码]
-
TaskPool.on_stop()[源代码]
-
TaskPool.shrink(n=1)[源代码]
-
TaskPool.signal_safe = False
-
TaskPool.task_join_will_block = False