17370845950

Go并发测试需验证goroutine启动、同步、竞态避免及超时控制：用sync.WaitGroup确保完成，-race检测竞态，select+time.After防死锁。

在 Go 中测试并发函数，核心是验证 goroutine 的行为是否符合预期：是否按需启动、是否正确同步、是否避免竞态、是否在合理时间内完成。不能只测结果，还要测过程逻辑。

用 sync.WaitGroup 等待 goroutine 完成

测试启动多个 goroutine 的函数时，必须确保它们全部执行完毕再断言结果。直接用 time.Sleep 不可靠，应使用 sync.WaitGroup 显式同步。

• 在 goroutine 启动前调用 wg.Add(1)
• 每个 goroutine 结束时调用 wg.Done()
• 主测试协程调用 wg.Wait() 阻塞等待

例如：测试一个并发累加函数，启动 10 个 goroutine 向同一 map 写入，需先加锁或改用 sync.Map，再用 WaitGroup 确保全部写完后检查最终键值数量。

用 -race 标志检测数据竞争

Go 自带竞态检测器是最有效的并发问题发现手段。运行测试时加上 -race 参数：

go test -race ./...

只要存在未受保护的并发读写（如多个 goroutine 同时读写普通 map 或全局变量），就会立即报错并定位到行号。这是验证“线程安全”的强制步骤，不应跳过。

用 select + time.After 控制超时，防止死锁挂起

并发测试容易因 channel 未关闭、goroutine 卡住而无限等待。务必为关键等待逻辑设置超时：

• 用 select 配合 time.After(500 * time.Millisecond) 避免测试卡死
• 对需要接收 channel 数据的测试，不直接 ，而是：
  

  select {
  case val := <-ch:
      // 处理值
  case <-time.After(300 * time.Millisecond):
      t.Fatal("expected value not received in time")
  }

超时时间不宜过短（避开调度延迟），也不宜过长（拖慢整体测试）；建议从 200–500ms 起步，按实际逻辑调整。

用 testify/assert 或原生 t.Error 验证并发副作用

并发函数常产生非确定性副作用（如日志输出、状态变更、channel 发送）。测试时需捕获并断言这些效果：

• 将日志重定向到 bytes.Buffer，检查是否输出了预期内容
• 用原子变量（atomic.Int64）或互斥锁保护的计数器，验证 goroutine 是否真实执行
• 对返回 channel 的函数，用循环 for i := 0; i 收集所有结果再比对

避免依赖“执行顺序”做断言（如“第一个 goroutine 一定先完成”），而应聚焦“最终状态是否满足条件”。