Go Channel 由于引用传递而出现死锁
在 Go 中,通道是一种强大的通信机制,但如果不这样做,可能会导致死锁正确使用。当两个或多个 goroutine 互相等待对方完成操作,导致两个 goroutine 都无法继续执行时,就会发生死锁。
考虑以下 Go 程序:
<br>包主<p>导入(</p><div class="code" style="position:relative; padding:0px; margin:0px;"><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><div class="code" style="position:relative; padding:0px; margin:0px;"><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中文网其他相关文章!