为什么提供的带有 WaitGroup 和缓冲通道的 Go 代码会导致死锁？

Go 中使用 WaitGroup 和缓冲通道的死锁

Go 中，当多个 goroutine 互相等待完成时会发生死锁，导致陷入僵局。当错误地使用缓冲通道和 WaitGroups 时，可能会出现这种情况。

考虑以下代码：

<code class="go">package main

import "fmt"
import "sync"

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

    var wg sync.WaitGroup
    for i := 0; i <p>此代码预计会创建一个缓冲区大小为 4 的通道并启动 5 个 goroutine ，每个都向通道发送一个空切片。主协程等待所有协程完成，然后在通道上进行范围。</p>
<p>但是，此代码将导致死锁。为什么？</p>
<p><strong>死锁原因：</strong></p>
<p>代码中存在两个问题：</p>
<ol>
<li>通道容量：通道的容量为4，这意味着它最多可以容纳 4 个元素。然而，有 5 个 Goroutine 试图发送到 Channel，导致最后一个 Goroutine 会阻塞等待一个 slot 被释放。</li>
<li>关闭 Channel：range ch 循环继续等待元素进入频道。由于没有更多的 goroutine 可以写入通道，循环将无限期地等待。</li>
</ol>
<p><strong>解决方案：</strong></p>
<ol>
<li>
<p><strong>增加通道容量：</strong>通过将通道容量增加到 5，将有足够的槽位供所有 goroutine 发送它们的值而不会阻塞。此外，在 goroutine 完成写入后关闭通道将向范围循环发出信号，表明不再有元素到来，从而防止它无限期地等待。</p>
<pre class="brush:php;toolbar:false"><code class="go">ch := make(chan []int, 5)
...
wg.Wait()
close(ch)</code>

使用 Done Loop 中的 (): 可以使用 WaitGroup 的 Done() 方法在最后一个 goroutine 完成时发出信号，而不是关闭通道。通过在 range 循环中调用 Done()，当通道为空并且循环可以退出时，主 goroutine 将收到通知。

<code class="go">go func() {
    for c := range ch {
        fmt.Printf("c is %v\n", c)
        wg.Done()
    }
}()
wg.Wait()</code>

这些解决方案通过确保以下方式解决了死锁：通道有足够的容量，并且当没有更多元素可以从通道读取时，范围循环退出。

以上是为什么提供的带有 WaitGroup 和缓冲通道的 Go 代码会导致死锁？的详细内容。更多信息请关注PHP中文网其他相关文章！