Go ですべてのゴルーチンが終了した後にチャネルを適切に閉じるにはどうすればよいですか?

Go で完了したゴルーチンのチャネル クローズを管理する

Go では、すべてのゴルーチンが完了した後のチャネル クローズを管理するのが難しい場合があります。この記事では一般的なアプローチを検討し、sync.WaitGroup.

問題:
複数のゴルーチンがチャネルにデータを送信するとき、チャネルがデータの損失を防ぐために適切に閉じることが重要です。チャネルを閉じる前にすべてのゴルーチンが完了するのを待つのが望ましい動作です。

初期アプローチ:
一般的な試みの 1 つは、すべてのゴルーチンを生成した直後にチャネルを閉じることです。ただし、これにより、ゴルーチンが閉じたチャネルに結果を送信しようとする可能性があります。

ゴルーチンのカウント:
より洗練されたアプローチには、実行中のゴルーチンをカウントし、カウントが到達したときにチャネルを閉じることが含まれます。ゼロ。この方法では問題は解決されますが、潜在的な同期エラーが発生します。

sync.WaitGroup 解決策:
推奨される解決策は、同時実行 Go プログラムでの同期を簡素化する sync.WaitGroup タイプを利用します。 。 WaitGroup を使用すると、ゴルーチンの数を簡単に追跡し、チャネルを閉じる前にゴルーチンの完了を待つことができます。

コード例:
次を使用して元のコードを変更する方法を示します。 sync.WaitGroup:

var wg sync.WaitGroup
for i := 0; i <= 10; i++ {
    wg.Add(1)
    go func(){
        result := calculate()
        c <- result
        wg.Done()
    }()
}

// Close the channel when all goroutines are finished
go func() {
    wg.Wait()
    close(c)
}()

for result := range c {
    all_result = append(all_result, result...)
}

ここでは、WaitGroup を使用してゴルーチンをカウントします。各ゴルーチンは、データをチャネルに送信する前にカウントをインクリメントし、終了時にカウントをデクリメントします。別のゴルーチンはカウントがゼロに達するまで待機し、すべてのゴルーチンが完了した後にのみチャネルが閉じられるようにします。

以上がGo ですべてのゴルーチンが終了した後にチャネルを適切に閉じるにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。