同時操作のキューがあるシナリオでは、アクティブなゴルーチンの数を監視することが不可欠になります。これにより、適切な数のゴルーチンがキューを処理し、パフォーマンスとリソースの使用率が最適化されます。
提供されたコード スニペットは、キュー内の要素の数に基づいてゴルーチンを生成するループを示しています。ただし、このアプローチにはいくつかの欠点があります。
より良い解決策は、同期メカニズムを利用することです。ここでは、WaitGroup が使用されています。
func deen(wg *sync.WaitGroup, queue chan int) { for element := range queue { wg.Done() fmt.Println("element is ", element) if element%2 == 0 { fmt.Println("new element is ", element) wg.Add(2) queue <- (element*100 + 11) queue <- (element*100 + 33) } } } func main() { var wg sync.WaitGroup queue := make(chan int, 10) queue <- 1 queue <- 2 queue <- 3 queue <- 0 for i := 0; i < 4; i++ { wg.Add(1) go deen(&wg, queue) } wg.Wait() close(queue) fmt.Println("list len", len(queue)) //this must be 0 }
この修正されたコードにより、ゴルーチンの数は常に 4 つに制限され、キュー内のすべての要素が処理されると処理が完了します。このアプローチは、過度の goroutine 作成と CPU 消費の問題に効果的に対処します。
以上がGo でアクティブな Goroutine の数を効果的に監視および制御するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。