Snippet

Koordinierung mehrerer Goroutines mit sync.WaitGroup

Das sync.WaitGroup wird verwendet, um den Ausführungsfluss zu koordinieren, wenn mehrere nebenläufige Aufgaben in separaten Goroutines gestartet werden. Durch den Aufruf von Add(1) vor dem Start einer Goroutine und Done() bei deren Beendigung verwalten wir einen Zähler aktiver Routinen. Wait() blockiert die Ausführung, bis dieser Zähler auf Null sinkt, was garantiert, dass der nachfolgende Code erst ausgeführt wird, wenn alle Aufgaben abgeschlossen sind.

snippet.go

package main
 
import (
	"fmt"
	"sync"
	"time"
)
 
func performTask(taskID int, wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Printf("Starting task %d\n", taskID)
	time.Sleep(100 * time.Millisecond)
	fmt.Printf("Finished task %d\n", taskID)
}
 
func coordinateTasks() {
	var wg sync.WaitGroup
	for i := 1; i <= 3; i++ {
		wg.Add(1)
		go performTask(i, &wg)
	}
	wg.Wait()
	fmt.Println("All concurrent tasks completed successfully.")
}

Erklärung

var wg sync.WaitGroup

Deklariert eine Group-Variable, die den internen Zähler der Goroutines enthält, auf die gewartet werden soll.

wg.Add(1)

Erhöht den WaitGroup-Zähler. Dies muss in der Haupt-Goroutine ausgeführt werden, bevor die Unter-Goroutine gestartet wird.

defer wg.Done()

Stellt sicher, dass der Zähler dekrementiert wird, wenn die Goroutine endet, selbst bei vorzeitigem Beenden.

wg.Wait()

Blockiert den aktuellen Ausführungsblock, bis der interne WaitGroup-Zähler Null erreicht.

Vorheriges Snippet Nächstes Snippet

Mehr Go-Übungen für Fortgeschrittene →

Koordinierung mehrerer Goroutines mit sync.WaitGroup

Verwandt