Golang errgroup

Kira 收录于类别编程语言

2021-05-11 2023-03-11 约 306 字预计阅读 1 分钟

警告

本文最后更新于 2023-03-11，文中内容可能已过时。

介绍

errgroup 是Go语言的一个包，用于管理和协调多个并发任务，当其中任意一个任务出错时，可以及时结束所有任务，并返回错误信息。

运行模式

errgroup 有两种运行模型，开启任务后，如果遇到有 Goroutine 报错

一种是继续执行其它任务
另一种是取消其它的任务

继续执行其它任务

1

g := new(errgroup.Group)

取消其它的任务

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23


func main() {
	eg, ctx := errgroup.WithContext(context.Background())
	eg.Go(func() error {
		select {
		case <-ctx.Done():
		default:
			return errors.New("eg 1 err")
		}
		return nil
	})
	eg.Go(func() error {
		time.Sleep(1 * time.Second)
		select {
		case <-ctx.Done():
		default:
			fmt.Println("eg 2")
		}
		return nil
	})
	if err := eg.Wait(); err != nil {
		fmt.Println(err)
	}
}

问题

没有处理 panic。
~~没有控制并发 goroutine 数量~~ 新版本中有 SetLimit 控制 goroutine 数量。
如果内部报错，errgroup 会调用 g.cancel，如果在外面使用这个返回的 context，会报错。

推荐使用这个。

目录

Golang errgroup

介绍

运行模式

问题

相关内容

目录

Golang errgroup

介绍

运行模式

问题

相关内容

sync.Map

Go的垃圾回收

分布式锁

Go的测试

Go逃逸分析