celery.concurrency.eventlet

• celery.concurrency.eventlet

celery.concurrency.eventlet

Eventlet pool implementation.

class celery.concurrency.eventlet.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.cancel(tref)

  • TaskPool.Timer.ensure_started()

  • TaskPool.Timer.start()

  • TaskPool.Timer.stop()

• TaskPool.is_green = True

• TaskPool.on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, \*_*)[源代码]

• TaskPool.on_start()[源代码]

• TaskPool.on_stop()[源代码]

• TaskPool.signal_safe = False

• TaskPool.task_join_will_block = False