update ticker

largeModel/model_handler.go

@@ -100,7 +100,7 @@ func (m *ModelHandler) MonitorModelInfo() {
 				}
 			}
 			m.IsInit = true
-			ticker = time.NewTicker(time.Minute * 10)
+			ticker.Reset(time.Minute * 10)
 		}
 	}
 }
@@ -192,7 +192,7 @@ func (m *ModelHandler) MonitorModelStatus() {
 						}
 					}
 				}
-				ticker = time.NewTicker(time.Minute * 10)
+				ticker.Reset(time.Minute * 10)
 			}
 		}
 	}

nm/monitor.go

@@ -140,7 +140,7 @@ func (m *MonitorNm) monitorNodeManagerSeed() {
 				nodeManagerArr = append(nodeManagerArr, &NodeManager{Info: node, IsUsed: false, IsExist: true})
 			}
 			m.IsInit = true
-			ticker = time.NewTicker(time.Minute * 10)
+			ticker.Reset(time.Minute * 10)
 		}
 	}
 }
@@ -153,7 +153,7 @@ func (m *MonitorNm) monitorGpuUsage(msgRespWorker *RespMsgWorker, nodeManager *m
 		case <-tick.C:
 			{
 				msgRespWorker.RegisterMsgResp(nodeManager, worker, GpuUsageResp, nil)
-				tick = time.NewTicker(time.Minute * 10)
+				tick.Reset(time.Minute * 10)
 			}
 		}
 	}

nm/task_handler.go

@@ -143,8 +143,8 @@ func (t *TaskWorker) ComputeTaskHandler(taskMsg *nodemanagerV2.PushTaskMessage)
 		taskParam:           &models.TaskParam{},
 		httpClient:          &http.Client{},
 		request:             &http.Request{},
-		waitRunningTicker:   time.NewTicker(time.Millisecond),
-		waitReqTicker:       time.NewTicker(time.Millisecond),
+		waitRunningTicker:   time.NewTicker(time.Millisecond * 100),
+		waitReqTicker:       time.NewTicker(time.Millisecond * 100),
 		startBeforeTaskTime: time.Now(),
 	}
 	t.LruCache.Add(taskMsg.TaskId, taskOp.taskExecResult)
@@ -506,7 +506,7 @@ func (op *TaskOp) waitContainerRunning(handler *TaskWorker, imageName string, in
 	for {
 		select {
 		case <-op.waitRunningTicker.C:
-			op.waitRunningTicker = time.NewTicker(time.Second * models.DefaultTaskTimer)
+			op.waitRunningTicker.Reset(time.Second * models.DefaultTaskTimer)
 			if int64(time.Since(op.startBeforeTaskTime).Seconds()) > maxExecTime-50 {
 				log.Errorf("%s", "The maximum execution time for this task has been exceeded")
 				return fmt.Errorf("%s", "The maximum execution time for this task has been exceeded")
@@ -568,7 +568,7 @@ func (op *TaskOp) waitReqContainerOk(dockerOp *operate.DockerOp) error {
 	for {
 		select {
 		case <-op.waitReqTicker.C:
-			op.waitReqTicker = time.NewTicker(time.Second * models.DefaultTaskTimer)
+			op.waitReqTicker.Reset(time.Second * models.DefaultTaskTimer)
 			if int64(time.Since(op.startBeforeTaskTime).Seconds()) > maxExecTime-50 {
 				log.Errorf("%s", "The maximum execution time for this task has been exceeded")
 				return fmt.Errorf("%s", "The maximum execution time for this task has been exceeded")