Golang并发任务错误收集与处理示例

使用errgroup可实现并发任务的错误收集与快速失败，通过WithContext支持取消机制；若需汇总所有错误，则可用带缓冲channel配合WaitGroup，避免阻塞并确保正确关闭。

在Go语言中处理并发任务时，经常会遇到多个goroutine同时执行并可能返回错误的情况。如何安全地收集这些错误，并在所有任务完成或任意一个任务出错时做出响应，是编写健壮并发程序的关键。下面是一个实用的错误收集与处理示例。

使用errgroup.Group（推荐方式）

它允许你启动多个goroutine，并在任意一个返回非nil错误时自动取消其他任务（如果配合context使用），同时只返回第一个发生的错误。

示例代码：

package main
import (
"context"
"fmt"
"time"
"golang.org/x/sync/errgroup"
)
立即学习“go语言免费学习笔记（深入）”；
func main() {
ctx := context.Background()
g, ctx := errgroup.WithContext(ctx)
urls := []string{
    "https://httpbin.org/status/200",
    "https://www.php.cn/link/874b2add857bd9bcc60635a51eb2b697", // 模拟失败
    "https://httpbin.org/status/200",
}

for _, url := range urls {
    url := url // 注意变量捕获
    g.Go(func() error {
        return fetchURL(ctx, url)
    })
}

if err := g.Wait(); err != nil {
    fmt.Printf("请求失败: %v\n", err)
} else {
    fmt.Println("所有任务成功完成")
}
}
func fetchURL(ctx context.Context, url string) error {
select {
case https://www.php.cn/link/874b2add857bd9bcc60635a51eb2b697" {
return fmt.Errorf("请求 %s 失败，服务器错误", url)
}
fmt.Printf("成功获取: %s\n", url)
return nil
case 
在这个例子中，只要有一个fetchURL返回错误，g.Wait() 就会立即返回该错误，其余正在运行的任务也会因context被取消而尽快退出。

							

								
								

									如此AI员工
									
国内首个全链路营销获客AI Agent
								
								下载 
							
						
手动通过channel收集所有错误
如果你希望收集所有任务的错误而不是仅第一个，可以使用带缓冲的error channel。
这种方式适合需要汇总全部结果的场景，比如批量任务中统计成功与失败数量。
示例代码：
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
errCh := make(chan error, 3) // 缓冲channel，避免阻塞
tasks := []string{"task-1", "task-2", "task-3"}

for _, task := range tasks {
    wg.Add(1)
    go func(t string) {
        defer wg.Done()
        err := processTask(t)
        if err != nil {
            errCh <- fmt.Errorf("任务 %s 执行失败: %w", t, err)
        }
    }(task)
}

go func() {
    wg.Wait()
    close(errCh)
}()

var errors []error
for err := range errCh {
    errors = append(errors, err)
}

if len(errors) > 0 {
    fmt.Printf("共发生 %d 个错误:\n", len(errors))
    for _, e := range errors {
        fmt.Println(e)
    }
} else {
    fmt.Println("所有任务成功")
}
}
func processTask(name string) error {
if name == "task-2" {
return fmt.Errorf("模拟处理失败")
}
fmt.Printf("任务 %s 成功完成\n", name)
return nil
}
注意：errCh 必须有足够容量或由独立goroutine接收，否则发送错误可能导致goroutine阻塞，进而引发deadlock。
选择合适的策略
选择哪种方式取决于你的业务需求：

想在第一个错误发生时快速失败？用 errgroup

需要知道所有任务的执行结果？用 error channel + WaitGroup

任务间有关联且需取消机制？结合 context 使用 errgroup

基本上就这些。实际项目中推荐优先使用 errgroup，简洁且语义清晰。手动管理错误channel则提供更大的灵活性，但要注意资源释放和channel关闭问题。