Go协程错误处理实用技巧

func worker() error {
    // 模拟工作
    if someCondition {
        return fmt.Errorf("something went wrong")
    }
    return nil
}
func main() {
errCh := make(chan error, 1)
go func() {
    errCh <- worker()
}()

// 做其他事情...

if err := <-errCh; err != nil {
    fmt.Printf("worker failed: %v\n", err)
}
}

func doTask(id int) error {
    if id == 3 {
        return fmt.Errorf("task %d failed", id)
    }
    return nil
}
func main() {
var wg sync.WaitGroup
errCh := make(chan error, 5) // 缓冲大小等于goroutine数量
for i := 1; i <= 5; i++ {
    wg.Add(1)
    go func(i int) {
        defer wg.Done()
        if err := doTask(i); err != nil {
            errCh <- err
        }
    }(i)
}

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

for err := range errCh {
    fmt.Printf("error: %v\n", err)
}
}

ctx, cancel := context.WithCancel(context.Background())
errCh := make(chan error, 1)
go func() {
if err := longRunningTask(ctx); err != nil {
errCh <- err
cancel() // 触发其他协程退出
}
}()
// 等待结果或错误
select {
case <-ctx.Done():
fmt.Println("task canceled:", ctx.Err())
case err := <-errCh:
fmt.Println("got error:", err)
}