Gabungan pintar pemprosesan tak segerak Golang dan Go WaitGroup

Gabungan pintar pemprosesan tak segerak Golang dan Go WaitGroup

Pengenalan:
Dalam pembangunan perisian, pemprosesan tak segerak ialah cara teknikal biasa yang boleh meningkatkan prestasi dan responsif program. Dalam bahasa Go, coroutine pemprosesan tak segerak boleh diuruskan dengan lebih ringkas dengan menggunakan WaitGroup. Artikel ini akan memperkenalkan konsep asas pemprosesan tak segerak Golang dan menerangkan secara terperinci cara menggabungkan Go WaitGroup dengan bijak untuk melaksanakan pemprosesan tak segerak.

1. Konsep pemprosesan tak segerak
Pemprosesan tak segerak bermaksud bahawa semasa pelaksanaan program, tidak perlu menunggu operasi selesai, tetapi untuk terus melaksanakan sekeping kod seterusnya. Kaedah pemprosesan tak segerak yang biasa termasuk multi-threading, dipacu peristiwa, fungsi panggil balik, dsb. Dalam bahasa Go, anda boleh menggunakan goroutine untuk mencapai konkurensi untuk mencapai pemprosesan tak segerak.

2. Goroutine di Golang
Goroutine ialah benang ringan dalam bahasa Go yang boleh dibuat dan dimusnahkan dengan kos yang sangat rendah. Concurrency boleh digunakan melalui goroutine untuk meningkatkan prestasi program dan keupayaan concurrency. Untuk menggunakan goroutine, anda hanya perlu menambah kata kunci pergi sebelum fungsi atau kaedah. Contohnya:

func main() {
    go myfunction()
    // 其他代码
}

func myfunction() {
    // 异步处理的代码逻辑
}

Dalam kod di atas, fungsi saya akan dipanggil sebagai goroutine bebas dan dilaksanakan secara tak segerak.

3. WaitGroup di Golang
WaitGroup ialah primitif penyegerakan dalam bahasa Go, yang boleh digunakan untuk menunggu pelaksanaan kumpulan goroutine selesai. Kaunter di dalam WaitGroup boleh digunakan untuk mengawal sama ada semua goroutine telah dilaksanakan Anda boleh menggunakan kaedah Tambah untuk meningkatkan nilai pembilang, kaedah Selesai untuk mengurangkan nilai pembilang dan kaedah Tunggu untuk menyekat dan menunggu pembilang kembali. kepada sifar.

Apabila menggunakan WaitGroup, proses umum adalah seperti berikut:

1. Buat objek WaitGroup
2. Apabila memulakan goroutine, gunakan kaedah Tambah untuk meningkatkan nilai kaunter
3. Selepas penggunaan Dongoroutine selesai, laksanakan kaedah untuk mengurangkan nilai pembilang
4. Dalam goroutine utama, gunakan kaedah Tunggu untuk menyekat dan tunggu pembilang kembali kepada sifar
5. Selepas semua goroutine dilaksanakan, teruskan melaksanakan kod seterusnya

Kod khusus adalah seperti berikut:

import (
    "fmt"
    "sync"
)

var wg sync.WaitGroup

func main() {
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go myfunction(i)
    }
    wg.Wait()
    // 所有goroutine执行完成后，继续执行后续代码
    fmt.Println("all goroutines completed")
}

func myfunction(id int) {
    defer wg.Done()
    // 异步处理的代码逻辑
    fmt.Println("goroutine", id, "completed")
}

Dalam kod di atas, kami mencipta gelung yang mengandungi 10 goroutine, dalam setiap logik Kod yang melakukan pemprosesan tak segerak dalam goroutine. Selepas setiap goroutine dilaksanakan, kaedah wg.Done() dipanggil untuk mengurangkan nilai pembilang. Dalam goroutine utama, kami menggunakan kaedah wg.Wait() untuk menunggu kaunter mencapai sifar.

Dengan menggunakan WaitGroup, kami boleh mengurus pelaksanaan serentak berbilang goroutin dengan mudah dan terus melaksanakan kod berikutnya selepas semua pelaksanaan goroutine selesai.

4. Aplikasi pintar menggabungkan pemprosesan tak segerak dan WaitGroup

Apabila bilangan tugasan yang perlu kami proses tidak diketahui, kami boleh menggabungkan pemprosesan tak segerak dan WaitGroup untuk mencapai pemprosesan serentak yang lebih fleksibel. Contoh kod diberikan di bawah:

import (
    "fmt"
    "sync"
    "time"
)

var wg sync.WaitGroup

func main() {
    tasks := []string{"task1", "task2", "task3", "task4", "task5"}

    for _, task := range tasks {
        wg.Add(1)
        go processTask(task)
    }

    wg.Wait()
    fmt.Println("all tasks completed")
}

func processTask(task string) {
    defer wg.Done()

    // 模拟耗时的任务处理
    time.Sleep(time.Second * 2)
    fmt.Println("task", task, "completed")
}

Dalam kod di atas, kami mewakili senarai tugasan yang belum selesai melalui kepingan rentetan. Dalam gelung, kami menggunakan kaedah Tambah untuk meningkatkan nilai pembilang, dan memulakan goroutine untuk setiap tugasan untuk diproses Selepas pemprosesan selesai, kami memanggil kaedah Selesai untuk mengurangkan nilai pembilang. Akhir sekali, gunakan kaedah Tunggu untuk menunggu pelaksanaan semua tugas selesai.

Dengan cara ini, kami boleh mengendalikan bilangan tugasan yang tidak diketahui dengan mudah dan terus melaksanakan kod berikutnya selepas semua tugasan selesai.

Kesimpulan:
Artikel ini memperkenalkan konsep pemprosesan tak segerak di Golang dan cara bijak menggunakan Go WaitGroup untuk mengurus goroutin pemprosesan tak segerak. Melalui pemprosesan tak segerak, kami boleh meningkatkan prestasi dan responsif program, dan menggunakan WaitGroup boleh membantu kami mengurus dan mengawal pelaksanaan serentak pemprosesan tak segerak dengan lebih mudah. Dengan menguasai teknik ini, anda boleh meningkatkan kecekapan pembangunan program Golang dengan berkesan.

Atas ialah kandungan terperinci Gabungan pintar pemprosesan tak segerak Golang dan Go WaitGroup. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!