add more goroutine

nm/start.go

@@ -124,7 +124,7 @@ func monitorWorker(op *operate.DockerOp) {
 				go msgRespWorker.SendMsg()
 
 				taskMsgWorker := NewTaskWorker(op)
-				taskMsgWorker.HandlerTask(1)
+				taskMsgWorker.HandlerTask(3)
 
 				proofWorker := validator.NewProofWorker()
 
@@ -132,13 +132,15 @@ func monitorWorker(op *operate.DockerOp) {
 				go reportModelInfo(nodeManager, worker, msgRespWorker, op)
 
 				// 证明存储
-				go proofWorker.ProofStorage()
+				//go proofWorker.ProofStorage()
 
 				// 证明提交
-				go proofWorker.CommitWitness()
+				//go proofWorker.CommitWitness()
 
 				// 处理其他消息
-				go handlerMsg(nodeManager, worker, msgRespWorker, taskMsgWorker, proofWorker)
+				for i := 0; i < 3; i++ {
+					go handlerMsg(nodeManager, worker, msgRespWorker, taskMsgWorker, proofWorker)
+				}
 
 				log.Info("------------------------Start rev msg worker thread------------------------")
 				for {