python - celery中task的eta countdown的实现方式

Question

rt， 看了下代码，并没有找到celery的task的定时时怎么实现的。

自己写了些测试代码/场景：

启动第一个任务，countdown设置为5秒
启动第二个任务,countdown设置为1秒。
第二个任务依然比第一次先运行。

启动一百个任务，50个为马上执行，50个设置coutdown为10s.

在rabbitmqctl list_queues中可以看到， celery队列中还有50条消息，10s后这50条消息都都consume掉了。

据此判断，消息是马上发出去了，但里面包含了countdown的信息。猜测是worker这边的manager进程判断消息是应该执行了，由于manager进程进行调度，但task进程不一定能马上执行，所以这也是celery官方文档中说明的，任务只确保在指定时间后运行，并不难保证任务的精确性

看了代码，没找到这个是怎么实现的， 不知道各位有什么见解没

Answer 1

Worker中的consumer会读取message，如果message有countdown，就会添加到timer(单独的线程)中进行schedule。
Internals: The worker