- ParallelTask结束后，清除subFinishChan与taskChan

2019-08-30 08:50:07 +08:00
parent bfa6ca2b9e
commit 27adff6add
1 changed files with 2 additions and 0 deletions
--- a/business/jxutils/tasksch/parallel_task.go
+++ b/business/jxutils/tasksch/parallel_task.go
@@ -180,6 +180,8 @@ func (task *ParallelTask) Run() {
 		close(task.subFinishChan)
 		task.jobList = nil // 如果不释放，任务被管理的话，会导致内存不能释放
 		task.worker = nil
+		task.subFinishChan = nil
+		task.taskChan = nil
 	})
 }