- tasksch中，子任务结束发送结果时要获取lock

business/jxutils/tasksch/parallel_task.go

@@ -148,7 +148,11 @@ func (task *ParallelTask) Run() {
 				}
 			end:
 				// globals.SugarLogger.Debugf("ParallelTask.Run %s, put to chann chanRetVal:%v", task.Name, chanRetVal)
-				task.subFinishChan <- chanRetVal
+				task.locker.RLock()
+				if task.Status < TaskStatusEndBegin {
+					task.subFinishChan <- chanRetVal
+				}
+				task.locker.RUnlock()
 			})
 		}
 		for _, job := range task.jobList {