为什么这是golang/waitgroup的死锁？

Question

我不确定我错过了什么但是我遇到了死锁错误.我正在使用一个缓冲的通道,在完成所有程序后我将其范围覆盖.该通道的容量为4,我正在运行4个例程,所以我希望它在达到最大容量后自动"关闭".

package main

import "fmt"
import "sync"

func main() {
    ch := make(chan []int, 4)
    var m []int

    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            ch <- m
            return
        }()
    }
    wg.Wait()

    for c := range ch {
        fmt.Printf("c is %v", c)
    }
}

Answer 1

我正在运行4个例行程序

不,你正在运行5 - 因此死锁,因为通道只缓冲4条消息.

但是,迭代通道将在以后使程序死锁.由于通道未关闭,一旦读取了5个值,它将永远阻塞.

所以,

ch := make(chan []int, 5)

和

close(ch) 

在range循环之前.

Answer 2

你有两个问题:

• 由于你的频道太小,所以goroutines都没有足够的位置:当你的频道已满时,其余的goroutines必须等待一个插槽被释放
• range ch 仍然在等待频道中的元素进入,并且没有留下任何goroutine来写它.

解决方案1:

使通道足够大,关闭它以便range停止等待:

ch := make(chan []int, 5)
...
wg.Wait()
close(ch)

示范

这可以工作,但这主要是因为你没有在所有任务完成之前开始打印,所以这里的通道的目的就失败了.

解决方案2: 此解决方案允许真正的流水线操作(即较小的通道缓冲区),将Done()在打印时执行:

func main() {
    ch := make(chan []int, 4)
    var m []int

    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            ch <- m
            return
        }()
    }
    go func() {
        for c := range ch {
            fmt.Printf("c is %v\n", c)
            wg.Done()
        }
    }()
    wg.Wait()
}

示范