标签：cronexpr cronJob expr cronLine Next Cron time GO 定时

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)
}

标签：cronexpr,cronJob,expr,cronLine,Next,Cron,time,GO,定时
来源： https://www.cnblogs.com/Peter2014/p/12026898.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。