celery中task的eta countdown的实现方式


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官方文档中说明的,任务只确保在指定时间后运行,并不难保证任务的精确性

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

python 异步任务队列 celery

工口star 10 years, 6 months ago

Your Answer