Go语言中实现定时任务主要有三种方式:1. 使用time.Ticker实现周期性任务,如每5秒执行一次;2. 使用time.AfterFunc实现一次性延迟任务;3. 使用robfig/cron库支持复杂调度规则,如每天8点执行。此外,可通过sync.Mutex防止任务重入,避免并发执行问题。

在Go语言中实现定时任务调度功能,有多种方式可以选择。最常见的是使用标准库 time.Timer 和 time.Ticker,以及第三方库如 robfig/cron 来实现更复杂的调度规则。下面通过几个典型示例展示如何在Golang中实现定时任务。
1. 使用 time.Ticker 实现周期性任务
适用于每隔固定时间执行一次的任务,比如每5秒打印一条日志。
package mainimport ( "fmt" "time" )
func main() { ticker := time.NewTicker(5 * time.Second) defer ticker.Stop()
for { select { case <-ticker.C: fmt.Println("执行定时任务:", time.Now()) } }}
说明: time.NewTicker 创建一个周期性触发的 Ticker,通过监听其通道 ticker.C 可以在每次到达间隔时执行任务。记得调用 Stop() 防止资源泄漏。
立即学习“go语言免费学习笔记(深入)”;
2. 使用 time.AfterFunc 实现延迟执行
适用于只执行一次的延时任务,例如3秒后发送通知。
package mainimport ( "fmt" "time" )
func main() { timer := time.AfterFunc(3*time.Second, func() { fmt.Println("延迟任务执行:", time.Now()) })
// 阻塞主线程,确保程序不会提前退出 time.Sleep(5 * time.Second) timer.Stop() // 如果需要可以取消}
说明: AfterFunc 在指定时间后自动调用函数。适合一次性任务,也可以结合循环实现重复调度。
3. 使用 cron 库实现复杂调度(如每天凌晨执行)
安装 robfig/cron:
go get github.com/robfig/cron/v3
示例代码:每天早上8点执行任务。
package mainimport ( "fmt" "time" "github.com/robfig/cron/v3" )
func main() { c := cron.New()
// 添加任务:每天 8:00 执行 c.AddFunc("0 8 * * *", func() { fmt.Println("每日任务执行:", time.Now()) }) c.Start() defer c.Stop() // 保持程序运行 select {}}
说明: cron 表达式支持秒级(v3版本)或分钟级精度。常用格式为:秒 分 时 日 月 周。
例如:"0 0 2 * * *" 表示每天凌晨2点执行"。
4. 控制并发与防止重入
某些任务耗时较长,需避免多个实例同时运行。可通过互斥锁控制。
package mainimport ( "fmt" "sync" "time" "github.com/robfig/cron/v3" )
func main() { var mu sync.Mutex isRunning := false
c := cron.New() c.AddFunc("@every 10s", func() { mu.Lock() if isRunning { fmt.Println("任务正在执行,跳过本次调度") mu.Unlock() return } isRunning = true mu.Unlock() // 模拟耗时任务 fmt.Println("任务开始:", time.Now()) time.Sleep(15 * time.Second) fmt.Println("任务结束:", time.Now()) mu.Lock() isRunning = false mu.Unlock() }) c.Start() defer c.Stop() select {}}
说明: 使用 sync.Mutex 和状态标志防止任务被重复触发,特别适用于执行时间可能超过调度周期的情况。
基本上就这些。根据实际需求选择合适的方式:简单周期用 Ticker,复杂时间表达式用 cron,注意控制并发和资源释放即可。










