select语句介绍

select 是 Go 中的一个控制结构。select 语句类似于 switch 语句，但是select会随机执行一个可运行的case。如果没有case可运行，它将阻塞，直到有case可运行。但是 select 语句中所有 case 中的表达式都必须是 channel 的发送或接收操作。

select 语句的语法结构和switch语句很相似，也有case语句和default语句：

select {    case communication clause  :       statement(s);          case communication clause  :       statement(s);     /* 你可以定义任意数量的 case */    default : /* 可选 */       statement(s);}

说明：

  • 每个case都必须是一个通信

  • 所有channel表达式都会被求值

  • 所有被发送的表达式都会被求值

  • 如果有多个case都可以运行，select会随机公平地选出一个执行。其他不会执行。

  • 否则：

    如果有default子句，则执行该语句。

    如果没有default字句，select将阻塞，直到某个通信可以运行；Go不会重新对channel或值进行求值。

除了上面展示的典型示例外，接下来我们逐一介绍一些select的特殊示例。

空select

内部不包含任何case语句的，即为空的select，例如：

select{}

空的 select 语句会直接阻塞当前的 goroutine，使得该goroutine进入无法被唤醒的永久休眠状态。

只有一个case

如果select中只包含一个case，那么该select就变成了一个阻塞的channel读/写操作。

select {case   fmt.Println("liwenzhou.com")}

上面的代码，当ch1可读时会执行打印操作，否则就会阻塞。

有default语句

当其他case都没有满足时，select中还可以包含default语句，用于执行一些默认操作，可以避免阻塞。

select {case   fmt.Println("liwenzhou.com")default:  time.Sleep(time.Second)}

上面的代码，当ch1可读时会执行打印操作，否则就执行 default 语句中的代码，这里就相当于做了一个非阻塞的 channel 读取操作。

如何在select中实现优先级

已知，当select 存在多个 case时会随机选择一个满足条件的case执行。

现在我们有一个需求：我们有一个函数会持续不间断地从ch1和ch2中分别接收任务1和任务2，

如何确保当ch1和ch2同时达到就绪状态时，优先执行任务1，在没有任务1的时候再去执行任务2呢？

高级Go语言程序员小明挠了挠头写出了如下函数：

func worker(ch1, ch2 chan int, stopCh chan struct{}) {  for {    select {    case       return    case job1 :=       fmt.Println(job1)    default:      select {      case job2 :=         fmt.Println(job2)      default:      }    }  }}

上面的代码通过嵌套两个select实现了”优先级”，看起来是满足题目要求的。但是这代码有点问题，如果ch1和ch2都没有达到就绪状态的话，整个程序不会阻塞而是进入了死循环。

怎么办呢？

小明又挠了挠头，又写下了另一个解决方案：

func worker2(ch1, ch2 chan int, stopCh chan struct{}) {  for {    select {    case       return    case job1 :=       fmt.Println(job1)    case job2 :=     priority:      for {        select {        case job1 :=           fmt.Println(job1)        default:          break priority        }      }      fmt.Println(job2)    }  }}

这一次，小明不仅使用了嵌套的select，还组合使用了for循环和LABEL来实现题目的要求。

上面的代码在外层select选中执行 job2 :=

实际应用场景

上面的需求虽然是我编的，但是关于在 select 中实现优先级在实际生产中是有实际应用场景的，例如 k8s 的 controller 中就有关于上面这个技巧的实际使用示例，这里在关于 select 中实现优先级相关代码的关键处都已添加了注释，具体逻辑这里就不展开细说了。

// kubernetes/pkg/controller/nodelifecycle/scheduler/taint_manager.go func (tc *NoExecuteTaintManager) worker(worker int, done func(), stopCh chan struct{}) {  defer done()  // 当处理具体事件的时候，我们会希望 Node 的更新操作优先于 Pod 的更新  // 因为 NodeUpdates 与 NoExecuteTaintManager无关应该尽快处理  // -- 我们不希望用户(或系统)等到PodUpdate队列被耗尽后，才开始从受污染的Node中清除pod。  for {    select {    case       return    case nodeUpdate :=       tc.handleNodeUpdate(nodeUpdate)      tc.nodeUpdateQueue.Done(nodeUpdate)    case podUpdate :=       // 如果我们发现了一个 Pod 需要更新，我么你需要先清空 Node 队列.    priority:      for {        select {        case nodeUpdate :=           tc.handleNodeUpdate(nodeUpdate)          tc.nodeUpdateQueue.Done(nodeUpdate)        default:          break priority        }      }      // 在 Node 队列清空后我们再处理 podUpdate.      tc.handlePodUpdate(podUpdate)      tc.podUpdateQueue.Done(podUpdate)    }  }}

总结

本文回顾了Go语言中select语句的一些用法，并延伸出了一个如何在select中实现优先级的小技巧，希望能对大家有所帮助。

最后，Go语言由于自身没有很多奇怪的语法糖和自带代码格式化，相比其他语言来说并不会存在看不懂别人写的代码的情况。所以我们完全可以通过阅读优秀库的源代码，站在巨人的肩膀上，看的更远。

完整示例代码归档地址：

https://github.com/Scoefield/gokeyboardman/tree/main/goselect

以上是关于Go语言select语句优先级实现的介绍，感谢您的阅读，如有疑问或意见请及时反馈给我们。

上一篇文章：

Golang操作数据库Redis