Go 优雅处理goroutines错误

2024-06-07 12:12

本文主要是介绍Go 优雅处理goroutines错误,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在Go语言中,goroutines是轻量级的线程,它们在后台运行,可以并发执行任务。优雅地处理goroutines中的错误是确保程序稳定性和可维护性的关键。

使用Channel返回错误

Go中goroutines通常通过channel来通信。你可以创建一个额外的channel来发送错误信息。

案例一:

goroutines 中的通道理解为一种可以发射或接收信号的传感器。然后,我会将错误视为信号。当传感器收到信号(错误)时,它会通知我们已经收到信号,然后我们就可以利用这些信号启动进一步的流程。

package mainimport ("errors""fmt""time"
)func main() {errCh := make(chan error, 3)go errorSpawning(3*time.Second, errCh)go errorSpawning(2*time.Second, errCh)go errorSpawning(4*time.Second, errCh)for err := range errCh {if err != nil {panic(err)}}
}func errorSpawning(delay time.Duration, errCh chan<- error) {time.Sleep(delay) //模拟业务处理时间fmt.Printf("业务运行%v后出现错误\n", delay)errCh <- errors.New("处理业务出错")
}

只需声明 errCh(错误通道),通道大小等于需要处理的 goroutines 数量。在本例中,errCh 的大小为 3。

然后将 errCh 作为 chan<- error 传递到函数中(该符号表示 errCh 在该函数中只是一个接收器)。再用一个 for 循环来捕捉错误信号,循环的 channel 为 errCh。

使用这种写法,如果有一个 goroutines 遇到错误,main() 函数就会崩溃。无需等待所有 goroutines 全部结束。

案例二:

package mainimport ("errors""fmt""time"
)func main() {errCh := make(chan error, 3)go errorSpawning(3*time.Second, errCh)go errorSpawning(2*time.Second, errCh)go errorSpawning(4*time.Second, errCh)for {select {case e := <-errCh:if e != nil {fmt.Println(e)}case <-time.After(time.Second * 5):return}}
}func errorSpawning(delay time.Duration, errCh chan<- error) {defer func() {if r := recover(); r != nil {//...}}()time.Sleep(delay) //模拟业务处理时间err := errors.New("处理" + delay.String() + "的业务出错")errCh <- errif err != nil {panic(err)}
}

 一个goroutine错误不影响其他的goroutine 

这篇关于Go 优雅处理goroutines错误的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1039139

相关文章

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

PHP轻松处理千万行数据的方法详解

《PHP轻松处理千万行数据的方法详解》说到处理大数据集,PHP通常不是第一个想到的语言,但如果你曾经需要处理数百万行数据而不让服务器崩溃或内存耗尽,你就会知道PHP用对了工具有多强大,下面小编就... 目录问题的本质php 中的数据流处理:为什么必不可少生成器:内存高效的迭代方式流量控制:避免系统过载一次性

Python实现批量CSV转Excel的高性能处理方案

《Python实现批量CSV转Excel的高性能处理方案》在日常办公中,我们经常需要将CSV格式的数据转换为Excel文件,本文将介绍一个基于Python的高性能解决方案,感兴趣的小伙伴可以跟随小编一... 目录一、场景需求二、技术方案三、核心代码四、批量处理方案五、性能优化六、使用示例完整代码七、小结一、

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》:本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法(1)多个e

PHP应用中处理限流和API节流的最佳实践

《PHP应用中处理限流和API节流的最佳实践》限流和API节流对于确保Web应用程序的可靠性、安全性和可扩展性至关重要,本文将详细介绍PHP应用中处理限流和API节流的最佳实践,下面就来和小编一起学习... 目录限流的重要性在 php 中实施限流的最佳实践使用集中式存储进行状态管理(如 Redis)采用滑动

MyBatis-plus处理存储json数据过程

《MyBatis-plus处理存储json数据过程》文章介绍MyBatis-Plus3.4.21处理对象与集合的差异:对象可用内置Handler配合autoResultMap,集合需自定义处理器继承F... 目录1、如果是对象2、如果需要转换的是List集合总结对象和集合分两种情况处理,目前我用的MP的版本

深度解析Java @Serial 注解及常见错误案例

《深度解析Java@Serial注解及常见错误案例》Java14引入@Serial注解,用于编译时校验序列化成员,替代传统方式解决运行时错误,适用于Serializable类的方法/字段,需注意签... 目录Java @Serial 注解深度解析1. 注解本质2. 核心作用(1) 主要用途(2) 适用位置3

Debian 13升级后网络转发等功能异常怎么办? 并非错误而是管理机制变更

《Debian13升级后网络转发等功能异常怎么办?并非错误而是管理机制变更》很多朋友反馈,更新到Debian13后网络转发等功能异常,这并非BUG而是Debian13Trixie调整... 日前 Debian 13 Trixie 发布后已经有众多网友升级到新版本,只不过升级后发现某些功能存在异常,例如网络转

Python自动化处理PDF文档的操作完整指南

《Python自动化处理PDF文档的操作完整指南》在办公自动化中,PDF文档处理是一项常见需求,本文将介绍如何使用Python实现PDF文档的自动化处理,感兴趣的小伙伴可以跟随小编一起学习一下... 目录使用pymupdf读写PDF文件基本概念安装pymupdf提取文本内容提取图像添加水印使用pdfplum

C# LiteDB处理时间序列数据的高性能解决方案

《C#LiteDB处理时间序列数据的高性能解决方案》LiteDB作为.NET生态下的轻量级嵌入式NoSQL数据库,一直是时间序列处理的优选方案,本文将为大家大家简单介绍一下LiteDB处理时间序列数... 目录为什么选择LiteDB处理时间序列数据第一章:LiteDB时间序列数据模型设计1.1 核心设计原则