兰州网站设计公司工厂管理培训课程
一、获取cron/v3包
go get github.com/robfig/cron/v3@v3.0.0
安装v3版本的cron包。
二、创建cron调度器
使用cron.New()创建一个新的Cron调度器:
c := cron.New()
三、添加定时任务
使用AddFunc方法添加定时任务,参数是cron表达式和任务函数:
c.AddFunc("* * * * *", task)
四、启动调度器
使用Start方法启动cron调度器,开始执行定时任务:
c.Start()
也可以使用Run方法,它会在后台启动goroutine运行调度器:
c.Run()
cron.Start() 和 cron.Run() 是cron/v3库中启动定时任务调度的两个主要方法,它们的区别是:
-
cron.Start() 直接启动调度,当前goroutine继续执行。如果当前goroutine退出,定时任务也会停止。 -
cron.Run() 内部会启动一个新的goroutine来调用Start方法,可以确保调度持续运行,当前goroutine可以继续做其他工作。
一个例子:
c := cron.New()
c.AddFunc("* * * * *", task)c.Start()
// 当前goroutine退出时,定时任务也会退出c.Run()
// 新goroutine会持续运行定时任务,当前goroutine继续执行
所以,如果需要定时任务持续运行,通常推荐使用cron.Run()方法。
另外,可以通过cron.Stop()来停止一个调度器。
总结区别:
- cron.Start():当前goroutine控制定时任务
- cron.Run():新goroutine运行定时任务,当前goroutine不受影响
日常使用中,cron.Run()配合cron.Stop()可以方便控制定时任务的生命周期。
五、cron表达式格式
cron表达式共5个字段,格式为:
* * * * *
- - - - -
| | | | |
| | | | ----- 星期 - 0-6(0表示星期天)
| | | ------- 月 - 1-12
| | --------- 日 - 1-31
| ----------- 小时 - 0-23
------------- 分钟 - 0-59
例如*/5 * * * *表示每5分钟执行一次。
六、设置时区
可以在创建调度器时指定时区:
loc, _ := time.LoadLocation("Asia/Shanghai")
c := cron.New(cron.WithLocation(loc))
也可以为每个任务设置时区:
c.AddFunc("@hourly", task, cron.WithLocation(loc))
在cron表达式中设置:
CRON_TZ=Asia/Tokyo * * * * *
七、停止调度器
使用Stop方法可以停止调度器:
c.Stop()
以上汇总了使用cron/v3实现Go语言定时任务的相关内容,包括包引用、调度器创建、任务添加、表达式格式、时区设置等,可以提供参考。
//0周日 1周一 2周二 3周三 4周四 5周五 6周六
c := cron.New(cron.WithLocation(loc))
c.AddFunc("33 9 ? * 5", func() {// 打印当前时间fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
})
c.AddFunc("34 9 ? * 5", func() {// 打印当前时间fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
})
c.Run()
更多内容参考：https://github.com/robfig/cron