Go 语言 errgroup 包并发执行一组 goroutine ，并能够捕获这些 goroutine 中的任何错误

你的名字 2023-10-12 09:11 2阅读 0赞

#### 阅读目录 ####

*  Go 语言 errgroup 包并发执行一组 goroutine ，并能够捕获这些 goroutine 中的任何错误

## Go 语言 errgroup 包并发执行一组 goroutine ，并能够捕获这些 goroutine 中的任何错误 ##

errgroup 包提供了一种用于并发执行一组 goroutine 的方式，并能够捕获这些 goroutine 中的任何错误。

它通常用于在并发环境中执行多个任务，并在所有任务完成或发生错误时进行相应的处理。

WithContext 是 errgroup 包中的一个函数，它接受一个上下文（Context）作为参数，并返回一个 Group 对象。Group 是 errgroup 包中的主要结构，它用于管理一组并发执行的任务。

WithContext 函数将提供的上下文与 Group 关联起来，以便在发生错误或上下文被取消时，可以通知所有的任务停止执行。上下文通常用于控制 goroutine 的生命周期和传递取消信号。

在你的代码中，watchCtx 是一个上下文对象，它会与 Group 关联起来。然后，你可以使用 Group 来启动一组并发任务，并在所有任务完成或发生错误时进行相应的处理。

package main
    
    import (
    	"context"
    	"fmt"
    	"golang.org/x/sync/errgroup"
    	"time"
    )
    
    func main() {
        
    	// 创建一个上下文对象
    	ctx := context.Background()
    
    	// 创建一个带有上下文的 errgroup.Group
    	group, ctx := errgroup.WithContext(ctx)
    
    	// 启动第一个任务
    	group.Go(func() error {
        
    		// 模拟一个耗时的任务
    		time.Sleep(2 * time.Second)
    		fmt.Println("Task 1 completed")
    		return nil
    	})
    
    	// 启动第二个任务
    	group.Go(func() error {
        
    		// 模拟一个有错误的任务
    		time.Sleep(1 * time.Second)
    		fmt.Println("Task 2 completed with error")
    		return fmt.Errorf("Task 2 encountered an error")
    	})
    
    	// 启动第三个任务
    	group.Go(func() error {
        
    		// 模拟一个耗时的任务
    		time.Sleep(3 * time.Second)
    		fmt.Println("Task 3 completed")
    		return nil
    	})
    
    	// 等待所有任务完成或发生错误
    	err := group.Wait()
    
    	if err != nil {
        
    		fmt.Println("Error occurred:", err)
    	} else {
        
    		fmt.Println("All tasks completed successfully")
    	}
    }

PS E:\TEXT\test> go run .\test.go
    Task 2 completed with error
    Task 1 completed
    Task 3 completed
    Error occurred: Task 2 encountered an error
    PS E:\TEXT\test>

在这个示例中，我们首先创建了一个上下文对象 ctx。  
然后，我们使用 errgroup.WithContext(ctx) 创建了一个 Group 对象 group，并将它与上下文对象关联起来。

接下来，我们使用 group.Go 启动了三个并发任务。  
第一个任务会耗时2秒完成，  
第二个任务会耗时1秒并返回一个错误，  
第三个任务会耗时3秒完成。

最后，我们调用 group.Wait() 来等待所有任务完成或发生错误。  
如果有任务返回了错误，那么 Wait() 会立即返回该错误，否则会返回 nil。  
在这个例子中，第二个任务返回了一个错误，因此在最后打印出了错误信息。

请注意，errgroup 包还提供了其他方法来管理并发任务，如 group.Wait()、group.Go() 和 group.Wait()。你可以根据自己的需求选择合适的方法来使用。