go任务调度2（linux的cron调用）

概述cron格式： 分 时 日 月 周 每隔5分钟执行1次： /5 * echo hello > /tmp/x.log 每隔1-5分钟执行1次： 1-5 echo hello > /tmp/x.log 每天10点整、22点整执行1次： 0 10,22 * echo hello > /tmp/x.log 每隔1-5分钟执行1次： 1-5 echo hello > /tmp/x.log Parse()：解

cron格式：
分 时 日 月 周

每隔5分钟执行1次： /5 * echo hello > /tmp/x.log

每隔1-5分钟执行1次： 1-5 echo hello > /tmp/x.log

每天10点整、22点整执行1次： 0 10,22 * echo hello > /tmp/x.log

每隔1-5分钟执行1次： 1-5 echo hello > /tmp/x.log

Parse()：解析与校验Cron表达式
Next()：根据当前时间，计算下次调度时间

package mainimport (    "fmt"    "github.com/gorhill/cronexpr"    "time")func main()  {    var (        expr *cronexpr.Expression        err error        Now time.Time        nextTime time.Time    )    //每隔5分钟执行一次(这个库支持7位，精确到秒、年)    if expr,err = cronexpr.Parse("*/5 * * * * * *"); err != nil {        fmt.Println(err)        return    }    //当前时间    Now = time.Now()    //下次调度时间    nextTime = expr.Next(Now)    //等待这个定时器超时    time.AfterFunc(nextTime.Sub(Now),func() {        fmt.Println("被调度了:",nextTime)    }) //下次时间减去当前时间    time.Sleep(10 * time.Second)}

调用一个cron
输出：被调度了: 2019-04-19 17:00:30 +0800 CST

package mainimport (    "fmt"    "github.com/gorhill/cronexpr"    "time")//代表一个任务type CronJob struct {    expr *cronexpr.Expression    nextTime time.Time //expr.Next(time.Now())就可以得到下一次调度时间}func main()  {    //需要有1个调度协程，它定时检查所有Cron任务，谁过期了就执行谁    var (        cronJob *CronJob        expr *cronexpr.Expression        Now time.Time        scheduletable map[string] *CronJob //key:任务名字,)    scheduletable = make(map[string]*CronJob)    //当前时间    Now = time.Now()    //定义第一个cronjob    expr = cronexpr.MustParse("*/5 * * * * * *")    cronJob = &CronJob{        expr: expr,nextTime: expr.Next(Now),}    //任务注册到了调度表    scheduletable["job1"] = cronJob    //定义第二个cronjob    expr = cronexpr.MustParse("*/5 * * * * * *")    cronJob = &CronJob{        expr: expr,}    //任务注册到了调度表    scheduletable["job2"] = cronJob    //启动调度协程    go func() {        var (            jobname string            cronJob *CronJob            Now time.Time        )        //定时检查任务调度表是否有到期的        for {            Now = time.Now()            for jobname,cronJob = range scheduletable {                //判断是否过期（如果下次调度时间早于等于当前时间，说明已经过期了）                if cronJob.nextTime.Before(Now) || cronJob.nextTime.Equal(Now) {                    //启动一个协程，执行这个任务                    go func(jobname string) {                        fmt.Println("执行:",jobname)                    }(jobname)                    //计算下一次调度时间                    cronJob.nextTime = cronJob.expr.Next(Now)                    fmt.Println(jobname,"下次执行时间:",cronJob.nextTime)                }            }            select {            //睡眠100毫秒（不让它占用过多cpu）            case <- time.NewTimer(100 * time.Millisecond).C: //将在100毫秒可读，返回            }        }    }()    time.Sleep(100 * time.Second)}

调用多个cron，按时间间隔输出：执行: job1job1 下次执行时间: 2019-04-19 17:31:20 +0800 CSTjob2 下次执行时间: 2019-04-19 17:31:20 +0800 CST执行: job2执行: job1job1 下次执行时间: 2019-04-19 17:31:25 +0800 CST执行: job2job2 下次执行时间: 2019-04-19 17:31:25 +0800 CST执行: job1job1 下次执行时间: 2019-04-19 17:31:30 +0800 CSTjob2 下次执行时间: 2019-04-19 17:31:30 +0800 CST执行: job2......

总结

以上是内存溢出为你收集整理的go任务调度2（linux的cron调用）全部内容，希望文章能够帮你解决go任务调度2（linux的cron调用）所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。