Golang使用time.Ticker控制并发任务执行-Golang-PHP中文网

Golang使用time.Ticker控制并发任务执行

P粉602998670

发布： 2025-09-18 13:39:02

原创

446人浏览过

使用time.Ticker可实现周期性任务调度，结合goroutine与channel控制并发执行；通过带缓冲channel限制最大并发数，避免资源耗尽；引入context实现优雅停止，适用于定时采集、心跳检测等场景。

golang使用time.ticker控制并发任务执行

在Go语言中，time.Ticker 是一种非常实用的工具，用于周期性地触发任务。当需要控制并发任务按固定频率执行时（比如每秒处理一批任务），结合 goroutine 和 channel 使用 time.Ticker 可以实现稳定、可控的调度机制。

使用 Ticker 周期触发任务

time.Ticker 会每隔指定时间发送一个事件到其 C channel 中，我们可以监听这个 channel 来驱动任务执行。

例如：每500毫秒执行一次数据采集任务：

ticker := time.NewTicker(500 * time.Millisecond)
defer ticker.Stop()
<p>for {
select {
case <-ticker.C:
go func() {
// 并发执行任务
fetchData()
}()
}
}</p>

登录后复制

这种方式确保任务每隔500ms被触发一次，且通过 go 关键字启动新的 goroutine 执行，避免阻塞 ticker 的主循环。

立即学习“go语言免费学习笔记（深入）”；

控制并发数量防止资源耗尽

虽然上面的方式可以实现周期性触发，但如果每次都无限制地开启 goroutine，可能造成系统资源耗尽。建议引入信号量或带缓冲的 channel 来限制最大并发数。

示例：最多允许3个并发任务运行：

行者AI

行者AI绘图创作，唤醒新的灵感，创造更多可能

100

查看详情

semaphore := make(chan struct{}, 3) // 最多3个并发
<p>ticker := time.NewTicker(200 * time.Millisecond)
defer ticker.Stop()</p><p>for {
select {
case <-ticker.C:
select {
case semaphore <- struct{}{}: // 获取许可
go func() {
defer func() { <-semaphore }() // 释放许可
fetchData()
}()
default:
// 并发已达上限，跳过本次执行或排队
log.Println("too many concurrent tasks, skip")
}
}
}</p>

登录后复制

这样即使触发频繁，也不会超过设定的并发上限，保护系统稳定性。

结合 context 实现优雅停止

在实际服务中，通常需要支持中断和退出。使用 context 可以安全地关闭 ticker 和正在运行的任务。

ctx, cancel := context.WithCancel(context.Background())
ticker := time.NewTicker(1 * time.Second)
<p>go func() {
time.Sleep(5 * time.Second)
cancel() // 5秒后停止
}()</p><p>for {
select {
case <-ctx.Done():
ticker.Stop()
return
case <-ticker.C:
select {
case semaphore <- struct{}{}:
go func() {
defer func() { <-semaphore }()
if err := doWork(ctx); err != nil {
log.Printf("work failed: %v", err)
}
}()
default:
log.Println("concurrent limit reached, skip")
}
}
}</p>

登录后复制

通过监听 ctx.Done()，程序可以在收到取消信号时退出循环并停止 ticker，实现优雅关闭。

基本上就这些。合理使用 time.Ticker 配合并发控制手段，能有效管理周期性任务的执行节奏与资源占用，适合监控采集、定时上报、心跳检测等场景。

以上就是Golang使用time.Ticker控制并发任务执行的详细内容，更多请关注php中文网其它相关文章！