ゴルーチンのデッドロックの解決

このシナリオでは、Go 同時実行コードでデッドロック エラーが発生しました。問題を詳しく調べて、効率的な解決策を提供しましょう。

このエラーは、プロデューサとコンシューマの動作の不一致が原因で発生します。プロデューサー関数に実装されたプロデューサーは、限られた期間、チャネル ch で値を送信します。ただし、メイン関数に存在するコンシューマは無限に実行され、ch.

からの値の受信を延々と試みます。このデッドロックを解決するには、コンシューマがプロデューサの完了を尊重するようにする必要があります。これは、プロデューサーが値の送信を終了したときにコンシューマーが自動的に終了する必要があることを意味します。

1 つの効果的なアプローチは、sync.WaitGroup を利用してプロデューサーを調整することです。待機グループを使用すると、プロデューサーの進行状況を追跡し、チャンネルを閉じる前にプロデューサーがタスクを完了するのを待つことができます。コードの改良版は次のとおりです。

func main() {
    var wg sync.WaitGroup
    ch := make(chan int)

    wg.Add(1)
    go producer(ch, 100*time.Millisecond, 2, &wg)

    wg.Add(1)
    go producer(ch, 200*time.Millisecond, 5, &wg)

    // Start a goroutine to close the channel when all producers are done
    go func() {
        wg.Wait()
        close(ch)
    }()

    // Use a for range loop to receive values from the channel
    for v := range ch {
        fmt.Println(v)
    }
}

この更新されたコードでは、アクティブなプロデューサーの数を追跡するために sync.WaitGroup が使用されます。プロデューサーは、値の送信が終了したときに wg.Done() を呼び出して待機グループをデクリメントします。メインのゴルーチンは、すべてのプロデューサーが wg.Wait() の使用を完了するのを待ってから、ch チャネルを閉じます。

sync.WaitGroup を利用することで、コンシューマーが完了ステータスを尊重できるようにする調整メカニズムを確立します。プロデューサーの機能を強化し、デッドロック エラーを効果的に解決します。