Function startCronTask

crontask.go:137–151

start cron task

(task *CronTask)

//start cron task
func startCronTask(task *CronTask) {
	now := time.Now()
	nowSecond := time.Date(now.Year(), now.Month(), now.Day(), now.Hour(), now.Minute(), now.Second(), 0, time.Local)
	afterTime := nowSecond.Add(time.Second).Sub(time.Now().Local())
	task.TimeTicker = time.NewTicker(DefaultPeriod)
	go func() {
		time.Sleep(afterTime)
		for {
			select {
			case <-task.TimeTicker.C:
				doCronTask(task)
			}
		}
	}()
}

func doCronTask(task *CronTask) {
	taskCtx := task.getTaskContext()