Junior — Middle
Hogyan valósítjuk meg több párhuzamos feladat szinkron várakozását egy Go programban?
sobes.tech MI
Válasz az MI-től
Go nyelvben általában a sync.WaitGroup-ot használják több párhuzamos feladat szinkronizált várakoztatására. Ez lehetővé teszi több goroutine indítását és azok befejezésének várását.
Példa:
package main
import (
"fmt"
"sync"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done() // Tájékoztatja a WaitGroup-ot, hogy a feladat befejeződött
fmt.Printf("Munkás %d indult\n", id)
// munka szimulálása
// time.Sleep(time.Second)
fmt.Printf("Munkás %d befejeződött\n", id)
}
func main() {
var wg sync.WaitGroup
numWorkers := 3
wg.Add(numWorkers) // A feladatok számának beállítása
for i := 1; i <= numWorkers; i++ {
go worker(i, &wg)
}
wg.Wait() // Várakozás minden goroutine befejezésére
fmt.Println("Minden munkás befejeződött")
}
Így a WaitGroup hatékonyan szinkronizálja a párhuzamos feladatok végrehajtását.