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官方文档中说明的,任务只确保在指定时间后运行,并不难保证任务的精确性
看了代码,没找到这个是怎么实现的, 不知道各位有什么见解没
工口star
10 years, 6 months ago