go test -race -run TestBatch -count=50 ./... grep -n 'wg.Add' -r . grep -n 'wg.Wait' -r .
并发任务一多就 panic:`panic: sync: negative WaitGroup counter`,本地单条数据跑一百遍都不出错,压测到几十并发立刻挂,日志里也看不出是哪一批任务多减了一次。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。
追下去是这么回事:Add 写在 goroutine 内部,Wait 可能在 Add 之前就返回,计数被减到负数,正确做法是在启动协程之前就把计数加好,Done 放进 defer 保证异常路径也会执行,顺序不能反。
围绕「WaitGroup 计数错误」排查时,命令行跑一遍比在面板里点十次有用,面板会替你做掉不少隐式操作。同类问题如果隔一段时间又出现,多半是某个定时任务或重启流程把改动冲掉了。
把这次用到的命令存进笔记,比记住结论有用,换个环境还能照着走。
处理上按这个顺序:把计数的加法提到启动协程的那条语句之前;完成通知统一用 defer 包住,保证异常路径也会执行;等待返回之后,不要再复用同一个等待组实例。
确认没问题再收工,五十轮并发压测不再 panic,任务数和完成计数完全对得上,误差为零。
