Clear 清空所有任务
()
| 302 | |
| 303 | // Clear 清空所有任务 |
| 304 | func (s *Scheduler) Clear() { |
| 305 | s.mu.Lock() |
| 306 | defer s.mu.Unlock() |
| 307 | |
| 308 | // 停止所有时间间隔任务 |
| 309 | for _, task := range s.intervalTasks { |
| 310 | close(task.stopCh) |
| 311 | } |
| 312 | |
| 313 | // 清空 |
| 314 | s.stepTasks = make(map[string]*StepTask) |
| 315 | s.stepListeners = make([]StepCallback, 0) |
| 316 | s.intervalTasks = make(map[string]*IntervalTask) |
| 317 | } |
| 318 | |
| 319 | // Shutdown 关闭调度器 |
| 320 | func (s *Scheduler) Shutdown() { |
no outgoing calls