在 Go 中 for 循环内直接启动 goroutine 时，若匿名函数引用循环变量（如 ctx、ip 或 pingOneMachine），会因闭包按引用捕获变量而导致所有 goroutine 实际共享同一份值，造成逻辑错误或仅执行最后一次迭代——这是并发编程中最经典也最易被忽视的陷阱。
在 go 中 for 循环内直接启动 goroutine 时，若匿名函数引用循环变量（如 `ctx`、`ip` 或 `pingonemachine`），会因闭包按引用捕获变量而导致所有 goroutine 实际共享同一份值，造成逻辑错误或仅执行最后一次迭代——这是并发编程中最经典也最易被忽视的陷阱。
你提供的代码存在两个关键问题，它们共同导致“只对一个设备生效”的表象：
? 问题一：ctx 和 pingOneMachine 变量被意外复用（核心陷阱）
for _, ip := range listOfDevices {
// ... 省略中间逻辑 ...
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
defer cancel() // ⚠️ 危险！此处 defer 在循环外统一执行，仅取消最后一次 ctx
wg.Add(len(listOfDevices))
go func() {
defer wg.Done()
pingOneMachine.Run(ctx) // ❌ 所有 goroutine 共享同一个 ctx 和 pingOneMachine 实例！
}()
}-
pingOneMachine是在每次循环中新建的，但变量名pingOneMachine在循环中被反复赋值，其内存地址始终唯一； -
ctx同理：每次迭代都创建新ctx，但defer cancel()会累积注册（且最终只生效最后一次），而 goroutine 中读取的ctx始终是循环结束时的最后一个值； - 更严重的是：
pingOneMachine.Run(ctx)中的ctx和pingOneMachine都是循环变量，所有 goroutine 捕获的是它们的地址而非快照值。当 goroutine 真正调度执行时，循环早已结束，pingOneMachine指向最后一个设备的探测器，ctx已超时或被取消。
✅ 正确做法：显式将当前迭代所需值作为参数传入 goroutine（推荐，语义清晰、无歧义）：
for _, ip := range listOfDevices {
inChan <- types.NewNotification(time.Now(), "/cloudtracer/status", nil,
&map[key.Key]interface{}{
key.New(ip): types.Pointer{Pointer: "/cloudtracer/status/" + ip},
})
pingOneMachine := probe.NewPing(ip, 2*time.Second, inChan)
// ✅ 每次迭代独立创建 ctx，并立即传入 goroutine
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
// 注意：此处 cancel 应在 goroutine 内部调用，或使用单独 defer（见下文）
wg.Add(1) // ⚠️ 放在 goroutine 启动前，且每次 +1（非 len(listOfDevices)）
go func(c context.Context, p *probe.Ping) {
defer wg.Done()
defer cancel() // ✅ 在 goroutine 内部安全 cancel，避免泄漏
p.Run(c)
}(ctx, pingOneMachine) // 显式传参：确保每个 goroutine 拥有专属副本
}
wg.Wait()? 提示：
wg.Add(1)必须在go func()之前调用，且每次循环只加 1；若写成wg.Add(len(listOfDevices))放在循环体内，会导致计数翻倍甚至 panic。
? 问题二：defer cancel() 位置错误（资源泄漏风险）
原代码中 defer cancel() 写在循环体顶层，会导致：
- 所有
defer注册到main函数退出时才执行； - 仅最后一次
cancel()生效，其余ctx无法及时释放，可能引发上下文泄漏或探测器长时间挂起。
✅ 解决方案：将 cancel() 移入 goroutine，并搭配 defer —— 既保证及时释放，又避免跨 goroutine 调用竞态。
?️ 进阶建议：使用 range + 值拷贝（适用于小结构体）
若 probe.Ping 是轻量结构体（非指针），也可在循环内声明局部副本：
for _, ip := range listOfDevices {
ip := ip // ✅ 遮蔽循环变量，创建独立副本
pingOneMachine := probe.NewPing(ip, 2*time.Second, inChan)
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
wg.Add(1)
go func() {
defer wg.Done()
defer cancel()
pingOneMachine.Run(ctx)
}()
}⚠️ 注意：此方式仅当 pingOneMachine 是值类型且无需跨 goroutine 共享状态时安全；若其内部含 channel、mutex 或需复用连接，则必须传指针并确保线程安全。
✅ 最终验证要点
- 使用
go vet检查：它会警告loop variable ip captured by func literal； - 添加日志确认每 goroutine 处理真实 IP：
fmt.Printf("pinging %s\n", ip)； - 避免在循环中
defer资源清理操作，一律移至 goroutine 内部； - 性能权衡：若
listOfDevices规模大（如 >1000），考虑引入 worker pool 控制并发度，防止系统过载。
掌握这一模式，你不仅能修复当前问题，更能规避 http.Handler 注册、定时任务分发、批量 API 调用等几乎所有并发循环场景中的隐性 Bug。
