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

go的select多路复用

传统的方法在遍历管道时,如果不关闭会阻塞而导致 deadlock ,在实际开发中,可能我们不好确定什么关闭该管道。使用select来获取channel里面的数据的时候不需要关闭channel
你也许会写出如下代码使用遍历的方式来实现:
for {
// 尝试从 ch1 接收值
data, ok := <-ch1
// 尝试从 ch2 接收值
data, ok := <-ch2
}
这种方式虽然可以实现从多个管道接收值的需求,但是运行性能会差很多。为了应对这种场
景, Go 内置了 select 关键字,可以同时响应多个管道的操作。
select 的使用类似于 switch 语句,它有一系列 case 分支和一个默认的分支。每个 case 会对
应一个管道的通信(接收或发送)过程。 select 会一直等待,直到某个 case 的通信操作完成
时,

 就会执行 case 分支对应的语句

package mainimport ("fmt""time"
)func main() {// 在某些场景下我们需要同时从多个通道接收数据,这个时候就可以用到golang中给我们提供的select多路复用//1.定义一个管道 10个数据intintChan := make(chan int, 10)for i := 0; i < 10; i++ {intChan <- i}//2.定义一个管道 5个数据stringstringChan := make(chan string, 5)for i := 0; i < 5; i++ {stringChan <- "hello" + fmt.Sprintf("%d", i)}//使用select来获取channel里面的数据的时候不需要关闭channelfor {select {case v := <-intChan:fmt.Printf("从 intChan 读取的数据%d\n", v)time.Sleep(time.Millisecond * 50)case v := <-stringChan:fmt.Printf("从 stringChan 读取的数据%v\n", v)time.Sleep(time.Millisecond * 50)default:fmt.Printf("数据获取完毕")return //注意退出...}}}

http://www.xdnf.cn/news/9911.html

相关文章:

  • ES分词搜索
  • #13 学习反馈
  • 【AI-安装指南】Redis Stack 的安装与使用
  • 二分法算法技巧-思维提升
  • 接口自动化测试用例的编写方法
  • pandas数据分析
  • 简述synchronized和java.util.concurrent.locks.Lock的异同 ?
  • Idea使用springAI搭建MCP项目
  • torch.zeros()用法简介
  • c# 获取电脑 分辨率 及 DPI 设置
  • Root权限:解锁Android的终极力量
  • WSL里执行python深度学习的一些方法记录
  • 如何优化Hive的查询性能?请详细说明查询优化的各个层面(SQL优化、配置优化、资源优化等)和具体方法。
  • onlyoffice docspace 协作空间企业版使用秘籍-1.如何连接外部存储
  • 数据结构之队列:原理与应用
  • 下载即转化的商业密码:解析华为应用商店CPD广告的智能投放逻辑
  • 近期知识库开发过程中遇到的一些问题
  • Spring MVC 框架
  • BERT***
  • Linux多线程(六)之线程控制4【线程ID及进程地址空间布局】
  • 记录一次apisix上cros配置跨域失败的问题
  • 如何使用windows下的vscode连接到本地虚拟机的linux
  • 浏览器指纹科普 | Canvas 指纹是什么?
  • 4.2.2 Spark SQL 默认数据源
  • React从基础入门到高级实战:React 高级主题 - React Concurrent 特性:深入探索与实践指南
  • Sublime Text 4格式化JSON无效的解决方法
  • 换宽带ip地址会变吗?同一个宽带如何切换ip地址
  • 7.3 Organizing data into training batches
  • 易路 iBuilder:解构企业 AI 落地困境,重构智能体时代生产力范式
  • 顶刊SCS | 基于视觉语言大模型推理分割的建筑足迹尺度功能分类, 样本数据和代码已开源!