change task handle

nm/start.go

@@ -240,30 +240,33 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
 
 			taskMsg := rev.GetPushTaskMessage()
 			if taskMsg != nil {
-				if !taskMsgWorker.DockerOp.IsHealthy {
-					params := buildParams(taskMsgWorker.DockerOp.Reason)
-					msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
-					return
-				}
-				taskMsgWorker.Wg.Add(1)
-				taskMsgWorker.TaskMsg <- taskMsg
-				taskMsgWorker.Wg.Wait()
-				taskResHeader := taskMsgWorker.TaskRespHeader[taskMsg.TaskUuid]
-				taskResBody := taskMsgWorker.TaskRespBody[taskMsg.TaskUuid]
-				isSuccess := taskMsgWorker.TaskIsSuccess[taskMsg.TaskUuid]
-				containerSign := taskMsgWorker.DockerOp.GetContainerSign(taskMsg, taskResBody)
-				if containerSign == nil || len(containerSign) == 0 {
-					log.Error("Container signing failed................")
-					isSuccess = false
-				}
-				reqHash, respHash, minerSign := taskMsgWorker.GetMinerSign(taskMsg, taskResBody)
-				params := buildParams(taskMsg.TaskUuid, containerSign, minerSign, taskResHeader, taskResBody, isSuccess)
-				taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.ContainerSign, containerSign)
-				taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.MinerSign, minerSign)
-				taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.ReqHash, reqHash)
-				taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.RespHash, respHash)
-				msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResultResp, params)
-				log.Info(taskMsg)
+				go func(msgRespWorker *RespMsgWorker,
+					taskMsgWorker *TaskHandler) {
+					if !taskMsgWorker.DockerOp.IsHealthy {
+						params := buildParams(taskMsgWorker.DockerOp.Reason)
+						msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
+						return
+					}
+					taskMsgWorker.Wg.Add(1)
+					taskMsgWorker.TaskMsg <- taskMsg
+					taskMsgWorker.Wg.Wait()
+					taskResHeader := taskMsgWorker.TaskRespHeader[taskMsg.TaskUuid]
+					taskResBody := taskMsgWorker.TaskRespBody[taskMsg.TaskUuid]
+					isSuccess := taskMsgWorker.TaskIsSuccess[taskMsg.TaskUuid]
+					containerSign := taskMsgWorker.DockerOp.GetContainerSign(taskMsg, taskResBody)
+					if containerSign == nil || len(containerSign) == 0 {
+						log.Error("Container signing failed................")
+						isSuccess = false
+					}
+					reqHash, respHash, minerSign := taskMsgWorker.GetMinerSign(taskMsg, taskResBody)
+					params := buildParams(taskMsg.TaskUuid, containerSign, minerSign, taskResHeader, taskResBody, isSuccess)
+					taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.ContainerSign, containerSign)
+					taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.MinerSign, minerSign)
+					taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.ReqHash, reqHash)
+					taskMsgWorker.LruCache.Add(taskMsg.TaskUuid+models.RespHash, respHash)
+					msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResultResp, params)
+					log.Info(taskMsg)
+				}(msgRespWorker, taskMsgWorker)
 			}
 
 			nmSignMsg := rev.GetProofTaskResult()