对于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()
对于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()
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
