大蟒蛇python教程共享Go select使用与底层原理讲解

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。

到此这篇关于go select使用与底层原理讲解的文章就介绍到这了,更多相关go select使用 内容请搜索<计算机技术网(www.ctvol.com)!!>以前的文章或继续浏览下面的相关文章希望大家以后多多支持<计算机技术网(www.ctvol.com)!!>!

需要了解更多python教程分享Go select使用与底层原理讲解,都可以关注python教程分享栏目—计算机技术网(www.ctvol.com)!

本文来自网络收集,不代表计算机技术网立场,如涉及侵权请联系管理员删除。

ctvol管理联系方式QQ:251552304

本文章地址:https://www.ctvol.com/pythontutorial/1187691.html

(0)
上一篇 2022年8月4日
下一篇 2022年8月4日

精彩推荐