如何优雅地终止 Go 中的 Goroutine 并处理错误？

惯用的 Goroutine 终止和错误处理

在 Go 并发领域，无缝处理 Goroutine 的终止和错误至关重要。考虑一个简单的用例，我们的目标是同时从多个远程服务器检索数据，返回第一个遇到的错误。

泄漏 Goroutines

最初的尝试可能涉及泄漏 Goroutine，如下所示代码片段：

func fetchAll() error {
  wg := sync.WaitGroup{}
  errs := make(chan error)
  leaks := make(map[int]struct{})
  //...
}

要解决这个问题，我们可以使用上下文或使用 errgroup 包：

错误组解决方案

errgroup 包提供了一种便捷的方法管理 goroutine 终止和错误。它会自动等待所有提供的 goroutine 完成，或者在出现任何错误时取消剩余的 goroutine。

func fetchAll(ctx context.Context) error {
  errs, ctx := errgroup.WithContext(ctx)
  //...
  return errs.Wait()
}

这段代码优雅地处理 goroutine 终止并返回遇到的第一个错误。

以上是如何优雅地终止 Go 中的 Goroutine 并处理错误？的详细内容。更多信息请关注PHP中文网其他相关文章！