本文共 3002 字,大约阅读时间需要 10 分钟。
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 CSTpackage 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, nextTime: expr.Next(now), } //任务注册到了调度表 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......转载于:https://blog.51cto.com/5660061/2381564