errgroup für nebenläufige Fehlerbehandlung
golang.org/x/sync/errgroup in der Praxis
errgroup für nebenläufige Fehlerbehandlung ist eine kostenlose Go Academy-Lektion auf CoddyKit. Dies ist Lektion 2 von 4. Du kannst die komplette Lektion unten kostenlos lesen – dann übst du sie direkt im Browser mit einem integrierten Code-Editor und einem KI-Tutor rund um die Uhr. Sie ist Teil des Go Academy-Lernpfads, und dein Fortschritt wird über Web und CoddyKit-App synchronisiert. Der Go Academy-Kurs umfasst insgesamt 4 Lektionen.
Problem mit Goroutinen und Fehlern
Das Starten von Goroutinen mit go func() verwirft Rückgabewerte einschließlich Fehlern. Sie benötigen zusätzliche Mechanismen (Channels, WaitGroup), um diese zu sammeln. errgroup vereinfacht dies.
golang.org/x/sync/errgroup
errgroup.Group führt Goroutinen aus und sammelt Fehler. Wait() blockiert, bis alle Goroutinen beendet sind, und gibt den ersten Fehler zurück, der nicht nil ist.
var g errgroup.Group
g.Go(func() error { return fetchUsers() })
g.Go(func() error { return fetchOrders() })
if err := g.Wait(); err != nil {
log.Fatal(err)
}errgroup.WithContext
WithContext gibt eine Gruppe und einen abgeleiteten Context zurück. Der Context wird abgebrochen, sobald die erste Goroutine einen Fehler zurückgibt, wodurch die verbleibende Arbeit angehalten wird.
g, ctx := errgroup.WithContext(context.Background())
g.Go(func() error { return doWork(ctx) })
g.Go(func() error { return doOtherWork(ctx) })
err := g.Wait()Ergebnisse zusammen mit Fehlern sammeln
errgroup sammelt keine Ergebnisse, sondern nur Fehler. Speichern Sie Ergebnisse in vorab angelegten Slices, auf die über den Index zugegriffen wird, um Synchronisierung zu vermeiden:
results := make([]Result, len(items))
for i, item := range items {
i, item := i, item
g.Go(func() error {
r, err := process(ctx, item)
if err != nil { return err }
results[i] = r
return nil
})
}
if err := g.Wait(); err != nil { return err }g.SetLimit (Go 1.20+)
g.SetLimit(n) begrenzt die Anzahl der Goroutinen, die gleichzeitig ausgeführt werden – es fungiert als integriertes Semaphore, ohne dass ein separater Channel erforderlich ist.
g.SetLimit(10) // at most 10 goroutines at once
for _, item := range items {
g.Go(func() error { return process(item) })
}g.TryGo
g.TryGo(f) startet die Goroutine nur, wenn das von SetLimit festgelegte Limit dies zulässt. Wenn sie nicht gestartet wurde, wird false zurückgegeben.
Nur der erste Fehler wird zurückgegeben
errgroup gibt nur den ersten Fehler zurück. Wenn Sie alle Fehler benötigen, sammeln Sie sie innerhalb jeder Goroutine in einer durch einen Mutex geschützten Slice.
var mu sync.Mutex
var errs []error
g.Go(func() error {
if err := doWork(); err != nil {
mu.Lock(); errs = append(errs, err); mu.Unlock()
}
return nil
})Unterschied zu sync.WaitGroup
WaitGroup verfolgt den Abschluss; errgroup verfolgt den Abschluss UND sammelt Fehler. Bevorzugen Sie errgroup, wenn ein Fehler einer beliebigen Goroutine gemeldet werden soll.
Weitergabe des Context-Abbruchs
Wenn errgroup.WithContext verwendet wird, signalisiert der Abbruch des abgeleiteten Contexts allen anderen Goroutinen, dass sie anhalten sollen – ähnlich der Semantik, beim ersten Fehler abzubrechen.
errgroup-Code testen
Fügen Sie in Tests einen Context mit WithTimeout ein, um sicherzustellen, dass die Gruppe nicht unbegrenzt weiterläuft, falls eine Goroutine hängt.
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
g, ctx := errgroup.WithContext(ctx)Alternative mit Semaphore
Vor SetLimit (Go < 1.20) verwenden Sie einen gepufferten Channel als Semaphore innerhalb einzelner Goroutinen, um denselben Effekt zu erzielen.
Schnelltest
Was gibt errgroup.WithContext zurück, das eine einfache errgroup.Group nicht zurückgibt?
Zusammenfassung: errgroup
Wichtige Punkte:
- g.Go(func() error) – starten und den ersten Fehler sammeln
- g.Wait() – blockiert, bis alle beendet sind; gibt den ersten Fehler zurück
- WithContext – Context wird beim ersten Fehler abgebrochen
- g.SetLimit(n) – begrenzt gleichzeitig ausgeführte Goroutinen (Go 1.20+)
Häufig gestellte Fragen
Ist die Lektion „errgroup für nebenläufige Fehlerbehandlung“ kostenlos?
Ja — der vollständige Text von „errgroup für nebenläufige Fehlerbehandlung“ ist hier im Web kostenlos zu lesen. Um sie interaktiv zu üben (integrierter Code-Editor und 24/7 KI-Tutor) und den Rest des Go Academy-Kurses freizuschalten, upgrade auf CoddyKit PRO. Der Go Academy-Kurs umfasst insgesamt 4 Lektionen.
Was lerne ich in „errgroup für nebenläufige Fehlerbehandlung“?
golang.org/x/sync/errgroup in der Praxis Du übst Go Academy mit praktischem Code, den du direkt im Browser ausführst, und ein 24/7 KI-Tutor beantwortet deine Fragen während du die Lektion bearbeitest.
Brauche ich Erfahrung, um Go Academy zu starten?
Keine Vorkenntnisse erforderlich. Go Academy auf CoddyKit ist für Anfänger bis fortgeschrittene Lernende strukturiert, sodass du hier starten oder von Anfang an beginnen und in deinem eigenen Tempo voranschreiten kannst. Dies ist Lektion 2 von 4.
Wie lange dauert die Lektion „errgroup für nebenläufige Fehlerbehandlung“?
Die meisten CoddyKit-Lektionen dauern etwa 5–10 Minuten. Jede ist kompakt und interaktiv, sodass du stetig Fortschritte machst und genau dort weitermachst, wo du aufgehört hast – im Web und in der App.
Kann ich in dieser Go Academy-Lektion Code schreiben und ausführen?
Ja. Jede Go Academy-Lektion enthält einen integrierten Code-Editor, sodass du echten Code direkt in deinem Browser schreibst und ausführst und sofort KI-Feedback erhältst — ohne lokale Einrichtung erforderlich.
Alle Lektionen in diesem Kurs
- Pipeline- und Stage-Patterns
- errgroup für nebenläufige Fehlerbehandlung
- Semaphore-Pattern
- Leak-Erkennung und Abbruch