Rumah >pembangunan bahagian belakang >Golang >Tutorial asas: Pergi WaitGroup dan aplikasinya di Golang

Tutorial asas: Pergi WaitGroup dan aplikasinya di Golang

王林
王林asal
2023-09-28 09:42:381077semak imbas

基础教程:Go WaitGroup及其在Golang中的应用

Tutorial Asas: Go WaitGroup dan aplikasinya di Golang, contoh kod khusus diperlukan

Kata Pengantar:
Dalam Golang (bahasa Go), menulis program serentak adalah tugas biasa. Golang menyediakan banyak primitif dan API serentak, salah satu alat penting ialah WaitGroup. Artikel ini akan memperkenalkan anda kepada konsep dan penggunaan WaitGroup dan memberikan beberapa contoh kod khusus.

1. Konsep WaitGroup
WaitGroup ialah primitif serentak di Golang, yang digunakan untuk menunggu penyiapan kumpulan goroutin. WaitGroup mengekalkan kaunter secara dalaman, dengan nilai awal 0. Apabila setiap coroutine mula melaksanakan, kaunter dinaikkan sebanyak 1. Apabila coroutine tamat, kaunter akan dikurangkan sebanyak 1. Benang utama boleh menyekat melalui kaedah Tunggu() sehingga kaunter mencapai 0, iaitu, semua coroutine dilaksanakan.

2. Penggunaan asas WaitGroup
Untuk menggunakan WaitGroup, anda perlu mengikuti langkah berikut:

  1. Buat objek WaitGroup: Pertama, kita perlu mengimport pakej "sync" dan mencipta objek WaitGroup.

    import "sync"
    
    var wg sync.WaitGroup
  2. Tambah coroutine pada WaitGroup: Untuk setiap coroutine yang akan dilaksanakan, kita perlu menambah pembilang dan menggunakan kata kunci go untuk melaksanakan tugas dalam coroutine baharu.

    wg.Add(1)
    go func() {
     // 协程的具体逻辑
     // ...
     wg.Done() // 协程执行完成后减少计数器
    }()
  3. Menunggu penyiapan coroutine: Benang utama boleh menggunakan kaedah Wait() untuk menyekat sehingga kaunter adalah 0, iaitu semua coroutine telah dilaksanakan.

    wg.Wait()

Contoh kod:
Berikut ialah contoh kod khusus yang menunjukkan aplikasi WaitGroup di Golang. Contoh ini menggunakan WaitGroup untuk menunggu beberapa coroutine selesai sebelum meneruskan dengan logik seterusnya.

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
func main() {
    var wg sync.WaitGroup
 
    for i := 0; i < 5; i++ {
        wg.Add(1)
 
        go func(num int) {
            defer wg.Done()
            time.Sleep(time.Second) // 模拟长时间的任务
 
            fmt.Printf("协程 %d 完成
", num)
        }(i)
    }
 
    fmt.Println("等待所有协程完成...")
    wg.Wait()
    fmt.Println("所有协程已完成!")
}

Dalam contoh di atas, kami mensimulasikan pelaksanaan 5 coroutine, dan setiap coroutine menunggu selama 1 saat. Dengan WaitGroup, utas utama menyekat sehingga semua coroutine dilaksanakan. Dalam output, kita dapat melihat bahawa susunan coroutine yang lengkap tidak tetap kerana ia dilaksanakan secara selari.

3. Nota tentang WaitGroup
Apabila menggunakan WaitGroup, anda perlu mengikuti langkah berjaga-jaga berikut:

  1. Sebelum memanggil Wait(), Done() mesti dipanggil dalam setiap coroutine untuk memastikan kaunter dikurangkan. Jika tidak, benang utama akan disekat selama-lamanya.
  2. WaitGroup diluluskan oleh nilai, jadi apabila menghantar ke fungsi atau kaedah, pastikan anda menghantar penunjuk, bukan salinan nilai.
  3. Jangan gunakan berbilang objek WaitGroup untuk menunggu antara satu sama lain, ini akan menyebabkan kebuntuan.

Kesimpulan:
WaitGroup ialah primitif konkurensi yang sangat berguna di Golang, yang boleh menunggu dengan mudah untuk menyiapkan kumpulan coroutine. Artikel ini memperkenalkan konsep asas dan penggunaan WaitGroup dan menyediakan contoh kod khusus. Saya berharap dengan mengkaji artikel ini dapat membantu anda lebih memahami dan mengaplikasikan penggunaan WaitGroup di Golang.

Atas ialah kandungan terperinci Tutorial asas: Pergi WaitGroup dan aplikasinya di Golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
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