Rumah > pembangunan bahagian belakang > Golang > Bagaimana untuk Mengehadkan Rutin Pergi Serentak dengan Berkesan?

Bagaimana untuk Mengehadkan Rutin Pergi Serentak dengan Berkesan?

Barbara Streisand
Lepaskan: 2024-11-02 05:25:02
asal
875 orang telah melayarinya

How to Effectively Limit Concurrent Go Routines?

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>
Salin selepas log masuk

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!

sumber:php.cn
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Artikel terbaru oleh pengarang
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan