go goroutine 怎样进行错误处理
前言
在 Go 语言程序开发中，goroutine 的使用是比较频繁的，因此在日常编码的时候 goroutine 里的错误处理，怎么做会比较好呢？
一般我们的业务代码如下：
func main() {
var wg sync.WaitGroup
wg.Add(2)
go func() {
//... 业务逻辑
wg.Done()
}()
go func() {
//... 业务逻辑
wg.Done()
}()
wg.Wait()
}
在上面的代码中，我们运行了多个 goroutine，每个协程又是单独行动的，想要抛出 error 错误信息，也不怎么明智。
通过错误日志记录
常用的第一种方法：通过把错误记录写入到日志文件中，再结合相关的 logtail 进行采集和梳理。
但这又会引入新的问题，那就是调用错误日志的方法写的到处都是，代码结构也比较乱、不直观。
最重要的是无法针对 error 做特定的逻辑处理和流转。
利用 channel 传输
大家可能会想到 Go 的经典哲学：不要通过共享内存来通信，而是通过通信来实现内存共享（Do not communicate by sharing memory; instead, share memory by communicating）。
第二种方法：利用 channel 来传输多个 goroutine 中的 errors：
func main() {
cherrors := make(chan error)
wgDone := make(chan bool)
var wg sync.WaitGroup
wg.Add(2)
go func() {
//... 业务逻辑
wg.Done()
}()
go func() {
//... 业务逻辑
err := returnErr()
if err != nil {
cherrors <- err
}
wg.Done()
}()
go func() {
wg.Wait()
close(wgDone)
}()
select {
case <-wgDone:
break
case err := <-cherrors:
close(cherrors)
fmt.Println(err)
}
time.Sleep(time.Second)
}
func returnErr() error {
return errors.New("出错啦。。我是错误信息")
}
虽然使用 channel 后已经方便了不少，但编写 channel 还要关心一些非业务向的逻辑。
使用 sync/errgroup
第三种方法，就是使用官方提供的 golang.org/x/sync/errgroup 标准库：
type Group
func WithContext(ctx context.Context) (*Group, context.Context)
func (g *Group) Go(f func() error)
func (g *Group) Wait() error
- Go：启动一个协程，在新的 goroutine 中调用给定的函数。
- Wait：等待协程结束，直到 Go 方法中的所有函数调用都返回，然后返回其中第一个非零错误（如果有错误的话）。
结合其特性能够非常便捷的针对多 goroutine 进行错误处理：
func main() {
group := new(errgroup.Group)
nums := []int{-1, 0, 1}
for _, num := range nums {
num := num
group.Go(func() error {
res, err := output(num)
fmt.Println(res)
return err
})
}
if err := group.Wait(); err != nil {
fmt.Println("Get errors: ", err)
} else {
fmt.Println("Get all num successfully!")
}
}
func output(num int) (int, error) {
if num < 0 {
return 0, errors.New("math: square root error!")
}
return num, nil
}
每启动一个新的 goroutine 都直接使用 Group.Go 方法，在等待和错误处理上使用 Group.Wait 方法。
这种方法进行错误处理的好处是不需要关注非业务逻辑的控制代码，比较简洁明了。
总结
在 Go 语言中，goroutine 是一种常用的方法，为此我们需要更了解 goroutine 的一系列相关知识，像是 context、error处理等
在团队开发中，统一一定的规范，这样的代码阅读起来就会比较明朗，一些隐藏很深的 Bug 也会减少很多。
到此这篇关于go goroutine 怎样进行错误处理的文章就介绍到这了,更多相关go goroutine 错误处理内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了golang协程与线程区别简要介绍，进程是操作系统资源分配的基本单位，是程序运行的实例，线程是操作系统调度到CPU中执行的基本单位2022-06-06
自定义类型是 Go 语言中非常重要的概念之一，通过自定义类型，我们可以更好地封装数据、组织代码，提高程序的可读性和可维护性。本文将从以下几个方面介绍 Go 自定义类型的相关知识，感兴趣的可以了解一下2023-04-04
Go是 Goolge 开发的一种静态型、编译型、并发型，并具有垃圾回收功能的语言，Go 语言上手非常容易，它的风格类似于 C 语言，Go 语言号称是互联网时代的 C 语言，那么它到底有多火呢，一起看看吧2021-05-05
在Go语言中,fmt包提供了丰富的格式化占位符用于输出不同类型的数据,了解和选择合适的占位符对于确保输出内容的正确性和可读性至关重要,本文就来介绍一下,感兴趣的可以学习2024-10-10
这篇文章主要介绍了基于golang的简单分布式延时队列服务的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-02-02
这篇文章主要介绍了Golang如何使用go.mod配置加载本地模块问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
这篇文章主要为大家详细介绍了Golang如何在编译时实现注入版本信息，文中的示例代码讲解详细，具有一定的学习价值，感兴趣的可以了解一下2023-06-06
这篇文章主要给大家介绍了golang实现可中断的流式下载,文中通过代码示例给大家介绍的非常详细,对大家的学习或工作有一定的帮助,需要的朋友可以参考下2024-01-01
这篇文章主要为大家介绍了Air实现Go程序实时热重载使用过程解析示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪2022-04-04
golang跳转语句goto,break,continue的使用及区别说明
这篇文章主要介绍了golang跳转语句goto,break,continue的使用及区别说明，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-12-12
最新评论