同じチャネルから読み取る複数のゴルーチン

#php エディターの Strawberry は、この記事で同じチャネルから読み込む複数のゴルーチンの関連コンテンツを紹介します。並行プログラミングでは、ゴルーチンは複数のタスクを同時に実行できる Go 言語の軽量スレッドです。チャネルは、ゴルーチン間で通信するための重要な方法です。複数のゴルーチンが同じチャネルからデータを読み取る必要がある場合、プログラムの正確さと効率を確保するために、いくつかの問題に注意し、対応する措置を講じる必要があります。以下では、このプロセスを詳細に説明し、いくつかの実用的なヒントとアドバイスを提供します。

質問内容

同じチャネルから値を読み取るために複数の goroutine を生成することを検討してください。 2 つのワーカーは期待どおりに生成されますが、チャネルから 1 つの項目を読み取るだけで、読み取りを停止します。チャネルに値を送信するゴルーチンが終了するまで、ゴルーチンがチャネルからデータを読み取り続けることが期待されます。何かが送信者の送信を妨げていますが、プロジェクトを生成したゴルーチンは閉じられていません。各ワーカーが 1 つの値だけを読み取って停止するのはなぜですか?

出力には、送信された 2 つの値が表示され、1 つは各ワーカー goroutine によって読み取られます。 3 番目の値は送信されますが、どちらのワーカー スレッドからも読み取られません。

遊園地に行きます

new worker new worker waiting sending 0 sending 1 sending 2 running func 1 sending value out 1 running func 0 sending value out 0

回避策

チャネルがバッファリングされていないという前のコメントは正しいですが、他にも同期の問題があります。

バッファなしチャネルとは、本質的に、値が書き込まれるとき、他の書き込みが行われる前にその値を受信する必要があることを意味します。

1. workerpool結果を保存するためのバッファなしチャネルoutを作成しますが、すべての結果が書き出された後にのみ戻ります。しかし、out チャネルからの読み取りはoutが返された後に発生し、outはバッファリングされないため、書き込みしようとしている間にworkerpoolがブロックされ、デスロックが発生します。各ワーカーが 1 つの値のみを送信しているように見えるのはこのためです。実際、最初の値を送信した後は、何も値を受信できないため、すべてのワーカーがブロックされます (これを行うには、outMove the print と記述します)これを参照するには後のステートメント)

修正オプションには、outにサイズn = 結果の数のバッファーを持たせることが含まれます (つまり、out := make(chan int, n)) またはoutをバッファリングせず、書き込み中にoutから読み取ります。

1. doneチャネルも正しく使用されていません。mainとworkerpoolはどちらもこれに依存して実行を停止しますが、何も書き込まれません。また、バッファリングされていないため、前述のデッドロックの問題が発生します。

これを修正するには、まずworkerpoolからcase <-done:を削除し、単純にinでスコープを閉じます。 ＃＃＃主要＃＃＃。doneをバッファリングされたチャネルに設定して、デッドロックを解決できます。これらの修正を組み合わせると次のようになります:

これで問題は解決するかもしれませんが、チャネルを使用する最良の方法ではありません。構造自体は、バッファリングされたチャネルに依存することなく、より簡単に変更できます。

以上が同じチャネルから読み取る複数のゴルーチンの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。