【发布时间】:2017-07-27 12:31:32
【问题描述】:
我有一段类似于以下的代码
class Job():
def start():
from threading import Timer
t = Timer(10.0, self.cancel)
t.start()
self.status = "Started"
submitChildTasks() #----> Submits child celery tasks
一个作业实例本身就是一个 celery 任务,可以有多个子 celery 任务。我需要取消 Job 及其所有正在执行的子任务。为此我需要执行cancel。我怀疑Job.start() 完成后t 就快死了。有没有办法处理它。我希望在“t”等待执行cancel 时也执行子任务。
但是cancel 没有被调用。是不是我做错了什么?
非常感谢任何指导。提前致谢。
【问题讨论】:
-
您的代码运行正常!!!可能还有其他问题,您能否提供更多详细信息?
标签: python multithreading python-2.7 celery