向celery队列添加n个任务,然后等待结果

向celery队列添加n个任务,然后等待结果,第1张

向celery队列添加n个任务,然后等待结果

对于Celery > = 3.0,使用taskset被弃用赞成组。

from celery import groupfrom tasks import addjob = group([  add.s(2, 2),  add.s(4, 4),  add.s(8, 8),  add.s(16, 16),  add.s(32, 32),])

在后台启动组:

result = job.apply_async()

等待:

result.join()


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zaji/4932641.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-11-12
下一篇 2022-11-13

发表评论

登录后才能评论

评论列表(0条)

保存