Bagaimana untuk Mengehadkan Rutin Pergi Serentak dengan Berkesan?

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:

• URL saluran penimbal dibuat, yang akan memberi suapan URL kepada pekerja.
• Groutine berasingan bertanggungjawab untuk menyuap saluran url dengan URL yang disediakan.
• Bilangan pekerja yang dikehendaki dibuat. Setiap pekerja menarik URL daripada saluran url dan memprosesnya secara bersiri.
• Apabila semua pekerja selesai memproses, goroutine menutup saluran keputusan untuk menandakan bahawa semua keputusan telah diambil.

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!