celery.concurrency.gevent† (experimental)

    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.start()

      • TaskPool.Timer.stop()

    • TaskPool.grow(n=1)[源代码]

    • TaskPool.is_green = True

    • TaskPool.on_start()

    • TaskPool.on_stop()[源代码]

    • TaskPool.shrink(n=1)

    • TaskPool.task_join_will_block = False