使用time.Ticker可实现每5秒并发执行独立任务;2. time.AfterFunc适合延迟10秒后执行一次性任务;3. 结合context与channel可优雅管理多个定时任务的生命周期,避免goroutine泄漏。

在Go语言中实现定时任务并发执行,关键在于结合 time.Timer、time.Ticker 和 Goroutine 的特性。Go原生支持并发,使得定时任务调度既简洁又高效。下面介绍几种常见的实现方式。
使用 time.Ticker 实现周期性并发任务
对于需要每隔固定时间执行一次的任务,time.Ticker 是理想选择。每个 ticker 会在指定间隔触发一次,配合 goroutine 可避免阻塞主线程。
示例代码:
func startPeriodicTask() {ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()
for range ticker.C {
go func() {
// 执行具体任务,例如请求API或处理数据
fmt.Println("执行定时任务:", time.Now())
}()
}
}
上面的代码每5秒启动一个 goroutine 执行任务,彼此独立,互不阻塞。
立即学习“go语言免费学习笔记(深入)”;
使用 time.AfterFunc 实现单次延迟执行
若需在某个时间点后执行一次任务,可用 time.AfterFunc。它会在延迟结束后自动调用指定函数,并可通过 goroutine 实现并发。
func scheduleOneTimeTask() {delay := 10 * time.Second
timer := time.AfterFunc(delay, func() {
go handleTask()
})
// 可选:在特定条件下停止定时器
// timer.Stop()
}
func handleTask() {
fmt.Println("延迟任务执行于:", time.Now())
}
这种方式适合做延时通知、缓存清理等一次性操作。
多个定时任务的并发管理
当有多个不同类型的任务需要同时调度时,可为每个任务启动独立的 ticker 或 timer,并统一用 goroutine 包装。
建议做法:
- 每个任务封装成独立函数
- 使用 channel 控制生命周期,避免 goroutine 泄漏
- 通过 context 实现优雅关闭
示例:使用 context 控制多个定时任务
func runScheduledTasks(ctx context.Context) {go func() {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()
for {
select {
case go taskA()
case return
}
}
}()
go func() {
ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()
for {
select {
case go taskB()
case return
}
}
}()
}
主程序可通过 cancel context 来统一停止所有任务。
使用第三方库增强调度能力
对于更复杂的场景(如Cron表达式、任务依赖、持久化),可引入成熟库:
- robfig/cron:支持标准 cron 表达式,API 简洁
- go-co-op/gocron:功能丰富,支持立即执行、错误重试等
以 gocron 为例:
scheduler := gocron.NewScheduler(time.UTC)scheduler.Every(2).Seconds().Do(func() {
go heavyTask()
})
scheduler.StartAsync()
这类库内部已处理并发安全和资源释放,适合生产环境。
基本上就这些。Go 的并发模型让定时任务实现变得直观高效,关键是合理使用 ticker、timer 和 context,避免 goroutine 泄漏。简单任务用标准库即可,复杂调度推荐使用 gocron 这类成熟方案。不复杂但容易忽略的是任务退出机制和错误处理,务必加上 recover 防止 panic 导致整个程序崩溃。










