diff --git a/business/jxutils/tasksch/parallel_task.go b/business/jxutils/tasksch/parallel_task.go index 375688916..80b97da8e 100644 --- a/business/jxutils/tasksch/parallel_task.go +++ b/business/jxutils/tasksch/parallel_task.go @@ -194,6 +194,7 @@ func (task *ParallelTask) Run() { } task.Result = taskResult task.TerminatedAt = time.Now() + task.jobList = nil // 如果不释放,任务被管理的话,会导致内存不能释放 task.locker.Unlock() globals.SugarLogger.Debugf("ParallelTask.Run %s, err:%v", task.Name, task.Err) close(task.subFinishChan)