谁在芹菜apply_async等待(倒计时=10)

Question

>我运行并发的芹菜工作线程 20

"-c", "20", "-P", "eventlet", "-Ofair"

并在另一个任务中为该工人队列生成 20 个任务包

async_call.apply_async(
(call_id, engine),
expires=60,
countdown=60*random(),  # random delay, to prevent spikes
)

在查看器flower我看到任务不超过 20 个。

问题是：谁在等待倒计时？ 它在队列内吗？还是在工作进程内部(接受任务的工人的一些空闲时间(？

如果是在worker内部，那么要使用所有CPU，我需要根据倒计时时间(空闲时间(到工作时间的比例增加并发性。

Answer 1

等待在每个芹菜工人都有的进程/线程中，如果工人正在等待任务，它将轮询代理以获取新任务。