time.Ticker可用于周期性执行任务,如每2秒触发一次操作,通过ticker.C接收信号,需调用ticker.Stop()防止资源泄漏;结合select与退出channel可实现优雅停止,适用于服务常驻场景;若只执行N次,可用for循环控制次数;与time.Timer区别在于Ticker周期触发,Timer仅触发一次,使用时需注意及时释放资源。
在go语言中实现定时任务,time.Ticker 是一个非常实用的工具。它能按照指定的时间间隔持续触发事件,非常适合用于周期性执行某些操作,比如定时上报日志、定期清理缓存、健康检查等场景。
time.Ticker 基本用法
time.Ticker 会每隔一段时间发送一个信号到它的 Channel(C),你可以通过读取这个 Channel 来触发任务。
创建一个每2秒执行一次的任务示例:
ticker := time.NewTicker(2 * time.Second) defer ticker.Stop() // 避免资源泄漏 <p>for range ticker.C { fmt.Println("执行定时任务:", time.Now()) }</p>
上面代码中,NewTicker 创建了一个每2秒触发一次的 Ticker,ticker.C 是一个 time.Time 类型的 channel,每次到达间隔时间就会写入当前时间。使用 defer ticker.Stop() 很重要,防止 Goroutine 和系统资源泄漏。
立即学习“go语言免费学习笔记(深入)”;
带退出控制的定时任务
实际开发中,通常需要能够优雅地停止定时任务,比如程序关闭时。可以通过 select 结合退出 channel 实现:
ticker := time.NewTicker(3 * time.Second) defer ticker.Stop() <p>quit := make(chan bool)</p><p>go func() { time.Sleep(10 * time.Second) // 模拟运行一段时间后退出 quit <- true }()</p><p>for { select { case <- ticker.C: fmt.Println("定时任务执行中...", time.Now()) case <- quit: fmt.Println("收到退出信号,停止定时任务") return } }</p>
这种方式让定时任务可以响应外部控制,适用于服务常驻进程中的场景。
只执行N次的定时任务
如果只想让任务执行固定次数,可以用 for-range 配合计数器:
ticker := time.NewTicker(1 * time.Second) defer ticker.Stop() <p>for i := 0; i < 5; i++ { <- ticker.C fmt.Printf("第 %d 次执行: %vn", i+1, time.Now()) } </font></p>
这种方式比使用 time.Sleep 更精确,因为 ticker 能保证每次间隔严格对齐。
与 time.Timer 的区别
time.Timer 只触发一次,而 time.Ticker 是周期性触发。如果你只需要延迟执行一次,用 Timer 更合适;如果是循环任务,Ticker 更自然。
注意:Ticker 在不再使用时必须调用 Stop(),否则会导致 Goroutine 泄漏,即使程序逻辑已经退出。
基本上就这些。合理使用 time.Ticker,再配合 select 和 channel 控制,就能写出稳定可靠的定时任务逻辑。不复杂但容易忽略细节,尤其是资源释放。