select是什么

   select是Go语言层面提供的一种多路复用机制,用于检测当前goroutine连接的多个channel是否有数据准备完毕,可用于读或写。

        Go语言的select语句,是用来起一个goroutine监听多个Channel的读写事件,提高从多个Channel获取信息的效率,相当于是单线程处理多个IO事件,其思想基本相同。

select的用法

select的基本使用模式如下:

select {case <- channel1:     // 如果从channel1读取数据成功,执行case语句 do ...   case channel2 <- 1:   // 如果向channel2写入数据成功,执行case语句 do ...          default:              // 如果上面都没有成功,进入default处理流程do ...
}

        可以看到,select的用法形式类似于switch,但是区别于switch的是select各个case的表达式必须都是channel的读写操作select通过多个case语句监听多个channel的读写操作是否准备好可以执行,其中任何一个case可以执行了则选择该case语句执行,如果没有可以执行的case,则执行default语句,如果没有default,则当前goroutine会阻塞。 

空select永久阻塞

当一个select中什么语句都没有,没有任何case,将会永久阻塞:

package mainfunc main() {select {}
}

运行结果:

fatal error: all goroutines are asleep - deadlock!

        程序因为select语句导致永久阻塞,当前goroutine阻塞之后,由于Go语言自带死锁检测机制,发现当前goroutine永远不会被唤醒,会报上述死锁错误。 

没有default且case无法执行的select永久阻塞

看下面示例:

package mainimport ("fmt"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)select {case <-ch1:fmt.Printf("received from ch1")case num := <-ch2:fmt.Printf("num is: %d", num)}
}

运行结果:

fatal error: all goroutines are asleep - deadlock!

        程序中 select从两个channelch1ch2中读取数据,但是两个channel都没有数据,且没有goroutine往里面写数据,所以不可能读到数据,这两个case永远无法执行到,select也没有default,所以会出现永久阻塞,报死锁。 

单一case和default的select

package mainimport ("fmt"
)func main() {ch := make(chan int, 1)select {case <-ch:fmt.Println("received from ch")default:fmt.Println("default!!!")}
}

运行结果:

default!!!

        执行到select语句的时候,由于ch中没有数据,且没有goroutinechannel中写数据,所以case不可能执行到,就会执行default语句,打印出default!!!。 

 多个case和default的select

package mainimport ("fmt""time"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)go func() {time.Sleep(time.Second)for i := 0; i < 3; i++ {select {case v := <-ch1:fmt.Printf("Received from ch1, val = %d\n", v)case v := <-ch2:fmt.Printf("Received from ch2, val = %d\n", v)default:fmt.Println("default!!!")}time.Sleep(time.Second)}}()ch1 <- 1time.Sleep(time.Second)ch2 <- 2time.Sleep(4 * time.Second)
}

运行结果:

Received from ch1, val = 1
Received from ch2, val = 2
default!!!

        主goroutine中向后往管道ch1ch2中发送数据,在子goroutine中执行两个select,可以看到,在执行select的时候,那个case准备好了就会执行当下case的语句,最后没有数据可接受了,没有case可以执行,则执行default语句。

注意当多个case都准备好了的时候,会随机选择一个执行

package mainimport ("fmt"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)ch1 <- 5ch2 <- 6select {case v := <-ch1:fmt.Printf("Received from ch1, val = %d\n", v)case v := <-ch2:fmt.Printf("Received from ch2, val = %d\n", v)default:fmt.Println("default!!!")}
}

运行结果:

Received from ch2, val = 6

多次执行,2个case都有可能打印,这就是select选择的随机性。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/diannao/94325.shtml
繁体地址,请注明出处:http://hk.pswp.cn/diannao/94325.shtml
英文地址,请注明出处:http://en.pswp.cn/diannao/94325.shtml

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

相关文章

VUE+SPRINGBOOT从0-1打造前后端-前后台系统-整体示例

一、注册、登录、密码找回二、VUE前台系统三、VUE后台系统

深入解析SmolVLA:VLM与动作专家间的注意力机制交互

在机器人学习领域&#xff0c;如何有效地将视觉语言模型&#xff08;VLM&#xff09;的强大感知能力与低级动作控制相结合&#xff0c;是实现通用机器人智能的关键挑战。SmolVLA&#xff08;Small Vision-Language-Action&#xff09;架构正是在这一背景下应运而生&#xff0c;…

Spring Security 认证与授权实现机制

Spring Security 是一个功能强大且高度可定制的身份验证和访问控制框架&#xff0c;其认证和授权实现机制如下&#xff1a;一、认证(Authentication)实现 1. 核心组件 AuthenticationManager&#xff1a;认证入口点&#xff0c;委托给AuthenticationProviderAuthenticationProv…

开源的时间跟踪工具TimeTagger

简介 什么是 TimeTagger &#xff1f; TimeTagger 是一个开源的时间跟踪工具&#xff0c;旨在帮助用户记录和分析他们的时间使用情况。它提供了一个互动的用户界面和强大的报告功能&#xff0c;适合个人和自由职业者使用。 主要特点 直观的用户界面&#xff1a;基于互动时间线…

学习游戏制作记录(角色属性和状态脚本)8.4

1.实现简单的角色属性创建CharactorState脚本&#xff1a;挂载在敌人和玩家身上public float damage;//角色伤害public float maxHp;//最大生命[SerializeField] private float currentHealth;//当前生命void Start(){currentHealth maxHp;//初始化将当前生命设置为最大生命}p…

04-Chapter02-Example01

文章介绍 1、完善项目结构 1.1 新建第二章对应模块Chapter021.2 新建模块Chapter02对应包com.itheima1.3 在包com.itheima下新建class类 &#xff0c;类名称Example01.java项目结构如下&#xff1a;2、编写Example01.java代码 P38 package com.itheima;public class Example01…

