Warum erhalte ich nur einige Fehler und nicht alle Fehler der von mir gestarteten Goroutine?

PHP-Editor Apple hat die Antwort für Sie: Wenn in der Go-Sprache ein Fehler in einer Goroutine auftritt, wird dieser nicht automatisch an die Haupt-Coroutine weitergegeben. Stattdessen wird es stillschweigend ignoriert, was dazu führen kann, dass Sie nur Teilfehler und keine Fehler in allen gestarteten Goroutinen erhalten. Dies liegt daran, dass die ursprüngliche Absicht des Go-Sprachdesigns darin besteht, das Programm stabil und effizient zu halten, und das gesamte Programm auch im Fehlerfall nicht sofort gestoppt wird. Wenn Sie alle Fehler abfangen möchten, können Sie einen Kanal oder einen anderen Mechanismus verwenden, um Fehlerinformationen explizit zu übergeben. So stellen Sie sicher, dass alle Fehler korrekt behandelt werden.

Frageninhalt

Ich habe eine Zyklusklasse definiert, um gleichzeitige Aufgaben zu bearbeiten. Ich möchte zwei Funktionen ausführen, jede in einer Goroutine, warten, bis sie abgeschlossen sind, und ihre Ausgabefehler zusammenführen. Aber ich bekomme nur eine Fehlermeldung. Die Verantwortlichkeiten jeder Methode sind wie folgt:

run – Führen Sie eine Funktion in einer Goroutine aus und erfassen Sie deren Fehler

waitalldone - Führen Sie alle Funktionsfehler zusammen und warten Sie, bis alle Funktionen abgeschlossen sind

do1、do2 - Testfunktion

import (
    "fmt"
    "go.uber.org/multierr"
    "sync"
    "testing"
)

type Cycle struct {
    errChan chan error
    wg sync.WaitGroup
}

func NewCycle() *Cycle {
    return &Cycle{
        errChan: make(chan error),
        wg:      sync.WaitGroup{},
    }
}

// run fn and collect its error into error channel
func (c *Cycle) Run(fn func() error) {
    c.wg.Add(1)
    go func() {
        defer c.wg.Done()
        if err := fn(); err != nil {
            c.errChan <- err
        }
    }()
}

// wait all fn finish and combine their error together
func (c *Cycle) WaitAllDone() error {
    var err error
    go func() {
        for {
            if tmpErr, ok := <-c.errChan; ok {
                err = multierr.Append(err, tmpErr)
            } else{
                break
            }
        }
    }()
    c.wg.Wait()
    close(c.errChan)
    return err
}

func Do1() error {
    return fmt.Errorf("ERR1")
}

func Do2() error {
    return fmt.Errorf("ERR2")
}

func Test41(t *testing.T) {
    c := NewCycle()
    c.Run(Do1)
    c.Run(Do2)
    if err := c.WaitAllDone(); err != nil {
        t.Log(err)
    }
}

Letztendlich gibt t.log(err) err1 oder err2 aus, aber ich möchte, dass es err1 err2 ausgibt. Warum wird ein Fehler übersehen? t.log(err)输出err1或err2，但我希望它输出err1 err2。为什么它会漏掉一个错误。

解决方法

这是因为 (*cycle).waitalldone 不会等待收集错误的 goroutine 完成。如果您使用 -race

Problemumgehung

Das liegt daran, dass (*cycle).waitalldone nicht darauf wartet, dass die Goroutine die Fehler sammelt. Wenn Sie Ihren Code mit dem Flag -race ausführen, werden manchmal mehrere Datenrennenfehler gemeldet. Das ist einer davon:

$ go test -race .
==================
warning: data race
write at 0x00c0000a0610 by goroutine 10:
  m.(*cycle).waitalldone.func1()
      /home/zeke/src/temp/76370962/main_test.go:40 +0xb6

previous read at 0x00c0000a0610 by goroutine 7:
  m.(*cycle).waitalldone()
      /home/zeke/src/temp/76370962/main_test.go:48 +0x14e
  m.test41()
      /home/zeke/src/temp/76370962/main_test.go:63 +0xa4
  testing.trunner()
      /snap/go/current/src/testing/testing.go:1576 +0x216
  testing.(*t).run.func1()
      /snap/go/current/src/testing/testing.go:1629 +0x47

rangeDiese Änderung behebt das Problem:

func (c *cycle) waitalldone() error {
    var err error
+   done := make(chan int)
    go func() {
        for {
            if tmperr, ok := <-c.errchan; ok {
                err = multierr.append(err, tmperr)
            } else {
                break
            }
        }
+       close(done)
    }()
    c.wg.wait()
    close(c.errchan)
+   <-done
    return err
  }

🎜Und die for-Schleife kann mit der 🎜-Klausel vereinfacht werden: 🎜

func (c *Cycle) WaitAllDone() error {
    var err error
    done := make(chan int)
    go func() {
        for tmpErr := range c.errChan {
            err = multierr.Append(err, tmpErr)
        }
        close(done)
    }()
    c.wg.Wait()
    close(c.errChan)
    <-done
    return err
}

Das obige ist der detaillierte Inhalt vonWarum erhalte ich nur einige Fehler und nicht alle Fehler der von mir gestarteten Goroutine?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!