Go语言使用cron/v3实现定时任务

一、获取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()