Go チャネルで WaitGroup を値で渡すとデッドロックが発生するのはなぜですか?

参照の受け渡しによる Go チャネルのデッドロック

Go ではチャネルは強力な通信メカニズムですが、そうでない場合はデッドロックが発生する可能性があります正しく使用されています。デッドロックは、2 つ以上のゴルーチンがお互いの操作の完了を待っているときに発生し、どちらのゴルーチンも続行できなくなります。

次の Go プログラムを考えてみましょう。

<br>パッケージ 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()

}

このプログラムを実行すると、デッドロック エラーでパニックになります:

throw: all goroutines are asleep - deadlock!

問題は、WaitGroup がゴルーチンに渡される方法にあります。 。 Go では、構造体は値によって渡されます。これは、WaitGroup のコピーが各 goroutine に渡されることを意味します。 1 つのゴルーチンがそのコピーで 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 ポインタを渡すことで、両方のゴルーチンが同じものにアクセスできるようになります。 WaitGroup インスタンス。 1 つの goroutine が Done を呼び出すと、元の WaitGroup のカウントがデクリメントされ、他の goroutine が続行できるようになります。

以上がGo チャネルで WaitGroup を値で渡すとデッドロックが発生するのはなぜですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。