当前位置: 首页 > news >正文

go如何终止多个for select循环嵌套

 空山新雨后,天气晚来秋。

目录

分类说明

总结


分类说明

for select循环嵌套,如何终止?上代码:

    stop := make(chan struct{})go func() {for i := 1; i < 3; i++ {fmt.Println("writed ", i)time.Sleep(time.Second * 1)}close(stop)fmt.Println("stop closed.")}()go func() {stop1:for {select {case <-stop:fmt.Println("recv 1")break stop1default:fmt.Println("A 1 default...")for {select {case <-stop:fmt.Println("recv 2")break stop1default:fmt.Println("A 2 default...")time.Sleep(time.Second * 1)}}}}fmt.Println("A 结束")}()fmt.Println("已关闭", stop == nil)for i := 1; i < 10; i++ {time.Sleep(time.Second * 1)fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())}

如上,内外均监听了stop,内层接受到信号后直接终止stop1,全流程正常结束。效果如下:
speed running:

已关闭 false
A 1 default...
A 2 default...
writed  1
A 2 default...
writed  2
ch==nil:  false    num= 3
ch==nil:  false    num= 3
A 2 default...
stop closed.
recv 2
A 结束
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1

换成先终止内层也可:

    stop := make(chan struct{})go func() {for i := 1; i < 3; i++ {fmt.Println("writed ", i)time.Sleep(time.Second * 1)}close(stop)fmt.Println("stop closed.")}()go func() {stop1:for {select {case <-stop: // 这里也可收到信号fmt.Println("recv 1")break stop1default:fmt.Println("A 1 default...")stop2:for {select {case <-stop: // 这里可收到信号fmt.Println("recv 2")break stop2 // 换成终止内层default:fmt.Println("A 2 default...")time.Sleep(time.Second * 1)}}fmt.Println("A 2 stop...")}}fmt.Println("A 结束")}()fmt.Println("已关闭", stop == nil)for i := 1; i < 10; i++ {time.Sleep(time.Second * 1)fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())}

如上代码,在内层先终止自己的逻辑stop2,外层也随之终止,正常结束。效果如下:


speed running:

已关闭 false
writed  1
A 1 default...
A 2 default...
writed  2
ch==nil:  false    num= 3
A 2 default...
A 2 default...
ch==nil:  false    num= 3
stop closed.
recv 2
A 2 stop...
recv 1
A 结束
ch==nil:  false    num= 2
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1
ch==nil:  false    num= 1

如果不是基于关闭操作而是写入呢,内层和外层都能收到吗? 答:只会接收一次。

stop := make(chan struct{})go func() {for i := 1; i < 3; i++ {//ch <- ifmt.Println("writed ", i)time.Sleep(time.Second * 1)}stop <- struct{}{}// close(stop)fmt.Println("stop writed.")}()go func() {stop1:for {select {case <-stop: // 这里未收到信号fmt.Println("recv 1")break stop1//case data := <-ch://    fmt.Println("A  data=", data)default:fmt.Println("A 1 default...")stop2:for {select {case <-stop: // 这里可收到信号fmt.Println("recv 2")break stop2 // 换成终止内层default:fmt.Println("A 2 default...")time.Sleep(time.Second * 1)}}fmt.Println("A 2 stop...")}}fmt.Println("A 结束")}()fmt.Println("stop == nil: ", stop == nil)for i := 1; i < 10; i++ {time.Sleep(time.Second * 1)fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())}close(stop)fmt.Println("stop已关闭, ", stop == nil)

speed running:

stop == nil:  false
writed  1
A 1 default...
A 2 default...
A 2 default...
writed  2
ch==nil:  false    num= 3
recv 2
A 2 stop...
A 1 default...
A 2 default...
stop writed.
ch==nil:  false    num= 3
ch==nil:  false    num= 2
A 2 default...
A 2 default...
ch==nil:  false    num= 2
ch==nil:  false    num= 2
A 2 default...
A 2 default...
ch==nil:  false    num= 2
A 2 default...
ch==nil:  false    num= 2
ch==nil:  false    num= 2
A 2 default...
A 2 default...
ch==nil:  false    num= 2
stop已关闭,  false

总结

触发条件需要全部结束时,直接终止最外层for select 即可达到其下嵌套的所有该循环的目的。

http://www.lryc.cn/news/279853.html

相关文章:

  • nginx(1.13.7)首次安装出现:【make: *** 没有规则可以创建“default”需要的目标“build” 问题】解决措施
  • 2024.1.8 关于 Redis 数据类型 Zset 集合命令、编码方式、应用场景
  • ffmpeg[学习(四)](代码实现) 实现音频数据解码并且用SDL播放
  • C++ 字符串哈希 || 字符串前缀哈希法
  • 【java】项目部署liunx服务器的简单步骤
  • 深度学习笔记(五)——网络优化(1):学习率自调整、激活函数、损失函数、正则化
  • 鸿蒙开发现在就业前景怎样?
  • 试用统信服务器操作系统UOS 20
  • [情商-11]:人际交流的心理架构与需求层次模型
  • 【.NET Core】Lazy<T> 实现延迟加载详解
  • 坑记(HttpInputMessage)
  • day04打卡
  • 语义分割miou指标计算详解
  • Unity3d 实现直播功能(无需sdk接入)
  • 计算机缺失msvcr100.dll如何修复?分享五种实测靠谱的方法
  • 面试宝典进阶之redis缓存面试题
  • 调试(c语言)
  • opencv-4.8.0编译及使用
  • Jmeter 性能-监控服务器
  • Excel学习
  • 【技能---labelme软件的安装及其使用--ubuntu】
  • 回归预测 | Matlab实现SSA-CNN-LSTM-Attention麻雀优化卷积长短期记忆神经网络注意力机制多变量回归预测(SE注意力机制)
  • css垂直水平居中的几种实现方式
  • OpenHarmony之hdc
  • 【爬虫实战】-爬取微博之夜盛典评论,爬取了1.7w条数据
  • CST2024的License服务成功启动,仍报错——“The desired daemon is down...”,适用于任何版本!基础设置遗漏!
  • matlab中any()函数用法
  • Apache ECharts | 一个数据可视化图表库
  • m1 + swoole(hyperf) + yasd + phpstorm 安装和debug
  • group by 查询慢的话,如何优化?