使用time.Ticker可实现周期性任务调度，结合goroutine与channel控制并发执行；通过带缓冲channel限制最大并发数，避免资源耗尽；引入context实现优雅停止，适用于定时采集、心跳检测等场景。
在Go语言中，time.Ticker 是一种非常实用的工具，用于周期性地触发任务。当需要控制并发任务按固定频率执行时（比如每秒处理一批任务），结合 goroutine 和 channel 使用 time.Ticker 可以实现稳定、可控的调度机制。
使用 Ticker 周期触发任务
time.Ticker 会每隔指定时间发送一个事件到其 C channel 中，我们可以监听这个 channel 来驱动任务执行。
例如：每500毫秒执行一次数据采集任务：
ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop()for { select { case <-ticker.C: go func() { // 并发执行任务 fetchData() }() } }
这种方式确保任务每隔500ms被触发一次，且通过 go 关键字启动新的 goroutine 执行，避免阻塞 ticker 的主循环。
立即学习“go语言免费学习笔记（深入）”；
控制并发数量防止资源耗尽
虽然上面的方式可以实现周期性触发，但如果每次都无限制地开启 goroutine，可能造成系统资源耗尽。建议引入信号量或带缓冲的 channel 来限制最大并发数。
客客出品专业威客系统英文名称KPPW，也是keke produced professional witkey的缩写。KPPW是一款基于PHP+MYSQL技术构架的威客系统，积客客团队多年实践和对威客模式商业化运作的大量调查分析而精心策划研发，是您轻松搭建威客网站的首选利器。KPPW针对威客任务和商品交易模式进行了细致的分析，提供完善威客任务流程控制解决方案，并将逐步分享威客系统专业化应用作为我们的
示例：最多允许3个并发任务运行：
semaphore := make(chan struct{}, 3) // 最多3个并发
ticker := time.NewTicker(200 * time.Millisecond)
defer ticker.Stop()
for {
select {
case <-ticker.C:
select {
case semaphore <- struct{}{}: // 获取许可
go func() {
defer func() { <-semaphore }() // 释放许可
fetchData()
}()
default:
// 并发已达上限，跳过本次执行或排队
log.Println("too many concurrent tasks, skip")
}
}
}
这样即使触发频繁，也不会超过设定的并发上限，保护系统稳定性。
结合 context 实现优雅停止
在实际服务中，通常需要支持中断和退出。使用 context 可以安全地关闭 ticker 和正在运行的任务。
ctx, cancel := context.WithCancel(context.Background()) ticker := time.NewTicker(1 * time.Second)go func() { time.Sleep(5 * time.Second) cancel() // 5秒后停止 }()
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") } } }
通过监听 ctx.Done()，程序可以在收到取消信号时退出循环并停止 ticker，实现优雅关闭。
基本上就这些。合理使用 time.Ticker 配合并发控制手段，能有效管理周期性任务的执行节奏与资源占用，适合监控采集、定时上报、心跳检测等场景。
