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.mzph.cn/news/618040.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

「HDLBits题解」Alwaysblock2

本专栏的目的是分享可以通过HDLBits仿真的Verilog代码 以提供参考 各位可同时参考我的代码和官方题解代码 或许会有所收益 题目链接&#xff1a;Alwaysblock2 - HDLBits // synthesis verilog_input_version verilog_2001 module top_module(input clk,input a,input b,output…

phpcms v9外链文章获取点击量

默认phpcms v9的外链文章因为直接跳转&#xff08;不进入详情页模板&#xff09;&#xff0c;导致外链文章的点击量一直是0&#xff0c;而我们有时需要按点击量排行或者排序的时候&#xff0c;就有问题了。 这里我们借助系统自带的点击量接口api来获取&#xff1a; 一、前台JS…

【随笔】遗传算法优化的BP神经网络(随笔,不是很详细)

文章目录 一、算法思想1.1 BP神经网络1.2 遗传算法1.3 遗传算法优化的BP神经网络 二、代码解读2.1 数据预处理2.2 GABP2.3 部分函数说明 一、算法思想 1.1 BP神经网络 BP神经网络&#xff08;Backpropagation Neural Network&#xff0c;反向传播神经网络&#xff09;是一种监…

Linux第21步_取消鼠标中键的复制粘贴功能

在ubuntu18.04操作系统中&#xff0c;选中文本后&#xff0c;若按下鼠标中键&#xff0c;就可以执行复制粘贴&#xff0c;相当于 CtrlshiftC 后又按了 CtrlshiftV。在Linux系统中&#xff0c;基本上都是这么配置的。在windows系统中&#xff0c;我们习惯用Ctrl-C复制&#xff0…

普通人想通过抖音赚钱要先知道这4点

1.变现方式 想做抖音首先要想好变现路径以及通过什么方式变现。做抖音就是在经营某一类人群&#xff0c;因为人群绑定了精准标签&#xff0c;系统推送的精准又绑定了变现。所以要明确你经营的目标人群是谁&#xff0c;你在做谁的生意&#xff0c;你要赚谁的钱。他们的年龄、收…

OpenCV-Python的版本介绍及区别

OpenCV-Python版本介绍 OpenCV-Python有多个版本&#xff0c;每个版本都有其特定的功能和改进。以下是一些常见OpenCV-Python版本及其介绍和区别&#xff1a; OpenCV-Python 2.x版本 这是OpenCV-Python的旧版本&#xff0c;支持Python 2.x。它包含了许多传统的计算机视觉功能&…

可盐可甜的红色马甲背心

膨体棉腈面料不易皱&#xff0c;搭配阿兰花菱形镂空设计 真的绝绝子&#xff0c;红色吸睛又美观 随便搭配一件衬衫去穿&#xff0c;自带文艺气息 氛围感直接拉满 出街拍照很出片&#xff0c;时髦又气质 女孩子的甜美&#xff0c;温柔等都可以突显 有喜欢的可以尝试一下哟…

超维空间M1无人机使用说明书——61、ROS无人机物体识别与精准投放

引言&#xff1a;基于空中物流的项目背景。我们提供了使用基于诗句的物体识别和精准投放、降落。实现原理如下&#xff1a; 1、在ROS下使用机载电脑实现物体识别 2、记载电脑根据反馈的位置发布运动控制指令 3、PX4解析机载电脑发布的命令&#xff0c;作出运动控制 4、设置…

将抖音视频转成MP3并下载

这篇是在上一篇的基础上写的&#xff0c;这篇负责抖音作者详情页的视频转声音提取&#xff0c;这篇需要用到后端。 本地启动后端后&#xff0c;在控制台输入对应代码&#xff0c;即可实现hover在封面上&#xff0c;按d一键下载音频 控制台代码 // 获取作者的视频列表var liEle…

【蓝桥备赛】特殊时间——时间日期类问题

题目链接 特殊时间 个人思路 枚举年份范围比较广&#xff0c;考虑略微复杂&#xff1b;枚举月日重点只要看月份需要枚举12个月&#xff1b;枚举时间有24小时。 综合起来看&#xff0c;枚举月日的讨论应该比较少。 详细分析看注释 参考代码 Java public class Main {publi…

