在go中使用goroutine，协程中函数是无法对返回数据直接处理error的。官方库中，有着这么一个收纳子任务error的包：errgroup。

errgroup 包为一组子任务的 goroutine 提供了 goroutine 同步，错误取消功能。

使用

官方test demo中，ExampleGroup_justErrors和ExampleGroup_parallel可以看到，测试先并发一系列子任务，然后wait等待完成（阻塞的，同步）。

TestZeroGroup案例，则是测试多子任务，errgroup是否返回第一个遇到的错误。这里需要注意的是，即使有任务错误，其依然会执行完所有任务，但返回的只是第一个碰到的错误，即使有多个error。

衍生

** kratos**二次封装的errgroup，提供带recover的errgroup，err中包含详细堆栈信息。

errgroup 包含三种常用方式

1、直接使用 此时不会因为一个任务失败导致所有任务被 cancel:

1
2
3
4
5
g := &errgroup.Group{}
g.Go(func(ctx context.Context) {
    // NOTE: 此时 ctx 为 context.Background()
    // do something
})

2、WithContext 使用 WithContext 时不会因为一个任务失败导致所有任务被 cancel:

1
2
3
4
5
g := errgroup.WithContext(ctx)
g.Go(func(ctx context.Context) {
    // NOTE: 此时 ctx 为 errgroup.WithContext 传递的 ctx
    // do something
})

3、WithCancel 使用 WithCancel 时如果有一个人任务失败会导致所有未进行或进行中的任务被 cancel:

1
2
3
4
5
g := errgroup.WithCancel(ctx)
g.Go(func(ctx context.Context) {
    // NOTE: 此时 ctx 是从 errgroup.WithContext 传递的 ctx 派生出的 ctx
    // do something
})

设置最大并行数 GOMAXPROCS 对以上三种使用方式均起效
NOTE: 由于 errgroup 实现问题,设定 GOMAXPROCS 的 errgroup 需要立即调用 Wait() 例如:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
g := errgroup.WithCancel(ctx)
g.GOMAXPROCS(2)
// task1
g.Go(func(ctx context.Context) {
    fmt.Println("task1")
})
// task2
g.Go(func(ctx context.Context) {
    fmt.Println("task2")
})
// task3
g.Go(func(ctx context.Context) {
    fmt.Println("task3")
})
// NOTE: 此时设置的 GOMAXPROCS 为2, 添加了三个任务 task1, task2, task3 此时 task3 是不会运行的!
// 只有调用了 Wait task3 才有运行的机会
g.Wait() // task3 运行