Go的Cron表达式解析库：github.com/gorhill/cronexpr

核心类型和方法

// 表达式对象
expr *cronexpr.Expression
// 解析cron表达式
expr = cronexpr.Parse()
// 返回下次执行时间
expr.Next()

解析Cron表达式

func PrintCronNext() {
    var (
        cronLine string
        expr *cronexpr.Expression
    )
    // 定时参数的格式 秒 分 时 日 月 周 年
    cronLine = "*/5 * * * * * *"
    expr, _ = cronexpr.Parse(cronLine)
    // expr.Next基于某个时间给出下一次的执行时间
    fmt.Println(expr.Next(time.Now()))
    // expr.NextN返回多个Next时间
    fmt.Println(expr.NextN(time.Now(), 5))
}

执行定时任务

// 结合time.AfterFunc实现定时任务的执行
func ExecWithCronNext() {
    var (
        cronLine string
        expr *cronexpr.Expression
    )
    cronLine = "*/5 * * * * * *"
    expr, _ = cronexpr.Parse(cronLine)
    // AfterFunc用于在指定的Duration后执行相应的函数
    // expr.Next() - time.Now() 得到相应的Duration
    time.AfterFunc(expr.Next(time.Now()).Sub(time.Now()), func() {
        fmt.Println("定时任务被执行了")
    })
    // 挂起主线程
    time.Sleep(10 * time.Second)
}

实现定时任务循环调度

// 封装一个任务
type CronJob struct {
    expr *cronexpr.Expression
    nextTime time.Time
    job func()  // 传递要执行的任务
}
// 构建调度器实现循环调度
func ScheduleWithCron() {
    // 调度器的本质是要循环一个调度表实现调度
    var (
        cronLine string
        expr *cronexpr.Expression
        cronJob *CronJob
        scheduleTable map[string]*CronJob
    )
    cronLine = "*/5 * * * * * *"
    // MustParse在Parse基础上当有err出现时进行Panic
    expr = cronexpr.MustParse(cronLine)
    // 新建任务
    cronJob = &CronJob{
        expr:     expr,
        nextTime: expr.Next(time.Now()),
        job: func() {
            fmt.Println("do cron job")
        },
    }
    // map类型需要make进行内存分配
    scheduleTable = make(map[string]*CronJob)
    // 将任务添加到调度表
    scheduleTable["job1"] = cronJob

    // 启动调度goroutine实现遍历调度表
    go func() {
        var (
            jobName string
            cronJob *CronJob
            now time.Time
        )
        for {
            now = time.Now()
            // range是go中的遍历语法
            for jobName, cronJob = range scheduleTable {
                // 比较每个CronJob中的NextTime是否已经过期
                if cronJob.nextTime.Before(now) || cronJob.nextTime.Equal(now) {
                    // 如果已经过期或者刚好相等，则启动一个goroutine来执行任务
                    go func() {
                        fmt.Printf("开始执行任务: %s \n", jobName)
                        cronJob.job()
                    }()
                    // 更新一下NextTime
                    cronJob.nextTime = cronJob.expr.Next(now)
                }
            }
            // 控制一下遍历调度表的频率
            select {
            // 使用time.NewTimer创建定时器，NewTimer.C返回一个channel
            // 当时间到了一个channel中会被放入一个Time类型的值从而唤醒阻塞，继续for遍历
            case <- time.NewTimer(100 * time.Millisecond).C:
            }
        }
    }()
    time.Sleep(100 * time.Second)
}