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

#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 つの値のみを送信しているように見えるのはこのためです。実際、最初の値を送信した後は、何も値を受信できないため、すべてのワーカーがブロックされます (これを行うには、out Move the print と記述します)これを参照するには後のステートメント)

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

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

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

リーリー

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

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