Jak zaimplementować synchroniczne oczekiwanie na zakończenie wielu równoległych zadań w programie w Go?

W Go, aby oczekiwać synchronicznie na zakończenie wielu zadań równoległych, zwykle używa się sync.WaitGroup. Pozwala to na uruchomienie wielu goroutine i oczekiwanie na ich zakończenie.

Przykład:

package main

import (
    "fmt"
    "sync"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done() // Informuje WaitGroup, że zadanie zostało zakończone
    fmt.Printf("Pracownik %d rozpoczął\n", id)
    // symulacja pracy
    // time.Sleep(time.Second)
    fmt.Printf("Pracownik %d zakończył\n", id)
}

func main() {
    var wg sync.WaitGroup
    numWorkers := 3

    wg.Add(numWorkers) // Ustawiamy liczbę zadań

    for i := 1; i <= numWorkers; i++ {
        go worker(i, &wg)
    }

    wg.Wait() // Czekamy na zakończenie wszystkich goroutine
    fmt.Println("Wszyscy pracownicy zakończyli")
}

W ten sposób WaitGroup pozwala efektywnie synchronizować wykonanie zadań równoległych.