Go并发神器」Error Group用法全解析！三步搞定协程错误管理🚀

package main  
import (  
    "context"  
    "fmt"  
    "golang.org/x/sync/errgroup"  
    "time"  
)  
 
func main() {  
    g, ctx := errgroup.WithContext(context.Background())  
 
    // 启动3个子任务  
    g.Go(func() error {  
        time.Sleep(1 * time.Second)  
        fmt.Println("任务1完成")  
        return nil // 无错误  
    })  
 
    g.Go(func() error {  
        time.Sleep(2 * time.Second)  
        return fmt.Errorf("任务2执行失败") // 模拟错误  
    })  
 
    g.Go(func() error {  
        select {  
        case <-ctx.Done(): // 监听Context取消信号  
            fmt.Println("任务3因上下文取消而终止")  
            return nil  
        case <-time.After(3 * time.Second):  
            fmt.Println("任务3完成")  
            return nil  
        }  
    })  
 
    if err := g.Wait(); err != nil {  
        fmt.Printf("并发任务出错：%v\n", err)  
    }  
}  

func DownloadFiles(urls []string) error {  
    g, _ := errgroup.WithContext(context.Background())  
 
    for _, url := range urls {  
        u := url // 避免闭包捕获循环变量  
        g.Go(func() error {  
            resp, err := http.Get(u)  
            if err != nil {  
                return fmt.Errorf("下载%s失败：%v", u, err)  
            }  
            defer resp.Body.Close()  
            // 写入本地文件（略）  
            return nil  
        })  
    }  
 
    return g.Wait()  
}