update wait container op ticker time

nm/task_handler.go

@@ -45,7 +45,8 @@ type TaskOp struct {
 	taskParam           *models.TaskParam
 	httpClient          *http.Client
 	request             *http.Request
-	ticker              *time.Ticker
+	waitRunningTicker   *time.Ticker
+	waitReqTicker       *time.Ticker
 	startBeforeTaskTime time.Time
 }
 
@@ -141,7 +142,8 @@ func (t *TaskWorker) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 		taskParam:           &models.TaskParam{},
 		httpClient:          &http.Client{},
 		request:             &http.Request{},
-		ticker:              time.NewTicker(time.Second * models.DefaultTaskTimer),
+		waitRunningTicker:   time.NewTicker(time.Millisecond),
+		waitReqTicker:       time.NewTicker(time.Millisecond),
 		startBeforeTaskTime: time.Now(),
 	}
 	t.LruCache.Add(taskMsg.TaskId, taskOp.taskExecResult)
@@ -469,7 +471,8 @@ func (op *TaskOp) waitContainerRunning(handler *TaskWorker, imageName string, co
 	log.WithField("maxExecTime", maxExecTime).Info("Waiting for container running", imageName)
 	for {
 		select {
-		case <-op.ticker.C:
+		case <-op.waitRunningTicker.C:
+			op.waitRunningTicker = time.NewTicker(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")
@@ -528,7 +531,8 @@ func (op *TaskOp) waitReqContainerOk(dockerOp *operate.DockerOp) error {
 	var err error
 	for {
 		select {
-		case <-op.ticker.C:
+		case <-op.waitReqTicker.C:
+			op.waitReqTicker = time.NewTicker(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")