使用Goroutine结合time.Ticker或time.Sleep可实现Go中定时任务的并发执行,每个任务在独立协程中运行,通过select和context可控制任务生命周期与优雅停止。

在Golang中实现定时任务并发执行,核心是结合 time.Ticker 或 time.Sleep 与 Goroutine。Go 的轻量级协程让多个定时任务可以安全、高效地并行运行。
每个定时任务可以用一个独立的 Goroutine 运行,内部通过 time.NewTicker 控制执行频率。
例如,有两个任务:每2秒打印日志,每5秒检查状态:func main() {
// 任务1:每2秒执行一次
go func() {
ticker := time.NewTicker(2 * time.Second)
defer ticker.Stop()
for range ticker.C {
fmt.Println("执行日志记录任务")
}
}()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">// 任务2:每5秒执行一次
go func() {
ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()
for range ticker.C {
fmt.Println("执行状态检查任务")
}
}()
// 主协程保持运行
select {}}
如果不需要精确控制或动态启停,for + time.Sleep 更简洁。
go func() {
for {
fmt.Println("每3秒执行一次")
time.Sleep(3 * time.Second)
}
}()
多个定时任务可能访问共享资源(如文件、数据库),需注意并发安全。
立即学习“go语言免费学习笔记(深入)”;
ctx, cancel := context.WithCancel(context.Background())
go func() {
ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()
for {
select {
case <-ticker.C:
fmt.Println("定时任务运行中...")
case <-ctx.Done():
fmt.Println("任务已停止")
return
}
}
}()
<p>// 某个条件触发后停止任务
time.AfterFunc(10*time.Second, cancel)
基本上就这些。Go 的并发模型让定时任务实现变得直观又高效,关键是把每个任务放进独立 Goroutine,再用 Ticker 或 Sleep 控制节奏,同时注意资源同步和退出机制。
以上就是如何在Golang中实现定时任务并发执行的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号