`celery.worker.loops`¶

The consumers highly-optimized inner loop.

celery.worker.loops.asynloop(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0)[源代码]¶: Non-blocking event loop.

celery.worker.loops.synloop(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0, **kwargs)[源代码]¶: Fallback blocking event loop for transports that doesn't support AIO.