并行运行多个Goroutine收集结果时遭遇死锁错误求助

兄弟，你这个死锁问题我太熟了——大概率是channel没被正确关闭，导致主goroutine卡在for range里一直等数据，可所有子goroutine都跑完了，没人再发数据也没人关channel，直接就死锁了。咱们结合你的代码结构一步步说清楚问题和修复办法。

你的代码核心问题在哪？ #

从你贴的代码片段来看，你启动了numBatch个BackPropagate goroutine往deltaChan里发结果，然后用for delta := range deltaChan来收数据。但这里有个致命漏洞：当所有子goroutine都完成发送后，你没关闭deltaChan。for range遍历channel的逻辑是——只要channel没关，就会一直阻塞等新数据，可此时所有goroutine都已经结束（WaitGroup就算等完了也没用），整个程序里没有任何goroutine再往channel写东西，也没人关它，这不就死锁了嘛！

另外还要确认下BackPropagate里有没有正确调用wg.Done()——要是某个goroutine忘了调，WaitGroup会一直等，也可能间接导致死锁，但结合你给出的错误信息，channel未关闭是最可能的原因。

修复方案直接上代码 #

核心思路就是：等所有子goroutine都跑完后，关闭channel，让for range知道“没数据了，可以停了”。但不能直接在主goroutine里先等WaitGroup再关channel（那样子goroutine往无缓冲channel发数据会阻塞），得单独开个goroutine来做这件事。

修复后的完整代码示例 #

func Function(inputs) {
    var wg sync.WaitGroup
    wg.Add(numBatch)
    deltaChan := make(chan DeltaPair)

    // 启动所有BackPropagate子goroutine
    for b := 1; b <= numBatch; b++ {
        // ... 这里放你的前置计算逻辑
        go BackPropagate(otherinputs, deltaChan, &wg)
    }

    // 开个单独的goroutine，等所有任务完成后关闭channel
    go func() {
        wg.Wait() // 等所有BackPropagate都干完
        close(deltaChan) // 关channel，通知for range可以结束了
    }()

    // 安心遍历收集结果
    for delta := range deltaChan {
        // ... 这里处理每个delta的逻辑
    }
}

// 一定要确保BackPropagate里正确调用wg.Done()！
func BackPropagate(otherinputs interface{}, deltaChan chan<- DeltaPair, wg *sync.WaitGroup) {
    defer wg.Done() // 用defer兜底，哪怕函数panic了也能通知WaitGroup
    // ... 你的反向传播计算逻辑
    deltaChan <- calculatedDelta // 把结果发去channel
}

关键修复点解释 #

1. 用defer确保wg.Done()必被调用：在BackPropagate开头加defer wg.Done()，不管函数是正常结束还是中途panic，都能正确告诉WaitGroup“我干完了”，避免WaitGroup一直挂着等。
2. 单独goroutine关闭channel：要是主goroutine先跑wg.Wait()，那for range还没开始接收，子goroutine往无缓冲channel发数据会直接阻塞，反而又死锁了。所以单独开个goroutine等WaitGroup完成后关channel，主goroutine就能同时在for range里收数据，完美配合。
3. channel关闭后for range自动退出：当channel被关闭，for range遍历完所有剩余数据后就会自动退出循环，不会一直阻塞，程序就能正常收尾。

额外排查点 #

• 如果你的deltaChan是无缓冲channel，上面的方案已经完全覆盖了，不用额外调整。
• 要是担心子goroutine panic导致wg.Done()没执行，可以在BackPropagate里加个recover逻辑，比如：

  func BackPropagate(...) {
      defer wg.Done()
      defer func() {
          if r := recover(); r != nil {
              // 这里可以记录panic日志，避免程序崩溃
              log.Printf("BackPropagate panic: %v", r)
          }
      }()
      // ... 计算逻辑
  }
  

内容的提问来源于stack exchange，提问作者spugia