LeetCode 2085. 统计出现过一次的公共字符串

目录 一、题目 1、题目描述 2、接口描述 3、原题链接 二、解题报告 1、思路分析 2、复杂度 3、代码详解 C代码 ​Python3代码 一、题目 1、题目描述 给你两个字符串数组 words1 和 words2 &#xff0c;请你返回在两个字符串数组中 都恰好出现一次 的字符串的数目。 2…

我的创作纪念日(随便唠唠)

机缘 我在CSDN上面发表文章只是一时兴起&#xff0c;想着可以当作记录学习知识的一个笔记使用&#xff0c;并且我写的内容通常是我学习一段时间之后&#xff0c;经过了一段时间的沉淀&#xff08;这个时间通常是三个月到半年&#xff09;&#xff0c;觉得理解的够深刻之后才会…

思科无线AP 2802无法注册,手工指定控制器的IP

背景 Cisco AP 2802I Default username and password: Cisco Cisco 无法注册成功到wlc 5520上&#xff0c;AP上红灯一直闪烁。 Console连接AP&#xff0c;发现有获得Ip&#xff0c;但因为跨3层又没有dhcp option 43下发WLC IP&#xff0c;所以无法注册成功 。 获得IP地址&…

Docker与微服务实战(高级篇)- 【上】

Docker与微服务实战&#xff08;高级篇&#xff09;- 【上】 一、Docker复杂安装详说1.1 Mysql主从复制--原理-【尚硅谷Mysql高级篇】1.2 Mysql主从复制--【一主一从】搭建步骤1.2.1新建--【主服务器】--容器实例--33071.2.2.进入/app/mysql-master/conf目录下新建my.cnf1.2.3.…

Scipy 中级教程——信号处理

Python Scipy 中级教程&#xff1a;信号处理 Scipy 的信号处理模块提供了丰富的工具&#xff0c;用于处理和分析信号数据。在本篇博客中&#xff0c;我们将深入介绍 Scipy 中的信号处理功能&#xff0c;并通过实例演示如何应用这些工具。 1. 信号生成与可视化 首先&#xff…

【算法】简单的二分查找算法

一个简单的二分查找算法&#xff1a; import java.util.Arrays; public class BinarySearch {public static int rank(int key,int[] a){int lo0;int hia.length-1;while (lo<hi){int midlo(hi-lo)/2;if (key<a[mid])himid-1;else if (key>a[mid])lomid1;else return …

嵌入式linux 编译qt5(以v851s为例)

本文参考Blev大神的博客&#xff1a;Yuzuki Lizard V851S开发板 --移植 QT5.12.9教程&#xff08;群友Blev提供&#xff09; - Allwinner / 柚木PI-V851S - 嵌入式开发问答社区 (100ask.net) 一. 环境准备 1.下载qt5源码&#xff1a;Open Source Development | Open Source …

XXL-JOB相关问题及答案(2024)

1、XXL-JOB是什么&#xff1f;它的作用是什么&#xff1f; XXL-JOB是一个分布式任务调度平台&#xff0c;用于实现任务的定时调度、任务执行和任务监控。它具有可视化的任务管理界面&#xff0c;支持多种任务调度方式&#xff0c;并提供任务执行结果的监控和告警功能。XXL-JO…

okhttpclient.setsslsocketfactory 报错解决

以前一直都用HttpUrlConnection这个类来做通信和进行文件下载&#xff0c;apk更新升级等。 后续因为更新apk的时候包体积较大&#xff0c;网络不好的时候&#xff0c;用HttpUrlConnection偶尔会下载失败&#xff0c;于是下载更新apk就改为了okhtt3这个库&#xff0c;其他业务请…

【Maven】001-Maven 概述

【Maven】001-Maven 概述 文章目录 【Maven】001-Maven 概述一、Maven 概述1、为什么学习 MavenMaven 作为依赖管理工具Maven 作为构建工具其它 2、Maven 介绍3、Maven 软件工作模型图 一、Maven 概述 1、为什么学习 Maven Maven 作为依赖管理工具 依赖管理&#xff1a; Mave…