Golang - 带有通道和等待组的管道，发送关闭通道恐慌错误

Question

人们试图理解为什么下面的代码会产生一个panic: send on closed channel 该应用程序有几个阶段。生产者生成随机数并将它们发送到通道。模拟几个工人需要处理这些消息的场景，等待一秒钟，然后将它们发送到最后阶段。func main() {    var wg sync.WaitGroup    numOfConcurrentWorkers := 2    sourceCH := make(chan int)    destCH := make(chan int)    // source stage    wg.Add(1)    go func(wg *sync.WaitGroup, out chan int) {        defer wg.Done()        data := rand.Perm(10)        for _, i := range data {            out <- i        }        close(out)    }(&wg, sourceCH)    // mid stage    wg.Add(numOfConcurrentWorkers)    for c := 0; c < numOfConcurrentWorkers; c++ {        go func(wg *sync.WaitGroup, in <-chan int, out chan int) {            defer wg.Done()            for i := range in {                time.Sleep(1 * time.Second)                out <- i            }            close(out)        }(&wg, sourceCH, destCH)    }    // final stage    wg.Add(1)    go func(wg *sync.WaitGroup, in <-chan int) {        defer wg.Done()        for i := range in {            log.Print("final ", i)        }    }(&wg, destCH)    wg.Wait()}

Answer 1

在中间阶段，每个 goroutine 都在关闭共享输出通道，所以当第一个 goroutine 关闭它时，所有其他尝试写入它的 goroutine 都会失败。

当所有中期工作人员完成时关闭它。为此使用单独的等待组。