Cancel 取消任务
(taskID string)
| 281 | |
| 282 | // Cancel 取消任务 |
| 283 | func (s *Scheduler) Cancel(taskID string) error { |
| 284 | s.mu.Lock() |
| 285 | defer s.mu.Unlock() |
| 286 | |
| 287 | // 检查步骤任务 |
| 288 | if _, exists := s.stepTasks[taskID]; exists { |
| 289 | delete(s.stepTasks, taskID) |
| 290 | return nil |
| 291 | } |
| 292 | |
| 293 | // 检查时间间隔任务 |
| 294 | if task, exists := s.intervalTasks[taskID]; exists { |
| 295 | close(task.stopCh) |
| 296 | delete(s.intervalTasks, taskID) |
| 297 | return nil |
| 298 | } |
| 299 | |
| 300 | return fmt.Errorf("task not found: %s", taskID) |
| 301 | } |
| 302 | |
| 303 | // Clear 清空所有任务 |
| 304 | func (s *Scheduler) Clear() { |