golang高并发利器-errgroup

简介: golang高并发利器-errgroup

志不真则心不热,心不热则功不紧——颜元


1. 前言



说起如今的SJ政策,大家都发表了各自的看法,但是我在这里明确说下:只要教育在,培训行业一定会在,只不过以不同的形式运行罢了,谁都不希望自己的孩子输在教育的起跑线上,你家孩子不上课,人家孩子疯狂报班学习利用寒暑假或者周中,最后蒙蔽的永远是那些看不到这政策背后的因,只看到眼前的果(终于大家一样了)。所以刚需在,教培一定在。


2. 容易写的高并发控制技术



闲话不多说,直接上干货

我们之前写一个多goroutine的时候一般都会选择sync下面的WaitGroup,比如:


wg := sync.WaitGroup{}
  for i:=0; i<10; i++ {
     wg.Add(1)
     go func() {
        defer wg.Done()
   }()
  }
  wg.Wait()


但是这样会有问题,就是当我们想要知道某个goroutine报什么错误的时候发现很难,因为我们是直接go func(){}出去的,并没有返回值,因此对需要接受返回值做进一步处理的需求就无法满足了。


3. errgroup他来了



这是google对go的一个扩展包:

golang.org/x/sync/errgroup它可以帮助我们实现当有一个goroutine执行报错的时候,通过wait可以获取到错误,然后执行相应的操作,如下:


group, _ := errgroup.WithContext(context.Background())
  group.Go(func() error {
     defer func() {
        //recover
     }()
     //TODO:真正逻辑
  })
  if err := group.Wait(); err != nil {
     return nil, err
  }


这样当有一个或者多个goroutine报错的时候,我们可以轻松的获取err信息,然后做相应的后续操作,你看这样是不很方便呢?


4. 小结



欢迎大家转发和投稿哈,每天坚持学习一点点,社会就会对你好一点点,不要被外部的因素所影响,坚持做自己认为对的事情,加油


5.关注公众号



 微信公众号:堆栈future

相关文章
|
14天前
|
Go 计算机视觉
在Golang高并发环境中如何进行协程同步?
在此示例中,使用互斥锁来保护对共享计数器变量 c 的访问,确保并发的 HTTP 请求不会产生数据竞争。
37 3
|
Go 数据安全/隐私保护
golang mutex两加两解助你实现高并发控制
golang mutex两加两解助你实现高并发控制
|
Go
Golang高并发:生产者消费者模型
Golang高并发:生产者消费者模型
1737 0
|
2月前
|
Go
Golang语言之管道channel快速入门篇
这篇文章是关于Go语言中管道(channel)的快速入门教程,涵盖了管道的基本使用、有缓冲和无缓冲管道的区别、管道的关闭、遍历、协程和管道的协同工作、单向通道的使用以及select多路复用的详细案例和解释。
115 4
Golang语言之管道channel快速入门篇
|
2月前
|
Go
Golang语言文件操作快速入门篇
这篇文章是关于Go语言文件操作快速入门的教程,涵盖了文件的读取、写入、复制操作以及使用标准库中的ioutil、bufio、os等包进行文件操作的详细案例。
67 4
Golang语言文件操作快速入门篇
|
2月前
|
Go
Golang语言之gRPC程序设计示例
这篇文章是关于Golang语言使用gRPC进行程序设计的详细教程,涵盖了RPC协议的介绍、gRPC环境的搭建、Protocol Buffers的使用、gRPC服务的编写和通信示例。
104 3
Golang语言之gRPC程序设计示例
|
2月前
|
安全 Go
Golang语言goroutine协程并发安全及锁机制
这篇文章是关于Go语言中多协程操作同一数据问题、互斥锁Mutex和读写互斥锁RWMutex的详细介绍及使用案例,涵盖了如何使用这些同步原语来解决并发访问共享资源时的数据安全问题。
86 4
|
2月前
|
Go
Golang语言错误处理机制
这篇文章是关于Golang语言错误处理机制的教程,介绍了使用defer结合recover捕获错误、基于errors.New自定义错误以及使用panic抛出自定义错误的方法。
48 3
|
2月前
|
Go 调度
Golang语言goroutine协程篇
这篇文章是关于Go语言goroutine协程的详细教程,涵盖了并发编程的常见术语、goroutine的创建和调度、使用sync.WaitGroup控制协程退出以及如何通过GOMAXPROCS设置程序并发时占用的CPU逻辑核心数。
52 4
Golang语言goroutine协程篇
|
2月前
|
Prometheus Cloud Native Go
Golang语言之Prometheus的日志模块使用案例
这篇文章是关于如何在Golang语言项目中使用Prometheus的日志模块的案例,包括源代码编写、编译和测试步骤。
55 3
Golang语言之Prometheus的日志模块使用案例
下一篇
无影云桌面