使用time.Ticker可实现每5秒执行一次日志清理的周期性任务,通过监听其C channel触发逻辑并用defer stop避免泄漏。

在Go语言开发中,定时任务是常见的需求,比如每天凌晨统计报表、每隔几分钟同步数据等。Golang本身提供了简洁高效的机制来实现定时任务,不需要依赖第三方框架也能轻松完成。
使用 time.Ticker 实现周期性任务
Go的 time.Ticker 可以按固定时间间隔触发任务,适合执行周期性的操作。
例如,每5秒执行一次日志清理:
- 创建一个 ticker,设置时间间隔
- 用 for 循环监听其 C channel
- 收到信号后执行具体逻辑
- 程序退出时记得 stop ticker 防止资源泄露
代码示例:
立即学习“go语言免费学习笔记(深入)”;
package main
<p>import (
"fmt"
"time"
)</p><p>func main() {
ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()</p><pre class="brush:php;toolbar:false;">for range ticker.C {
fmt.Println("执行定时清理任务:", time.Now())
// 这里写具体的业务逻辑
}}
使用 time.Timer 实现单次延迟任务
如果只需要延迟执行一次,比如10秒后发送提醒,用 time.Timer 更合适。
它只会触发一次,之后需要重新创建。
示例:10秒后发送通知
timer := time.NewTimer(10 * time.Second)
<-timer.C
fmt.Println("10秒已到,发送提醒")
也可以通过 Reset 方法重复使用 Timer,但要注意并发安全。
模拟 Cron 行为:每天固定时间运行
有些任务需要在每天某个时间点运行,比如凌晨2点备份数据。这种场景可以用循环加时间计算来实现。
思路是:
- 计算今天目标时间(如 02:00:00)
- 如果已过,则加24小时作为下次触发时间
- 用 time.Until 得出等待时长
- 用 Timer 等待并执行
- 执行完继续下一轮
代码片段:
func runDailyAt(hour, min, sec int, task func()) {
for {
now := time.Now()
next := time.Date(now.Year(), now.Month(), now.Day(), hour, min, sec, 0, now.Location())
<pre class="brush:php;toolbar:false;"> if next.Before(now) {
next = next.Add(24 * time.Hour)
}
timer := time.NewTimer(time.Until(next))
<-timer.C
task()
}}
// 使用 go runDailyAt(2, 0, 0, func() { fmt.Println("开始执行每日备份") })
控制并发与错误处理
实际项目中要避免任务重叠执行。比如前一次还没结束,下一次又开始了。
可以加锁或使用布尔标志位防止并发:
var running bool
var mu sync.Mutex
<p>func safeTask() {
mu.Lock()
if running {
mu.Unlock()
return
}
running = true
mu.Unlock()</p><pre class="brush:php;toolbar:false;">// 执行任务
fmt.Println("任务开始")
time.Sleep(3 * time.Second) // 模拟耗时
fmt.Println("任务结束")
mu.Lock()
running = false
mu.Unlock()}
同时建议把任务包裹在 defer recover 中,防止 panic 导致整个程序退出。
基本上就这些。Golang的定时任务并不复杂,关键是根据场景选择 Ticker、Timer 或手动计算时间。合理管理资源和异常,就能稳定运行在生产环境。