【达梦MPP(带主备)集群搭建】

达梦MPP&#xff08;带主备&#xff09;集群搭建 为了提高MPP系统可靠性&#xff0c;克服由于单节点故障导致整个系统不能继续正常工作的问题&#xff0c;DM在普通的MPP系统基础上&#xff0c;引入数据守护主备机制&#xff0c;为每一个MPP节点配置一个实时备库作为备份节点&a…

Java基础学习(一):类名规范、返回值、注释、数据类型

目录 一、类名规范二、返回值三、注释四、数据类型 1. 基本类型2. 引用类型3. 强制数据类型转换4. 进制5. 进制的转换6. 超范围运算 相关文章 Java基础学习&#xff08;二&#xff09;&#xff1a;Java中的变量和常量、final&#xff08;重点&#xff09;、运算、字符串 了…

Nginx相关实验(2)

nginx的一些高级配置 nginx状态页 基于nginx 模块 ngx_http_stub_status_module 实现&#xff0c; 在编译安装nginx的时候需要添加编译参数 --with-http_stub_status_module 否则配置完成之后监测会是提示语法错误 #检查模块是否配置 如果不存在需要添加模块重新编译 nginx …

2.Java和C++有什么区别

2.Java和C有什么区别 1.在C中&#xff0c;支持操作符重载&#xff0c;而在Java里是不允许的 2.C支持多继承&#xff0c;而Java不可以&#xff0c;但Java可以单继承多实现 3.Java内置多线程机制&#xff0c;而C没有 4.Java里面自带了垃圾回收机制&#xff0c;可以自动清理缓存等…

MLIR Introduction

简介 MLIR 项目是一个构建可重用和可扩展编译器基础设施创新项目&#xff0c;旨在解决软件碎片化问题&#xff0c;显著降低构建特定领域编译器的成本。 基于MLIR&#xff0c;可以实现&#xff1a; 数据流图表达&#xff08;如TensorFlow&#xff09;&#xff0c;包含dynamic…

[找出字符串中第一个匹配项的下标]

代码思路分析&#xff1a; 1. 边界情况处理 代码中没有显式处理以下边界情况&#xff0c;但逻辑已隐含支持&#xff1a; needle 为空字符串&#xff1a;应返回 0&#xff08;但题目通常保证 needle 非空&#xff09;。haystack 比 needle 短&#xff1a;直接返回 -1&#xff08…

深入剖析RT-Thread串口驱动:基于STM32H750的FinSH Shell全链路Trace分析与实战解密(上)

0. 概述 这是cherryusb代码trace分析系列文章之七。 RT-Thread串口驱动框架与FinSH Shell运行机制深度解析&#xff1a;针对STM32H750 ART-PI平台&#xff0c;本文独辟蹊径采用创新的代码trace分析方法&#xff0c;破解庞大串口框架下的复杂运行逻辑。通过精确trace日志与drv_u…

Python与C++通信教程:C++打包dll,供Python调用(1)

目录 1,新建一个工程 math_functions.cpp内容: 先编译一下看是否可以正常运行: 2,编译成dll,并用Python调用 有两种方式: 命令 1(使用静态链接): 可移植性: 命令 2(动态链接): 可移植性: 这里我使用的是静态链接的方式: python调用实例 test_dll.py 1,…

编程与数学 03-002 计算机网络 19_网络新技术研究

编程与数学 03-002 计算机网络 19_网络新技术研究一、软件定义网络&#xff08;SDN&#xff09;&#xff08;一&#xff09;SDN的基本原理与架构&#xff08;二&#xff09;SDN的应用场景与优势二、网络功能虚拟化&#xff08;NFV&#xff09;&#xff08;一&#xff09;NFV的概…

uniapp 跨端开发

一、创建uniapp项目 1. 项目架构2. 初始化项目3. pages.json 和 tabBar 案例4. uni-app和原生小程序开发区别5. 用命令行创建uni-app项目 官网链接&#xff1a;https://uniapp.dcloud.net.cn/quickstart-cli.html#创建uni-app6. 用vscode开发uni-app在uni-app中只有manifest.js…

区块链支付技术的核心原理

区块链支付利用分布式账本技术&#xff08;DLT&#xff09;实现点对点的价值转移&#xff0c;无需传统银行或支付网关的中介。核心特点是去中心化、透明、可追溯。• 基本流程&#xff1a;1. 用户发起交易&#xff1a;通过加密货币钱包发送支付请求&#xff08;例如用ETH支付&a…

linux中 多进程 导致cuda错误的问题解决

问题总结与解决方案 核心问题 在使用 Linux 系统时&#xff0c;多进程并行计算中加载模型到 GPU 时出现错误&#xff1a;_MODEL SentenceTransformer( model_path, device "cuda" if torch.cuda.is_available() else "cpu" )根本原因&#xff1a; CUDA 上…

智能感知的新入口:AIGC 与低延迟视频通路的深度融合

✳️ 引言&#xff1a;AIGC&#xff0c;正在重构视觉智能的“生成逻辑” AI生成内容&#xff08;AIGC&#xff09;正在从“内容创作工具”跃升为计算机视觉系统的新引擎。它不再只是“文生图”、“图生文”的演示技术&#xff0c;而是实实在在地改变着我们构建、处理和理解视觉…

Ubuntu 内网多台服务器时间同步方案(适用于临时能上外网的环境)

哎&#xff0c;最近项目是运行在内网环境下的&#xff0c;出现了由于时间不同步导致的bug。一般来讲&#xff0c;几台服务器的时间不一致&#xff0c;会带来很多问题&#xff0c;比如日志时间对不上、分布式服务出现异常&#xff0c;等等。项目上现在有三台服务器&#xff0c;其…