如何接受并发goroutine的错误
实现类似errgroup的功能
其实比较简单了，就是在并发goroutine的时候，我们根据初始化的goroutine的数量初始化一个
chan error类型的chan，然后每个goroutine在遇到错误时候，将error写入chan，这样主goroutine通过for range去遍历这个chan就行了。
代码
package main
import (
"errors"
"fmt"
"runtime"
"sync"
)
func main() {
ch := make(chan error, 3)
wg := sync.WaitGroup{}
wg.Add(3)
go func() {
defer wg.Done()
ch <- errors.New("err1")
}()
go func() {
defer wg.Done()
ch <- errors.New("err2")
}()
go func() {
defer wg.Done()
ch <- errors.New("err3")
}()
fmt.Println(runtime.NumGoroutine(), len(ch), cap(ch))
wg.Wait()
close(ch)
for err := range ch {
fmt.Println(err)
}
fmt.Println(runtime.NumGoroutine(), len(ch), cap(ch))
}
结果
小结
还有很多方式可以实现这个功能，不过最常见的还是在waitgroup中通过chan收集error，其它方式大家下去可以自行探索。
– END –
原文始发于微信公众号（堆栈future）：如何接受并发goroutine的错误
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/103500.html
