Rumah pembangunan bahagian belakang Golang Bagaimanakah anda boleh mengehadkan bilangan rutin Go serentak apabila memproses senarai URL semasa menggunakan goroutine?

Bagaimanakah anda boleh mengehadkan bilangan rutin Go serentak apabila memproses senarai URL semasa menggunakan goroutine?

Oct 31, 2024 am 11:31 AM

How can you limit the number of concurrent Go routines when processing a list of URLs while utilizing goroutines?

Menghadkan Bilangan Rutin Pergi Serentak

Isu:
Anda berhasrat untuk memproses senarai URL secara serentak menggunakan goroutin tetapi dengan bilangan maksimum goroutin yang dipratentukan yang dilaksanakan secara serentak. Dalam keadaan ini, anda ingin mengehadkan penyejajaran kepada sepuluh goroutin secara serentak, walaupun mempunyai tiga puluh URL.

Penyelesaian:

Kunci untuk menyelesaikan isu ini terletak pada mengubah suai seni bina kod anda. Daripada menghasilkan goroutine yang berasingan untuk setiap URL, hasilkan bilangan goroutin pekerja yang terhad yang menggunakan URL daripada saluran kongsi. Sifat penimbal saluran ini akan mengawal selia konkurensi.

Pengubahsuaian Kod:

Berikut ialah versi terkini kod anda yang menggabungkan pendekatan ini:

<code class="go">package main

import (
    "flag"
    "fmt"
    "os"
    "sync"
    "time"
)

func main() {
    parallel := flag.Int("parallel", 10, "max parallel requests allowed")
    flag.Parse()
    urls := flag.Args()

    // Create a buffered channel to buffer URLs
    urlsChan := make(chan string, *parallel)

    // Create a separate goroutine to feed URLs into the channel
    go func() {
        for _, u := range urls {
            urlsChan &lt;- u
        }
        // Close the channel to indicate that there are no more URLs to process
        close(urlsChan)
    }()

    var wg sync.WaitGroup
    client := rest.Client{}

    results := make(chan string)

    // Start the specified number of worker goroutines
    for i := 0; i &lt; *parallel; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            // Continuously retrieve URLs from the channel until it is closed
            for url := range urlsChan {
                worker(url, client, results)
            }
        }()
    }

    // Launch a separate goroutine to close the results channel when all workers are finished
    go func() {
        // Wait for all workers to finish processing URLs
        wg.Wait()
        // Close the results channel to signal that there are no more results
        close(results)
    }()

    // Read results from the channel until it is closed
    for res := range results {
        fmt.Println(res)
    }

    os.Exit(0)
}</code>
Salin selepas log masuk

Dalam kod yang disemak ini:

  1. Saluran penimbal, urlsChan, dicipta untuk menyimpan URL yang akan diproses. Saiz penimbal ditetapkan kepada *selari, dengan berkesan mengehadkan bilangan goroutin yang boleh mengakses saluran secara serentak.
  2. Groutine berasingan dikhaskan untuk mengisi saluran urlsChan dengan URL.
  3. Groutine pekerja teruskan menggunakan URL daripada saluran urlsChan sehingga ia ditutup.
  4. Groutine berasingan digunakan untuk menutup saluran keputusan sebaik sahaja semua pekerja menyelesaikan tugas mereka.

Dengan memanfaatkan seni bina yang diubah suai ini , anda boleh mengawal dengan berkesan bilangan goroutine yang dilaksanakan serentak berdasarkan had selari yang ditentukan.

Atas ialah kandungan terperinci Bagaimanakah anda boleh mengehadkan bilangan rutin Go serentak apabila memproses senarai URL semasa menggunakan goroutine?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

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

Tag artikel panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

GO Language Pack Import: Apakah perbezaan antara garis bawah dan tanpa garis bawah? GO Language Pack Import: Apakah perbezaan antara garis bawah dan tanpa garis bawah? Mar 03, 2025 pm 05:17 PM

GO Language Pack Import: Apakah perbezaan antara garis bawah dan tanpa garis bawah?

Bagaimana saya menulis objek dan stub untuk ujian di GO? Bagaimana saya menulis objek dan stub untuk ujian di GO? Mar 10, 2025 pm 05:38 PM

Bagaimana saya menulis objek dan stub untuk ujian di GO?

Bagaimana untuk melaksanakan pemindahan maklumat jangka pendek antara halaman dalam kerangka beego? Bagaimana untuk melaksanakan pemindahan maklumat jangka pendek antara halaman dalam kerangka beego? Mar 03, 2025 pm 05:22 PM

Bagaimana untuk melaksanakan pemindahan maklumat jangka pendek antara halaman dalam kerangka beego?

Bagaimana saya boleh menentukan kekangan jenis tersuai untuk generik di GO? Bagaimana saya boleh menentukan kekangan jenis tersuai untuk generik di GO? Mar 10, 2025 pm 03:20 PM

Bagaimana saya boleh menentukan kekangan jenis tersuai untuk generik di GO?

Bagaimana saya boleh menggunakan alat pengesanan untuk memahami aliran pelaksanaan aplikasi saya? Bagaimana saya boleh menggunakan alat pengesanan untuk memahami aliran pelaksanaan aplikasi saya? Mar 10, 2025 pm 05:36 PM

Bagaimana saya boleh menggunakan alat pengesanan untuk memahami aliran pelaksanaan aplikasi saya?

Bagaimanakah saya boleh menggunakan alat linter dan analisis statik untuk meningkatkan kualiti dan pemeliharaan kod pergi saya? Bagaimanakah saya boleh menggunakan alat linter dan analisis statik untuk meningkatkan kualiti dan pemeliharaan kod pergi saya? Mar 10, 2025 pm 05:38 PM

Bagaimanakah saya boleh menggunakan alat linter dan analisis statik untuk meningkatkan kualiti dan pemeliharaan kod pergi saya?

Bagaimana cara menulis fail dalam bahasa Go dengan mudah? Bagaimana cara menulis fail dalam bahasa Go dengan mudah? Mar 03, 2025 pm 05:15 PM

Bagaimana cara menulis fail dalam bahasa Go dengan mudah?

Bagaimana cara menukar senarai hasil pertanyaan mysql ke dalam slice struktur tersuai dalam bahasa Go? Bagaimana cara menukar senarai hasil pertanyaan mysql ke dalam slice struktur tersuai dalam bahasa Go? Mar 03, 2025 pm 05:18 PM

Bagaimana cara menukar senarai hasil pertanyaan mysql ke dalam slice struktur tersuai dalam bahasa Go?

See all articles