中止任务

你可以中止任务以及工作流

中止未运行任务

通过 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
}