diff --git a/business/jxutils/tasksch/parallel_task.go b/business/jxutils/tasksch/parallel_task.go
index 39a867593..375688916 100644
--- a/business/jxutils/tasksch/parallel_task.go
+++ b/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 {