为何在 func (g *Group) Wait() 函数中需要调用 g.cancel() 来处理错误

一分耕耘，一分收获！既然打开了这篇文章《为何在 func (g *Group) Wait() 函数中需要调用 g.cancel() 来处理错误》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

golang的错误组非常有用，下面是实现

func (g *group) go(f func() error) {
  g.wg.add(1)
  go func() {
    defer g.wg.done()
    if err := f(); err != nil {
      g.erronce.do(func() {
        g.err = err
        if g.cancel != nil {
          g.cancel()
        }
      })
    }
  }()
}

据我了解，一旦一个 go-routine 出现错误，错误组将取消所有其他 go-routine。然而，我感到困惑的是下面的等待函数：

func (g *Group) Wait() error {
  g.wg.Wait()
  if g.cancel != nil {
    g.cancel()
  }
  return g.err
}

为什么我们需要在这个函数中再次取消？您能否向我提供一个需要取消的案例？

我的意思是，在成功的情况下，所有 go 例程都完成了任务，因此不需要再次取消，另一方面，如果一个 go 例程失败，也不需要，因为我们在第一个代码块中取消了。

正确答案

快速回顾 errgroup：

errgroup.group 统一了错误传播和上下文取消。

调用例程wait()等待子任务完成；如果任何子任务返回错误，wait() 就会将该错误返回给调用者。 如果任何子任务返回错误，则组上下文将被取消，从而提前终止所有子任务。

关于该小组的背景： 如果父上下文（例如，http 请求上下文）被取消，则组上下文也会被取消。这有助于避免不必要的工作。例如，如果用户离开页面并取消 http 请求，我们可以立即停止。

从代码中可以看到，当创建errgroup时，会创建一个新的上下文：

// withcontext returns a new group and an associated context derived from ctx.
//
// the derived context is canceled the first time a function passed to go
// returns a non-nil error or the first time wait returns, whichever occurs
// first.
func withcontext(ctx context.context) (*group, context.context) {
    ctx, cancel := context.withcancel(ctx)
    return &group{cancel: cancel}, ctx
}

您在组上看到的取消函数是 withcancel 函数的返回值，并且属于这个新上下文，而不是直接属于该组。

一旦一个函数返回错误，就需要取消此上下文，而且如果操作完成，也需要取消，正如您从代码文档中看到的那样：“或第一次等待返回”

// Wait blocks until all function calls from the Go method have returned, then
// returns the first non-nil error (if any) from them.
func (g *Group) Wait() error {
    g.wg.Wait()
    if g.cancel != nil {
        g.cancel()
    }
    return g.err
}

这意味着整个操作已经完成。需要取消它的上下文以清理上下文的资源。也许该操作甚至启动了一个仍在运行且不再需要的子上下文，并且需要将取消传播到它。

理论要掌握，实操不能落！以上关于《为何在 func (g *Group) Wait() 函数中需要调用 g.cancel() 来处理错误》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！