From addd9e3ad9c9d6482fe2c69695bbe185174b2b63 Mon Sep 17 00:00:00 2001 From: gazebo Date: Wed, 17 Apr 2019 13:32:20 +0800 Subject: [PATCH] =?UTF-8?q?-=20tasksch=E4=B8=AD=EF=BC=8C=E5=AD=90=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E7=BB=93=E6=9D=9F=E5=8F=91=E9=80=81=E7=BB=93=E6=9E=9C?= =?UTF-8?q?=E6=97=B6=E8=A6=81=E8=8E=B7=E5=8F=96lock?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxutils/tasksch/parallel_task.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 {