StopAllTask stop all task
()
| 345 | |
| 346 | // StopAllTask stop all task |
| 347 | func (service *TaskService) StopAllTask() { |
| 348 | service.Logger().Info("Task:StopAllTask begin...") |
| 349 | for _, v := range service.taskMap { |
| 350 | v.Stop() |
| 351 | service.Logger().Info(fmt.Sprint("Task:StopAllTask::StopTask => ", v.TaskID())) |
| 352 | } |
| 353 | service.Logger().Info("Task:StopAllTask end[" + string(len(service.taskMap)) + "]") |
| 354 | } |
| 355 | |
| 356 | // StartAllTask start all task |
| 357 | func (service *TaskService) StartAllTask() { |
no test coverage detected