本文解析 Goroutine 循环中因 wg.Wait() 被误置于 process 函数内导致协程阻塞、迭代中断的根本原因，并提供正确使用 WaitGroup 和避免闭包变量捕获错误的完整实践方案。
本文解析 goroutine 循环中因 `wg.wait()` 被误置于 `process` 函数内导致协程阻塞、迭代中断的根本原因，并提供正确使用 waitgroup 和避免闭包变量捕获错误的完整实践方案。
在 Go 并发编程中，上述代码看似合理：遍历 sams 切片，为每个元素启动一个 goroutine 处理其对应的 pid 列表。但实际运行时，仅第一个 pid 被处理，后续 goroutine 未继续执行——这并非循环本身中断，而是所有 goroutine 均被阻塞在 process 内部的 wg.Wait() 上，造成死锁式挂起。
关键问题在于：wg.Wait() 不应出现在工作函数（如 process）内部，而应由主 goroutine 在所有任务启动后统一调用，用于等待全部子任务完成。一旦 process 中调用了 wg.Wait()，每个 goroutine 都会立即阻塞，等待一个永远无法满足的条件（因为其他 goroutine 同样卡住，wg.Done() 永远不会被执行），从而形成级联阻塞。
此外，原始代码还存在经典的循环变量捕获问题：
for _, v := range sams {
sam := v
pid := getPracticeIdBySam(db, sam)
go func() { // ❌ 匿名函数未接收参数，直接引用外部变量 sam/pid（可能已变更）
defer wg.Done()
for _, v := range pid {
process(db, stmt, v, min_year, max_year, bar)
}
}()
}尽管已用 sam := v 做了一层拷贝，但 pid 是在循环体中计算的，若 getPracticeIdBySam 是异步或耗时操作，多个 goroutine 仍可能共享同一 pid 变量（尤其在编译器优化下）。更安全的做法是将所需参数显式传入 goroutine：
AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序，基于浩创云、ThinkPHP（PHP）开发，支持微信服务号与 H5 端，适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。
✅ 正确写法（修复双重问题）：
var wg sync.WaitGroup
for _, sam := range sams {
wg.Add(1)
// 显式传参，彻底隔离闭包变量
go func(sam string) {
defer wg.Done()
pid := getPracticeIdBySam(db, sam) // 在 goroutine 内获取，确保数据归属明确
for _, id := range pid {
process(db, stmt, id, min_year, max_year, bar)
}
}(sam)
}
// 主 goroutine 最后统一等待 —— 这才是 wg.Wait() 的唯一正确位置
wg.Wait()⚠️ 注意事项：
- wg.Add(1) 必须在 go 语句前调用，避免竞态（若放在 goroutine 内，可能因调度延迟导致 wg.Wait() 先执行）；
- process 函数中绝对禁止出现 wg.Wait() 或任何阻塞当前 goroutine 等待其他 goroutine 完成的逻辑；
- 若 process 本身需并发执行子任务，请为其单独创建新的 sync.WaitGroup，切勿复用外层 wg；
- 对于大量 goroutine，建议结合 semaphore（如 golang.org/x/sync/semaphore）控制并发数，防止资源耗尽。
总结：Go 并发调试需同时关注同步原语的职责边界（WaitGroup 的 Add/Done/Wait 三者必须配对且位置合规）和闭包变量生命周期（优先显式传参而非隐式捕获）。二者任一失当，都可能导致静默失败或难以复现的阻塞行为。
