我今天一直在研究 Goroutines、Channels 和 WaitGroup，在閱讀了一段時間之后，我終于開始理解這個概念了。我的問題是，我不確定在這樣工作時如何處理錯誤，主要是因為我使用了 WaitGroup。使用 WaitGroup 時，我首先添加將要執行的 goroutine 數量，但如果其中之一發生錯誤怎么辦？package mainimport ( "errors" "sync")var waitGroup sync.WaitGroupfunc main() { c := make(chan int, 10) waitGroup.Add(10) go doSomething(c) waitGroup.Wait()}func doSomething(c chan int) { for i := 0; i < 10; i++ { n, err := someFunctionThatCanError() if err != nil { // How do I end the routines and WaitGroups here? } c <- n waitGroup.Done() } close(c) }func someFunctionThatCanError() (int, error) { return 1, errors.New("an error")}游樂場：https://play.golang.org/p/ZLsBSqdMD49我已盡力提供一個例子來說明我正在談論的內容。一個循環將運行 10 次，doSomething()并且每次迭代都會調用waitGroup.Done()，但是如果在這一切過程中發生錯誤怎么辦，如 所示someFunctionThatCanError()？當我現在嘗試通過返回和/或取消頻道來解決它時，我最終陷入了僵局，所以我有點不確定從這里該去哪里。我也不確定如何處理我認為正在等待更多事情發生的 WaitGroup。非常感謝任何幫助。
1 回答
慕虎7371278
TA貢獻1802條經驗 獲得超4個贊
使用golang.org/x/sync/errgroup等待并處理來自 goroutine 的錯誤。
package main
import (
"errors"
"log"
"sync"
"golang.org/x/sync/errgroup"
)
func main() {
c := make(chan int, 10)
var g errgroup.Group
g.Go(func() error {
return doSomething(c)
})
// g.Wait waits for all goroutines to complete
// and returns the first non-nil error returned
// by one of the goroutines.
if err := g.Wait(); err != nil {
log.Fatal(err)
}
}
func doSomething(c chan int) error {
defer close(c)
for i := 0; i < 10; i++ {
n, err := someFunctionThatCanError()
if err != nil {
return err
}
c <- n
}
return nil
}
func someFunctionThatCanError() (int, error) {
return 1, errors.New("an error")
}
- 1 回答
- 0 關注
- 166 瀏覽
添加回答
舉報
0/150
提交
取消