Sobes.tech
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.