Menghadkan Rutin Pergi Serentak
Dalam kod anda, anda cuba mengehadkan bilangan goroutin serentak. Walau bagaimanapun, pelaksanaan semasa tidak berfungsi seperti yang diharapkan. Berikut ialah pendekatan alternatif:
Penyelesaian:
Daripada membuat goroutine untuk setiap URL, buat bilangan pekerja tetap yang memproses URL daripada saluran kongsi. Berikut ialah kod yang diubah suai:
<code class="go">parallel := flag.Int("parallel", 10, "max parallel requests allowed") flag.Parse() // Workers get URLs from this channel urls := make(chan string) // Feed the workers with URLs go func() { for _, u := range flag.Args() { urls <- u } // Workers will exit from range loop when channel is closed close(urls) }() var wg sync.WaitGroup client := rest.Client{} results := make(chan string) // Start the specified number of workers. for i := 0; i < *parallel; i++ { wg.Add(1) go func() { defer wg.Done() for url := range urls { worker(url, client, results) } }() } // When workers are done, close results so that main will exit. go func() { wg.Wait() close(results) }() for res := range results { fmt.Println(res) }</code>
Penjelasan:
Ini pendekatan memastikan bahawa maksimum goroutin selari aktif pada bila-bila masa, mengehadkan konkurensi seperti yang dikehendaki.
Atas ialah kandungan terperinci Bagaimana untuk Mengehadkan Rutin Pergi Serentak dengan Berkesan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!