中止任务¶
你可以中止任务以及工作流
中止未运行任务¶
通过 AbortTask()
设置中止任务标记。
第二个参数是中止标记的过期时间,若任务太多建议设置长一点,或设为-1后续手动清理。 (对于mongo这里设置过期时间是无效的,只能在NewBackend时设置)
client:= ser.GetClient()
client.AbortTask(id, 10)
中止运行中的任务¶
对于运行中的任务,你同样需要调用 AbortTask()
设置中止标记。然后在任务函数中手动检测,并中止。
func abortWorker(ctl *server.TaskCtl, a int) int {
// do ...
if f, _ := ctl.IsAbort(); f {
ctl.Abort("手动中止")
// 别忘了return
return 0
}
return a * a
}