您的位置:首页 > 汽车 > 时评 > 陕西省建设网信息截图_公司装修预算表_app营销模式有哪些_品牌推广网络公司

陕西省建设网信息截图_公司装修预算表_app营销模式有哪些_品牌推广网络公司

2024/11/17 17:52:49 来源:https://blog.csdn.net/bocai_xiaodaidai/article/details/143387113  浏览:    关键词:陕西省建设网信息截图_公司装修预算表_app营销模式有哪些_品牌推广网络公司
陕西省建设网信息截图_公司装修预算表_app营销模式有哪些_品牌推广网络公司

errgroup.Groupsync.WaitGroup 的主要区别在于它们的错误处理和协程管理方式。

errgroup.Group 专为并发操作中的错误捕获设计,任意goroutine返回错误时,会立即终止其他goroutine的执行

sync.WaitGroup 主要用于等待多个 goroutine 完成,不会直接处理错误。

用法示例:

// errgroup
import ("fmt""golang.org/x/sync/errgroup"
)func main() {group := new(errgroup.Group)group.Go(func() error {// 模拟一个操作,可能会失败err := someOperation()if err != nil {return fmt.Errorf("operation failed: %v", err)}return nil})// 等待所有任务完成,并捕获错误if err := group.Wait(); err != nil {fmt.Println("任务执行中遇到错误:", err)} else {fmt.Println("所有任务执行完成")}
}
工作流程
  1. 调用 group.Go 添加需要并发执行的任务。
  2. group.Wait() 会等待所有任务完成。如果某个 goroutine 返回错误,Wait 会返回该错误。
  3. errgroup 会终止错误出现后所有未完成的 goroutine,确保资源节省和异常处理的统一性。
优点
  • 错误处理:直接返回错误,避免了手动捕获。
  • 中止机制:在遇到错误后自动中止其他任务。
import ("fmt""sync"
)func main() {var wg sync.WaitGroupvar mu sync.Mutex // 用于防止并发访问results := make(map[int]string)for i := 1; i <= 5; i++ {wg.Add(1)go func(id int) {defer wg.Done()result, err := someOperation(id)mu.Lock()defer mu.Unlock() // 锁定操作以确保安全访问if err != nil {results[id] = fmt.Sprintf("error: %v", err)} else {results[id] = fmt.Sprintf("success: %v", result)}}(i)}wg.Wait()fmt.Println("所有操作完成", results)
}

errgroup.Groupsync.WaitGroup 的总结对比

特性errgroup.Groupsync.WaitGroup
错误处理支持,返回第一个错误并中止其他任务不支持,需手动处理
中止机制出现错误后可中止其他任务不支持
适合场景并发任务中需统一错误处理仅需等待所有任务完成
代码简洁性更简洁,内置错误处理需要手动处理错误和并发访问控制
底层实现基于 sync.WaitGroup 进一步封装基础并发任务等待工具

选择哪种方式取决于需求,若并发任务中需要统一的错误捕获和中止机制,errgroup.Group 是更好的选择;若仅需等待所有任务执行完毕,可使用 sync.WaitGroup

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com