go - 如何在不产生死锁的情况下拥有一个缓冲 channel 和多个读取器？

这就是我尝试过的。我正在调用wg.Done()。什么不见​​了？

package main

import (
    "fmt"
    "strconv"
    "sync"
)

func sender(wg *sync.WaitGroup, cs chan int) {
    defer wg.Done()
    for i := 0; i < 2; i++ {
        fmt.Println(i)
        cs <- i
    }
}

func reciever(wg *sync.WaitGroup, cs chan int) {
    x, ok := <-cs
    for ok {
        fmt.Println("Retrieved" + strconv.Itoa(x))
        x, ok = <-cs
        if !ok {
            wg.Done()
            break
        }
    }
}

func main() {
    wg := &sync.WaitGroup{}
    cs := make(chan int, 1000)
    wg.Add(1)
    go sender(wg, cs)
    for i := 1; i < 30; i++ {
        wg.Add(1)
        go reciever(wg, cs)
    }
    wg.Wait()
    close(cs)
}

最佳答案

您应该在wg.Wait之前关闭 channel 。
您的所有接收器都在等待来自 channel 的数据。这就是为什么您会陷入僵局。
您可以在defer函数的sender语句中关闭 channel 。
另外，如果第一次尝试从 channel 接收失败(因为 channel 已关闭)，则需要wg.Done()
http://play.golang.org/p/qdEIEfY-kl

关于go - 如何在不产生死锁的情况下拥有一个缓冲 channel 和多个读取器？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/35602060/