Go select使用与底层原理讲解

作者:树獭叔叔??????? 时间:2024-04-28 09:14:11 

1. select的使用

select 是 Go 提供的 IO 多路复用机制,可以用多个 case 同时监听多个 channl 的读写状态:

  • case: 可以监听 channl 的读写信号

  • default:声明默认操作,有该字段的 select 不会阻塞

select {
case chan <-:
   // TODO
case <- chan:
   // TODO
default:
   // TODO
}

2. 底层原理

  • 每一个 case 对应的 channl 都会被封装到一个结构体中;

  • 当第一次执行到 select 时,会锁住所有的 channl 并且,打乱 case 结构体的顺序;

  • 按照打乱的顺序遍历,如果有就绪的信号,就直接走对应 case 的代码段,之后跳出 select;

  • 如果没有就绪的代码段,但是有 default 字段,那就走 default 的代码段,之后跳出 select;

  • 如果没有 default,那就将当前 goroutine 加入所有 channl 的对应等待队列;

  • 当某一个等待队列就绪时,再次锁住所有的 channl,遍历一遍,将所有等待队列中的 goroutine 取出,之后执行就绪的代码段,跳出select。

3. 数据结构

每一个 case 对应的数据结构如下:

type scase struct {
   c           *hchan         // chan
   elem        unsafe.Pointer // 读或者写的缓冲区地址
   kind        uint16   //case语句的类型,是default、传值写数据(channel <-) 还是  取值读数据(<- channel)
   pc          uintptr // race pc (for race detector / msan)
   releasetime int64
}

4. 几种常见 case

学习了 select 的使用与原理,我们就能更轻松地分辨不同情况下的输出情况了。

case 1

package main

import (
 "fmt"
 "time"
)

func main() {
 chan1 := make(chan int)
 chan2 := make(chan int)
 go func() {
   chan1 <- 1
   time.Sleep(5 * time.Second)
 }()
 go func() {
   chan2 <- 1
   time.Sleep(5 * time.Second)
 }()
 select {
   case <- chan1:
     fmt.Println("chan1")
   case <- chan2:
     fmt.Println("chan2")
   default:
     fmt.Println("default")
 }
}

三种输出都有可能。

case2

package main

import (
 "fmt"
 "time"
)
func main() {
 chan1 := make(chan int)
 chan2 := make(chan int)

select {
   case <- chan1:
     fmt.Println("chan1")
   case <- chan2:
     fmt.Println("chan2")
 }
 fmt.Println("main exit.")
}

上述程序会一直阻塞。

case3

package main

import (
 "fmt"
)

func main() {
 chan1 := make(chan int)
 chan2 := make(chan int)

go func() {
   close(chan1)
 }()
 go func() {
   close(chan2)
 }()
 select {
   case <- chan1:
     fmt.Println("chan1")
   case <- chan2:
     fmt.Println("chan2")
 }
 fmt.Println("main exit.")
}

随机执行1或者2.

case4

package main

func main() {
 select {
 }
}

对于空的 select 语句,程序会被阻塞,确切的说是当前协程被阻塞,同时 Go 自带死锁检测机制,当发现当前协程再也没有机会被唤醒时,则会发生 panic。所以上述程序会 panic。

来源:https://juejin.cn/post/7123037385419407374

标签:Go,select,使用,底层,原理
0
投稿

猜你喜欢

  • python实现两个dict合并与计算操作示例

    2021-07-29 15:37:25
  • Python+Qt身体特征识别人数统计源码窗体程序(使用步骤)

    2021-06-03 10:40:54
  • 大数据量高并发的数据库优化详解

    2024-01-18 14:21:50
  • TensorFlow实现随机训练和批量训练的方法

    2022-06-07 07:45:29
  • 如何在django里上传csv文件并进行入库处理的方法

    2022-02-07 00:19:31
  • 详解javascript遍历方式

    2023-10-14 16:44:48
  • 一文带你熟悉Go语言中的分支结构

    2024-03-07 19:52:49
  • sql 多条件组合查询,并根据指定类别找出所有最小子类别的SQL语句备忘

    2024-01-20 09:01:50
  • nlp自然语言处理学习CBOW模型类实现示例解析

    2023-08-08 00:26:03
  • pytest内置fixture使用临时目录流程详解

    2021-12-27 06:49:23
  • python爬虫之异常捕获及标签过滤详解

    2021-08-10 07:32:06
  • Razor常用语法介绍及示例

    2024-05-13 09:16:20
  • mysql添加索引方法详解(Navicat可视化加索引与sql语句加索引)

    2024-01-24 22:32:37
  • 基于Python自制一个文件解压缩小工具

    2021-10-15 14:28:00
  • JavaScript ES6 Class类实现原理详解

    2024-02-24 07:54:49
  • python实现简单名片管理系统

    2023-06-13 08:03:12
  • Python实现字符串逆序输出功能示例

    2023-10-14 04:59:17
  • 全透视:CSS Z-index 属性

    2009-09-21 12:52:00
  • js调用flash代码

    2010-01-23 12:35:00
  • Python类绑定方法及非绑定方法实例解析

    2022-08-10 11:36:38
  • asp之家 网络编程 m.aspxhome.com