RemoveTask remove task by taskid
(taskID string)
| 270 | |
| 271 | // RemoveTask remove task by taskid |
| 272 | func (service *TaskService) RemoveTask(taskID string) { |
| 273 | //1.stop task running |
| 274 | t, isExists := service.GetTask(taskID) |
| 275 | if !isExists { |
| 276 | return |
| 277 | } |
| 278 | t.Stop() |
| 279 | service.Logger().Info(fmt.Sprint("Task:RemoveTask::StopTask => ", taskID)) |
| 280 | |
| 281 | //2.delete task from taskMap |
| 282 | service.taskMutex.Lock() |
| 283 | delete(service.taskMap, taskID) |
| 284 | service.taskMutex.Unlock() |
| 285 | service.Logger().Info(fmt.Sprint("Task:RemoveTask => ", taskID)) |
| 286 | } |
| 287 | |
| 288 | // Count get all task's count |
| 289 | func (service *TaskService) Count() int { |