我今天一直在研究 Goroutines、Channels 和 WaitGroup，在閱讀了一段時(shí)間之后，我終于開(kāi)始理解這個(gè)概念了。我的問(wèn)題是，我不確定在這樣工作時(shí)如何處理錯(cuò)誤，主要是因?yàn)槲沂褂昧?WaitGroup。使用 WaitGroup 時(shí)，我首先添加將要執(zhí)行的 goroutine 數(shù)量，但如果其中之一發(fā)生錯(cuò)誤怎么辦？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")}游樂(lè)場(chǎng)：https://play.golang.org/p/ZLsBSqdMD49我已盡力提供一個(gè)例子來(lái)說(shuō)明我正在談?wù)摰膬?nèi)容。一個(gè)循環(huán)將運(yùn)行 10 次，doSomething()并且每次迭代都會(huì)調(diào)用waitGroup.Done()，但是如果在這一切過(guò)程中發(fā)生錯(cuò)誤怎么辦，如 所示someFunctionThatCanError()？當(dāng)我現(xiàn)在嘗試通過(guò)返回和/或取消頻道來(lái)解決它時(shí)，我最終陷入了僵局，所以我有點(diǎn)不確定從這里該去哪里。我也不確定如何處理我認(rèn)為正在等待更多事情發(fā)生的 WaitGroup。非常感謝任何幫助。
1 回答
慕虎7371278
TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超4個(gè)贊
使用golang.org/x/sync/errgroup等待并處理來(lái)自 goroutine 的錯(cuò)誤。
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 關(guān)注
- 182 瀏覽
添加回答
舉報(bào)
0/150
提交
取消