- tasksch任务在结束后释放jobList,避免被管理的任务不能释放内存
This commit is contained in:
@@ -194,6 +194,7 @@ func (task *ParallelTask) Run() {
|
|||||||
}
|
}
|
||||||
task.Result = taskResult
|
task.Result = taskResult
|
||||||
task.TerminatedAt = time.Now()
|
task.TerminatedAt = time.Now()
|
||||||
|
task.jobList = nil // 如果不释放,任务被管理的话,会导致内存不能释放
|
||||||
task.locker.Unlock()
|
task.locker.Unlock()
|
||||||
globals.SugarLogger.Debugf("ParallelTask.Run %s, err:%v", task.Name, task.Err)
|
globals.SugarLogger.Debugf("ParallelTask.Run %s, err:%v", task.Name, task.Err)
|
||||||
close(task.subFinishChan)
|
close(task.subFinishChan)
|
||||||
|
|||||||
Reference in New Issue
Block a user