GolangWaitGroup错误处理与并发问题解析

func doWork(id int) error {
    // 模拟工作，可能出错
    if id == 3 {
        return fmt.Errorf("工作协程 %d 失败", id)
    }
    return nil
}
func runWithErrors() error {
var wg sync.WaitGroup
errCh := make(chan error, 5) // 缓冲大小等于goroutine数量
for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(i int) {
        defer wg.Done()
        if err := doWork(i); err != nil {
            errCh <- err
        }
    }(i)
}

wg.Wait()
close(errCh)

// 检查是否有任何错误
for err := range errCh {
    return err // 返回第一个错误（或可改为收集所有）
}
return nil
}

func runWithSharedError() error {
    var wg sync.WaitGroup
    var mu sync.Mutex
    var firstErr error
setErr := func(err error) {
    mu.Lock()
    defer mu.Unlock()
    if firstErr == nil {
        firstErr = err
    }
}

for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(i int) {
        defer wg.Done()
        err := doWork(i)
        if err != nil {
            setErr(err)
        }
    }(i)
}

wg.Wait()
return firstErr
}

import "golang.org/x/sync/errgroup"
func runWithErrGroup() error {
var g errgroup.Group
for i := 0; i < 5; i++ {
    i := i
    g.Go(func() error {
        return doWork(i)
    })
}

return g.Wait() // 返回第一个非nil错误
}

type MultiError struct {
    Errors []error
}
func (m *MultiError) Error() string {
var strs []string
for _, err := range m.Errors {
strs = append(strs, err.Error())
}
return strings.Join(strs, "; ")
}
func runAndCollectAllErrors() error {
var wg sync.WaitGroup
var mu sync.Mutex
var allErrors MultiError
for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(i int) {
        defer wg.Done()
        err := doWork(i)
        if err != nil {
            mu.Lock()
            allErrors.Errors = append(allErrors.Errors, err)
            mu.Unlock()
        }
    }(i)
}

wg.Wait()

if len(allErrors.Errors) > 0 {
    return &allErrors
}
return nil
}