Function doLoopTask

looptask.go:124–184

(task *LoopTask)

}

func doLoopTask(task *LoopTask) {
	taskCtx := task.getTaskContext()
	defer func() {
		if taskCtx.TimeoutCancel != nil {
			taskCtx.TimeoutCancel()
		}
		task.putTaskContext(taskCtx)
		if err := recover(); err != nil {
			task.CounterInfo().ErrorCounter.Inc(1)
			//task.taskService.Logger().Debug(task.TaskID, " loop handler recover error => ", err)
			if task.taskService.ExceptionHandler != nil {
				task.taskService.ExceptionHandler(taskCtx, fmt.Errorf("%v", err))
			}
			//goroutine panic, restart cron task
			startLoopTask(task)
			task.taskService.Logger().Debug(fmt.Sprint(task.TaskID(), " goroutine panic, restart LoopTask"))
		}
	}()

	handler := func() {
		defer func() {
			if task.Timeout > 0 {
				taskCtx.doneChan <- struct{}{}
			}
		}()
		//inc run counter
		task.CounterInfo().RunCounter.Inc(1)
		//do log
		if task.taskService != nil && task.taskService.OnBeforeHandler != nil {
			task.taskService.OnBeforeHandler(taskCtx)
		}
		var err error
		if !taskCtx.IsEnd {
			err = task.handler(taskCtx)
		}
		if err != nil {
			taskCtx.Error = err
			task.CounterInfo().ErrorCounter.Inc(1)
			if task.taskService != nil && task.taskService.ExceptionHandler != nil {
				task.taskService.ExceptionHandler(taskCtx, err)
			}
		} else {
			//task.taskService.Logger().Debug(task.TaskID, " loop handler end success")
		}
		if task.taskService != nil && task.taskService.OnEndHandler != nil {
			task.taskService.OnEndHandler(taskCtx)
		}
	}

	if task.Timeout > 0 {
		go handler()
		select {
		case <-taskCtx.TimeoutContext.Done():
			task.taskService.Logger().Debug(fmt.Sprint(task.TaskID(), "do handler timeout."))
		case <-taskCtx.doneChan:
			return
		}
	} else {