为什么在 Go 通道中按值传递 WaitGroup 会导致死锁？

Go Channel 由于引用传递而出现死锁

在 Go 中，通道是一种强大的通信机制，但如果不这样做，可能会导致死锁正确使用。当两个或多个 goroutine 互相等待对方完成操作，导致两个 goroutine 都无法继续执行时，就会发生死锁。

考虑以下 Go 程序：

<br>包主<p>导入(</p><pre class="brush:php;toolbar:false">"fmt"
"sync"

)

func push(c chan int, wgsync.WaitGroup) {

for i := 0; i < 5; i++ {
    c <- i
}
wg.Done()

}

func pull(c chan int, wg 同步.WaitGroup) {

for i := 0; i < 5; i++ {
    result, ok := <-c
    fmt.Println(result, ok)
}
wg.Done()

}

func main() {

var wg sync.WaitGroup
wg.Add(2)
c := make(chan int)

go push(c, wg)
go pull(c, wg)

wg.Wait()

}

当你运行这个程序，它会因死锁错误而恐慌：

throw: all goroutines are asleep - deadlock!

问题关键在于 WaitGroup 如何传递给 goroutine。在 Go 中，结构体是按值传递的，这意味着 WaitGroup 的副本会传递给每个 goroutine。当一个 goroutine 在其副本上调用 Done 时，它​​对在 main 函数中创建的原始 WaitGroup 没有影响。

要修复死锁，必须传递 WaitGroup 指针而不是值。这是更正后的代码：

<br>package main</p><p>import (</p><pre class="brush:php;toolbar:false">"fmt"
"sync"

)

func push(c chan int , wg *sync.WaitGroup) {

for i := 0; i < 5; i++ {
    c <- i
}
wg.Done()

}

func pull(c chan int, wg *sync.WaitGroup) {

for i := 0; i < 5; i++ {
    result, ok := <-c
    fmt.Println(result, ok)
}
wg.Done()

}

func main( ） {

var wg sync.WaitGroup
wg.Add(2)
c := make(chan int)

go push(c, &wg)
go pull(c, &wg)

wg.Wait()

}

通过传递 WaitGroup 指针而不是值，两个 goroutine 都可以访问同一个 WaitGroup 实例。当一个 goroutine 调用 Done 时，它​​会减少原始 WaitGroup 上的计数，从而允许另一个 goroutine 继续执行。

以上是为什么在 Go 通道中按值传递 WaitGroup 会导致死锁？的详细内容。更多信息请关注PHP中文网其他相关文章！