Wie kann ich Goroutinen ordnungsgemäß beenden und Fehler in Go behandeln?

Idiomatische Goroutine-Beendigung und Fehlerbehandlung

Im Bereich der Go-Parallelität ist die nahtlose Handhabung der Beendigung von Goroutinen und Fehlern von entscheidender Bedeutung. Stellen Sie sich einen einfachen Anwendungsfall vor, bei dem wir darauf abzielen, Daten von mehreren Remote-Servern gleichzeitig abzurufen und dabei den ersten aufgetretenen Fehler zurückzugeben.

Undichte Goroutinen

Bei einem ersten Versuch kann es zu undichten Goroutinen kommen, wie im Folgenden hervorgehoben wird Codeausschnitt:

func fetchAll() error {
  wg := sync.WaitGroup{}
  errs := make(chan error)
  leaks := make(map[int]struct{})
  //...
}

Um dieses Problem zu beheben, können wir entweder Kontext verwenden oder das errgroup-Paket verwenden:

Fehlergruppenlösung

Das errgroup-Paket bietet eine praktische Möglichkeit um die Beendigung und Fehler von Goroutinen zu verwalten. Es wartet automatisch auf den Abschluss aller bereitgestellten Goroutinen oder bricht die verbleibenden ab, falls ein Fehler auftritt.

func fetchAll(ctx context.Context) error {
  errs, ctx := errgroup.WithContext(ctx)
  //...
  return errs.Wait()
}

Dieser Code handhabt die Beendigung der Goroutine elegant und gibt den ersten aufgetretenen Fehler zurück.

Das obige ist der detaillierte Inhalt vonWie kann ich Goroutinen ordnungsgemäß beenden und Fehler in Go behandeln?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!