celery.concurrency.gevent† (experimental)

• celery.concurrency.gevent

celery.concurrency.gevent

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*