goroutine 启动后不执行的主因是 main 函数提前退出;应使用 sync.WaitGroup(Add/Done/Wait 配对)、channel 或 time.Sleep 等方式确保 main 等待 goroutine 完成。

goroutine 启动后不执行?检查是否主 goroutine 提前退出
Go 程序中 main 函数返回即整个程序退出,不会等待其他 goroutine 完成。这是最常见“goroutine 没运行”的原因。
典型错误写法:
func main() { go func() { fmt.Println("hello from goroutine") }() // main 直接结束,上面的 goroutine 很可能没来得及打印 }
正确做法是让 main 适当等待,常用方式有:
- 用
time.Sleep()(仅用于测试,不推荐生产) - 用
sync.WaitGroup等待所有任务完成 - 用
channel配合select或阻塞
sync.WaitGroup 是什么?怎么配对使用 Add/Done/Wait
sync.WaitGroup 是控制 goroutine 生命周期的核心工具,但必须严格配对:Add() 和 Done() 数量一致,且 Wait() 必须在所有 Done() 之后才可能返回。
常见错误:
-
Add()在 goroutine 内部调用(应在线程安全位置,如main中) - 忘记调用
Done(),导致Wait()永久阻塞 -
Wait()被多次调用(它不是重入安全的)
正确示例:
func main() { var wg sync.WaitGroup for i := 0; i < 3; i++ { wg.Add(1) // 必须在 go 前调用 go func(id int) { defer wg.Done() // 确保执行 fmt.Printf("task %d donen", id) }(i) } wg.Wait() // 阻塞直到所有 Done() }
goroutine 泄漏:闭包变量捕获引发的意外共享
for 循环中直接使用循环变量启动 goroutine,容易因变量复用导致所有 goroutine 看到同一个值。
错误写法:
for i := 0; i < 3; i++ { go func() { fmt.Println(i) // 全部输出 3(循环结束后 i 的最终值) }() }
修复方式(任选其一):
- 将变量作为参数传入匿名函数:
go func(val int) { ... }(i) - 在循环内定义新变量:
val := i; go func() { fmt.Println(val) }() - 使用 Go 1.22+ 的 loopvar 实验性特性(需开启
GOEXPERIMENT=loopvar)
什么时候该用 channel 而不是 WaitGroup?关注数据流动而非仅同步
WaitGroup 只解决“等完成”,而 channel 解决“等结果”或“协调通信”。如果需要收集返回值、限流、取消、超时,channel 更合适。
例如:并发请求多个 API 并聚合响应:
results := make(chan string, 3) for _, url := range urls { go func(u string) { res, _ := http.Get(u) results <- res.Status }(url) } for i := 0; i < len(urls); i++ { fmt.Println(<-results) // 主动接收,天然带同步语义 }
注意:channel 容量要设好,否则发送方可能阻塞;读取次数必须匹配发送次数,否则会死锁。
goroutine 的本质是轻量级线程,但它的生命周期管理、变量作用域、通信机制都和传统线程不同——错一处,轻则逻辑错乱,重则死锁或泄漏。实际编码时,先想清楚:我要的是「等结束」还是「拿结果」,再决定用 WaitGroup 还是 channel,别凭直觉硬套。