Tasks synchronisieren mit sync.WaitGroup

Snippet

Tasks synchronisieren mit sync.WaitGroup

Eine WaitGroup wartet auf den Abschluss einer Gruppe von Goroutinen. Die Haupt-Goroutine ruft 'Add' auf, um die Anzahl der Tasks festzulegen, jeder Worker ruft 'Done' auf und 'Wait' blockiert, bis alle fertig sind.

snippet.go
go
func processAll() {
	var wg sync.WaitGroup
	for i := 1; i <= 3; i++ {
		wg.Add(1)
		go func(id int) {
			defer wg.Done()
			fmt.Printf("Worker %d started\n", id)
			time.Sleep(time.Second)
		}(i)
	}
	wg.Wait()
	fmt.Println("All workers finished")
}

Erklärung

wg.Add(1)

Erhöht den WaitGroup-Zähler für jede neue Goroutine.

defer wg.Done()

Verringert den Zähler, wenn die Goroutine ihre Ausführung beendet.

wg.Wait()

Blockiert die Ausführung, bis der Zähler den Wert Null erreicht.

Vorheriges Snippet Nächstes Snippet

Verwandt

Aus deiner Bibliothek