我有一段类似于以下内容的代码
class Job():
def start():
from threading import Timer
t = Timer(10.0, self.cancel)
t.start()
self.status = "Started"
submitChildTasks() #----> Submits child celery tasks
作业实例本身是一个芹菜任务,可以有多个子芹菜任务。我需要取消作业及其所有子任务执行。为此,我需要执行cancel
.我怀疑Job.start()
一说完,t
就要死了。有什么办法可以处理它。我想在"t"等待执行cancel
时也执行子任务。 但cancel
没有被召唤。我做错了什么吗?
任何指导都非常感谢。提前谢谢。
由于您没有发布所有代码,因此我添加了此代码,主要是您未发布的代码
from threading import Timer
def cancel():
print 'cancel called'
t = Timer(10.0, cancel)
t.start()
此代码将按预期在计时器中等待 10 秒。也许问题与缺失的班级有关?如果这仍然没有帮助,请添加您的代码。