如何拥有一个缓冲通道和多个读取器而不会产生死锁

Question

致命错误 所有 go 例程都处于睡眠状态。僵局。

这就是我尝试过的。我打电话给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)
}

Answer 1

您应该在wg.Wait之前关闭频道。
您的所有接收器都在等待来自频道的数据。这就是你陷入僵局的原因。
您可以在sender函数的语句defer关闭通道。
您还需要wg.Done()第一次尝试从频道接收是否失败（因为频道已经关闭）

http://play.golang.org/p/qdEIEfY-kl

Answer 2

有几件事：

1. 发送程序完成后，您需要关闭通道。
2. 在接收器中，通道范围
3. 无需将 1 添加到等待组并在发件人中呼叫完成

请参考 http://play.golang.org/p/vz39RY6WA7