GoLang のデッドロック: バッファーされたチャネルで範囲が制限される理由?

GoLang でバッファーされたチャネルを使用する場合は、デッドロック状況の発生を避けることが重要です。最近の問題により、すべてのゴルーチンが完了した後にバッファーされたチャネルを範囲指定しようとしているときに発生するデッドロックに関する懸念が生じました。

提供されたコードは、容量 4 のバッファーされたチャネルを使用し、データを送信する 4 つのゴルーチンを生成しようとしています。チャンネルに。ただし、デッドロックは次の理由で発生します。

• チャネル サイズが小さすぎるため、ブロックされたゴルーチンがチャネル全体への書き込みを待機しています。
• チャネル上の範囲オーバー操作が無期限に残ります。書き込むゴルーチンが残っていない間、要素の到着を待っています。

解決策 1: チャネル サイズを拡張し、完了後に閉じる

デッドロックを解決するには、チャネルのサイズを大きくして、すべてのゴルーチンが完了した後に閉じることができます:

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

ただし、これではすべてのタスクが完了するまで印刷が妨げられるため、パイプラインの利点が失われます。

解決策 2: 印刷ルーチン内から完了を通知する

実際のパイプライン処理を有効にするには、印刷ルーチン内で Done() 関数を呼び出すことができます。

func main() {
    ch := make(chan []int, 4)
    ...
    go func() {
        for c := range ch {
            fmt.Printf("c is %v\n", c)
            wg.Done()
        }
    }()
    ...
}

このアプローチでは、各要素が出力された後にのみ Done() 関数が呼び出され、各ゴルーチンの完了を効果的に通知します。