Go语言goroutine入门指南

本文深入剖析了Go语言中goroutine常见失效问题的根本原因——main函数提前退出导致所有后台协程被强制终止，并系统讲解了如何通过sync.WaitGroup或channel进行可靠同步：强调Add与Done必须严格守恒、wg.Add(1)须在goroutine启动前调用、defer wg.Done()保障异常安全，同时指出循环变量捕获陷阱、WaitGroup误用风险及高并发场景下的资源失控隐患，最后给出基于带缓冲channel的优雅限流方案，帮助开发者写出健壮、可维护的并发代码。

goroutine 启动后没输出？main 提前退出了

Go 程序一执行完 main 函数就立刻终止，不管还有多少 goroutine 没跑完。这是 90% 的“goroutine 没运行”问题的根源。

• 常见错误现象：go fmt.Println("hello") 后什么也没打印，程序静默结束
• 根本原因：main 函数末尾返回 → 整个进程退出 → 所有未完成的 goroutine 被强制杀死
• 临时验证（仅限本地调试）：加 time.Sleep(1 * time.Second) 看是否能打出日志 —— 如果能，就是等待机制缺失
• 生产环境必须用 sync.WaitGroup 或 channel 显式同步，不能靠 time.Sleep

WaitGroup 怎么配对才不 panic？Add/Done 必须守恒

sync.WaitGroup 不是“启动几个就自动等几个”，它靠计数器工作，错一个 Add 或漏一个 Done 就会卡死或 panic。

• 必须在 go 语句前调用 wg.Add(1)，不能放在 goroutine 内部
• defer wg.Done() 是最安全写法，确保 panic 时也能释放计数
• 循环中启动 goroutine 时，别直接捕获循环变量：for i := 0; i 会全打印 3；改用 go func(val int) { ... }(i) 或 val := i; go func() { ... }()
• wg.Wait() 只能调用一次，且不能在多个 goroutine 里并发调用

怎么控制并发数量？别直接 for 循环起 1000 个 goroutine

业务逻辑一多，for range tasks { go process(t) } 容易瞬间拉起成千上万个 goroutine，吃光内存、打爆下游接口，甚至触发系统级 OOM。

• 推荐方案：用带缓冲的 sem := make(chan struct{}, 10) 当信号量，限制最大并发为 10
• 每个任务开始前写 sem （阻塞直到有空位），结束后用 defer func() { 归还
• 别用 runtime.GOMAXPROCS 控制并发数 —— 它只影响 P 数量，和你的业务并发无关
• 第三方库如 ants 在 IO 密集场景多数是过度设计；标准库 errgroup.Group 更适合需要“任一失败即取消全部”的场景

结果怎么收？range channel 卡住或提前退出的真相

用 chan Result 收集并发结果时，for r := range results 会一直阻塞，除非 channel 被关闭 —— 而关闭时机错了，就会 panic 或丢数据。

• 必须由**唯一 goroutine** 关闭结果 channel，且只能在所有发送者都退出后
• 正确姿势：另起一个 goroutine 调用 wg.Wait()，然后 close(results)
• 多个 goroutine 同时 close(results) → panic “close of closed channel”
• 某个 goroutine panic 且没 recover，defer wg.Done() 仍会执行，但结果不会发出去 —— 如需容错，得配 err chan 或用 errgroup

goroutine 本身很轻，但调度、通信、生命周期管理这些细节，一不留神就从“并发变快”变成“并发变崩”。真正难的不是写 go f()，而是写清楚谁等谁、谁关 channel、谁负责回收。

到这里，我们也就讲完了《Go语言goroutine入门指南》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！