WaitGroup
strukturu, Go dilində goroutine-lərin sinxronizasiyası üçün istifadə olunan bir mexanizmdir. Go-nun sync
paketində tapılan bu struktur, birdən çox goroutine-in icrasını izləmək və onların hamısı tamamlandıqda müəyyən bir əməliyyatı yerinə yetirmək üçün imkan yaradır.
WaitGroup
, birdən çox goroutine-i izləməyə, onların bitməsini gözləməyə və hər bir goroutine tamamlandıqda xəbərdar olmağa imkan verir. Bu məqsədlə, Add()
, Done()
və Wait()
metodlarından istifadə edilir:
Add(n)
:n
sayda goroutine əlavə edir.Done()
: Goroutine bitdikdən sonra çağırılır və gözləmə sayını azaldır.Wait()
: Bütün goroutine-lər tamamlanana qədər gözləyir.
Aşağıdakı nümunədə, WaitGroup
istifadə edərək goroutine-lərin idarə olunması göstərilir:
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done() // Goroutine tamamlandıqda Done() çağırılır.
fmt.Printf("Worker %d starting\n", id)
time.Sleep(time.Second) // İşçinin işləməsi üçün bir saniyə gözləmə.
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup // WaitGroup dəyişəni yaradılır.
for i := 1; i <= 5; i++ {
wg.Add(1) // Hər goroutine üçün Add(1) edilir.
go worker(i, &wg) // Goroutine işə salınır.
}
wg.Wait() // Bütün goroutine-lər bitənə qədər gözləyir.
fmt.Println("All workers done")
}
Nümunə açıqlaması:
worker
funksiyası bir işçini təmsil edir. Hər işçi bir saniyə işləyir və tamamlandıqdawg.Done()
çağırılır.main
funksiyasında, 5 goroutine işə salınır və hər biriworker
funksiyasını icra edir.wg.Add(1)
hər işçi başlamazdan əvvəl sayğacı bir vahid artırır.wg.Wait()
bütün goroutine-lər bitmədənmain
funksiyasının bitməsini gecikdirir.
Output:
Worker 5 starting
Worker 3 starting
Worker 4 starting
Worker 1 starting
Worker 2 starting
Worker 5 done
Worker 3 done
Worker 2 done
Worker 1 done
Worker 4 done
All workers done
Bu nümunədə, 5 goroutine paralel olaraq işləyir, hər biri tamamlandıqda WaitGroup
onları izləyir və bütün işlər tamamlandıqda proqram "All workers done" mesajını yazdırır.