Bagaimana untuk menangani isu baris gilir tugasan serentak dalam bahasa Go?

Bagaimana untuk menangani isu baris gilir tugasan serentak dalam bahasa Go?

Dalam pembangunan, kita sering menghadapi senario di mana sejumlah besar tugas perlu diproses. Kadangkala, bilangan tugasan adalah besar dan perlu dilaksanakan secara serentak, yang memerlukan penggunaan baris gilir tugasan untuk diproses. Sebagai bahasa pengaturcaraan yang menyokong konkurensi, bahasa Go menyediakan banyak cara untuk mengendalikan baris gilir tugasan serentak. Artikel ini akan memperkenalkan kaedah pemprosesan biasa dan memberikan contoh kod khusus.

1. Struktur data baris gilir tugas

Struktur data baris gilir tugas ialah struktur data masuk dahulu, keluar dahulu (FIFO). Dalam bahasa Go, saluran boleh digunakan untuk melaksanakan baris gilir tugas. Saluran ialah struktur data asas dalam bahasa Go yang digunakan untuk komunikasi antara goroutine. Berikut ialah kod sampel untuk struktur data baris gilir tugasan asas:

type Job struct {
    // 任务数据
    ...
}

func worker(jobs <-chan Job, results chan<- Result) {
    for job := range jobs {
        // 处理任务
        ...
        // 将处理结果发送到结果通道
        results <- result
    }
}

func main() {
    // 创建任务队列和结果队列
    jobs := make(chan Job, numJobs)
    results := make(chan Result, numJobs)

    // 启动若干个工作goroutine
    for i := 0; i < numWorkers; i++ {
        go worker(jobs, results)
    }

    // 所有任务添加到任务队列
    for _, job := range jobsSlice {
        jobs <- job
    }
    close(jobs)

    // 从结果队列中读取处理结果
    for i := 0; i < numJobs; i++ {
        result := <-results
        // 处理结果
        ...
    }
}

Dalam contoh ini, baris gilir tugas menghantar tugas melalui satu saluran (pekerjaan), dan baris gilir hasil menyampaikan hasil pemprosesan melalui saluran lain (hasil). Beberapa goroutin pekerja mula memproses tugas dalam baris gilir tugas dan menghantar hasil pemprosesan ke baris gilir hasil. Goroutine utama bertanggungjawab untuk menambah tugasan pada baris gilir tugas dan membaca hasil pemprosesan daripada baris gilir hasil.

2. Kawal bilangan mata wang

Dalam pembangunan sebenar, kadangkala perlu mengawal bilangan mata wang untuk mengelakkan kehabisan sumber atau kemerosotan prestasi yang disebabkan oleh mata wang yang berlebihan. Saluran penimbal boleh digunakan dalam bahasa Go untuk mengawal bilangan konkurensi. Berikut ialah kod sampel khusus:

func worker(jobs <-chan Job, results chan<- Result, done chan<- bool) {
    for job := range jobs {
        // 处理任务
        ...
        // 将处理结果发送到结果通道
        results <- result
    }
    done <- true
}

func main() {
    // 创建任务队列和结果队列
    jobs := make(chan Job, numJobs)
    results := make(chan Result, numJobs)
    done := make(chan bool, numWorkers)

    // 启动若干个工作goroutine
    for i := 0; i < numWorkers; i++ {
        go worker(jobs, results, done)
    }

    // 所有任务添加到任务队列
    for _, job := range jobsSlice {
        jobs <- job
    }
    close(jobs)

    // 等待所有工作goroutine完成
    for i := 0; i < numWorkers; i++ {
        <-done
    }

    // 从结果队列中读取处理结果
    for i := 0; i < numJobs; i++ {
        result := <-results
        // 处理结果
        ...
    }
}

Dalam contoh ini, kami menggunakan saluran penimbal (selesai) untuk mengawal bilangan mata wang. Pada penghujung setiap goroutine kerja, nilai dihantar ke saluran selesai, dan goroutine utama menunggu semua goroutine kerja selesai dengan membaca saluran selesai.

Melalui contoh kod di atas, kita dapat melihat bahawa menangani isu baris gilir tugasan serentak dalam bahasa Go adalah agak mudah. Menggunakan saluran sebagai baris gilir tugas dan baris gilir hasil, dan bekerjasama dengan gorout untuk pemprosesan serentak, pemprosesan tugas yang cekap boleh dicapai. Dengan mengawal bilangan mata wang, kita boleh menggunakan sumber secara fleksibel dan mengelakkan keletihan sumber atau kemerosotan prestasi yang disebabkan oleh mata wang yang berlebihan. Oleh itu, menguasai kaedah pemprosesan baris gilir tugasan serentak merupakan kemahiran penting dalam pembangunan bahasa Go.

Atas ialah kandungan terperinci Bagaimana untuk menangani isu baris gilir tugasan serentak dalam bahasa Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!