Update 更新素,不存在则会失败
(oneJob task_queue2.OneJob)
| 181 | |
| 182 | // Update 更新素,不存在则会失败 |
| 183 | func (t *TaskQueue) Update(oneJob task_queue2.OneJob) (bool, error) { |
| 184 | |
| 185 | defer t.queueLock.Unlock() |
| 186 | t.queueLock.Lock() |
| 187 | |
| 188 | return t.update(oneJob) |
| 189 | } |
| 190 | |
| 191 | // AutoDetectUpdateJobStatus 根据任务的生命周期图,进行自动判断更新,见《任务的生命周期》流程图 |
| 192 | func (t *TaskQueue) AutoDetectUpdateJobStatus(oneJob task_queue2.OneJob, inErr error) { |