在 go 并发编程中，处理错误至关重要。go 框架提供了两种机制：context.context：用于传递和传播取消和错误信息，包括取消操作和错误传播。errgroup：用于管理多个并发操作，包括等待所有操作完成和收集错误。
Go框架如何处理并发错误
在Go并发编程中，错误处理对于维护程序的可维护性和健壮性至关重要。Go框架提供了各种机制来简化并发错误处理，本文将讨论两种最常见的框架：context.Context和errgroup。
context.Context
立即学习“go语言免费学习笔记（深入）”；
context.Context是一个值对象，用于在并发操作中传递和传播取消和错误信息。它提供了以下主要功能：
- 取消: 可用于通知并发操作在发生错误或超时的事件发生时取消它。
- 错误传播: 可用于在并发操作中传播错误，从而允许在操作的任何阶段处理或收集错误。
实战案例:
import (
"context"
"errors"
"fmt"
"time"
)
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
err := doSomething(ctx)
if err != nil {
fmt.Println("Error occurred:", err)
}
}
func doSomething(ctx context.Context) error {
if ctx.Err() != nil {
return ctx.Err()
}
// 模拟可能的错误
if rand.Intn(2) == 0 {
return errors.New("Failed to perform operation")
}
return nil
}
在这个例子中，context.WithTimeout创建一个带有5秒超时值的上下文。doSomething函数会检查上下文中的错误，并在超时或取消的事件发生时返回该错误。
errgroup
errgroup是一个同步原语，用于管理多个并发操作。它提供了以下主要功能：
- 等待所有: 阻塞直到所有并发操作完成。
- 错误收集: 收集所有并发操作期间发生的错误（如果有的话）。
实战案例:
import (
"context"
"errors"
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
var errgroup error
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
for i := 0; i < 10; i++ {
// 启动一个并发goroutine
wg.Add(1)
go func(i int) {
defer wg.Done()
// 模拟可能的错误
if rand.Intn(2) == 0 {
errgroup = errors.New(fmt.Sprintf("Error occurred in goroutine %d", i))
}
}(i)
}
wg.Wait()
if errgroup != nil {
fmt.Println("At least one error occurred:", errgroup)
}
}
在这个例子中，sync.WaitGroup用于确保在所有goroutine完成之前程序不会退出。errgroup用于收集任何并发goroutine中发生的错误。如果至少有一个goroutine返回错误，那么程序将打印错误信息。
