Function doCronTask

crontask.go:153–221

(task *CronTask)

}

func doCronTask(task *CronTask) {
	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(fmt.Sprint(task.TaskID(), " cron handler recover error => ", err))
			if task.taskService.ExceptionHandler != nil {
				task.taskService.ExceptionHandler(taskCtx, fmt.Errorf("%v", err))
			}
			//goroutine panic, restart cron task
			startCronTask(task)
			task.taskService.Logger().Debug(fmt.Sprint(task.TaskID(), " goroutine panic, restart CronTask"))
		}
	}()

	handler := func() {
		defer func() {
			if task.Timeout > 0 {
				taskCtx.doneChan <- struct{}{}
			}
		}()
		now := time.Now()
		if task.time_WeekDay.IsMatch(now) &&
			task.time_Month.IsMatch(now) &&
			task.time_Day.IsMatch(now) &&
			task.time_Hour.IsMatch(now) &&
			task.time_Minute.IsMatch(now) &&
			task.time_Second.IsMatch(now) {

			//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)
				}
			}
			if task.taskService != nil && task.taskService.OnEndHandler != nil {
				task.taskService.OnEndHandler(taskCtx)
			}
		}
	}

	if task.Timeout > 0 {
		go handler()