- miss use err: in SyncSku

business/jxutils/tasksch/task.go

@@ -125,7 +125,9 @@ func RunTask(taskName string, worker WorkFunc, resultHandler ResultHandlerFunc,
 				}
 			end:
 				// globals.SugarLogger.Debugf("RunTask %s, put to chann chanRetVal:%v", taskName, chanRetVal)
-				task.subFinishChan <- chanRetVal
+				if task.GetStatus() < TaskStatusEndBegin {
+					task.subFinishChan <- chanRetVal
+				}
 			}()
 		}
 		for _, job := range jobList {
@@ -142,6 +144,7 @@ func RunTask(taskName string, worker WorkFunc, resultHandler ResultHandlerFunc,
 			if err2, ok := result.(error); ok {
 				taskResult = nil
 				taskErr = err2
+				break
 			} else if result != nil {
 				resultList := result.([]interface{})
 				taskResult = append(taskResult, resultList...)
@@ -162,8 +165,8 @@ func RunTask(taskName string, worker WorkFunc, resultHandler ResultHandlerFunc,
 		task.err = taskErr
 		task.result = taskResult
 		task.TerminatedAt = time.Now()
-
 		task.locker.Unlock()
+
 		globals.SugarLogger.Debugf("RunTask %s, result:%v, err:%v", taskName, taskResult, taskErr)
 
 		close(task.finishChan)