素材牛VIP会员
celery中task的eta countdown的实现方式
 yu***01  分类:Python  人气:1303  回帖:1  发布于6年前 收藏

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

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

讨论这个帖子(1)垃圾回帖将一律封号处理……

Lv4 码徒
sy***88 软件测试工程师 6年前#1

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

 文明上网,理性发言!   😉 阿里云幸运券,戳我领取