你正在阅读 Celery 3.1 的文档。开发版本文档见： 此处.

celery.worker.loops

celery.worker.loop

The consumers highly-optimized inner loop.

celery.worker.loops.asynloop(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0, RUN=1)

Non-blocking event loop consuming messages until connection is lost, or shutdown is requested.

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.