WaitGroup を使用してすべてのゴルーチンが完了した後にチャネルを安全に閉じるにはどうすればよいでしょうか?

WaitGroup によるゴルーチンの完了後にチャネルを閉じる

チャネルとゴルーチンを操作する場合、すべてのゴルーチンが終了した後にチャネルを閉じることが重要です。これにより、チャネル上でのさらなる通信が防止され、適切なリソース管理が可能になります。

提供されたコードはこの動作を実装しようとしていますが、競合状態による制限に直面しています。これらの課題に対処するために、sync.WaitGroup タイプを利用できます。

WaitGroup を使用すると、タスクのコレクションを作成し、タスクの完了を待ってから実行を続行できます。チャネルを閉じるコンテキストでは、WaitGroup を使用して、すべてのゴルーチンがチャネルの使用を終了した場合にのみチャネルを閉じることができます。

WaitGroup を使用した改良されたコード スニペット:

import (
    "sync"
)

// ...

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 を使用して未処理の goroutine の数を追跡します。タスクを実行する各 goroutine は、WaitGroup カウンタをインクリメントし、タスクが開始されたことを示します。完了すると、各ゴルーチンは WaitGroup カウンタをデクリメントし、終了したことを示します。別のゴルーチンは WaitGroup で待機し、すべてのゴルーチンが完了を報告するとチャネルを閉じます。

このアプローチにより、チャネルが同期して確実に閉じられ、元のコードで発生する問題が回避されます。また、スリープ コールや混雑した待機の必要性もなくなり、より効率的で堅牢なソリューションが提供されます。

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