如何在无限 for 循环中实现 goroutine; for{} 等待组完成后重试?
来源:stackoverflow
时间:2024-03-17 12:57:29 453浏览 收藏
在并发编程中,使用 goroutine 可以有效提高程序效率。本文将探讨如何在无限 for 循环中实现 goroutine,并利用等待组(wait group)在其中一个 goroutine 出现错误时触发重试逻辑。通过结合等待组和定时器,可以实现当所有 goroutine 完成或超时时,重新启动循环。这对于需要持续监控或执行任务的场景非常有用,例如网络流量监听和数据处理。
我的场景是我想触发多个监听网络流量的 go 例程,如果其中一个 go 例程函数出现错误,函数将执行 wg.done() 并且这个 for 循环应该等待其他 go 例程执行 wg.done() 并在一段时间后,比如睡眠十分钟,这个 for 循环应该再次运行。这有点像重试逻辑。有人可以帮忙解决这个问题吗?谢谢。下面是我到目前为止想到的代码。
package main import ( "errors" "fmt" "sync" ) func main() { var wg sync.WaitGroup for { wg.Add(1) go A(&wg) wg.Add(1) go B(&wg) } wg.Wait() } func A(wg *sync.WaitGroup) { fmt.Println("inside function A") err := errors.New("There is an error") if err != nil { wg.Done() } } func B(wg *sync.WaitGroup) { fmt.Println("Inside function B") err := errors.New("There is an error") if err != nil { wg.Done() } }
解决方案
您的 wg.wait()
永远不会运行,因为它位于无限循环之外。
我猜您正在寻找类似的东西?
for { tC := time.After(10 * time.Minute) // start timer before workers wg.Add(1) go A(&wg) wg.Add(1) go B(&wg) wg.Wait() // waits for both A & B to complete - whether they succeed or not <-tC // wait for remainder of 10 minutes before retrying }
上述的一个警告:如果 a
和 b
需要超过 10 分钟才能完成,则计时器将触发,并且 <-tc
将不会等待 - 导致循环立即重新启动。
最后,如果您想确保 a
或 b
的运行时间不超过 10 分钟,那么您的工作线程应该考虑利用 context 包。通过 context.withtimeout(...)
传递上下文,您可以确保一旦上下文取消(即超时),工作线程将退出。
好了,本文到此结束,带大家了解了《如何在无限 for 循环中实现 goroutine; for{} 等待组完成后重试?》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!
-
502 收藏
-
502 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
139 收藏
-
204 收藏
-
325 收藏
-
477 收藏
-
486 收藏
-
439 收藏
-
357 收藏
-
352 收藏
-
101 收藏
-
440 收藏
-
212 收藏
-
143 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 508次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习