go : select 的执行顺序

栏目: IT技术 · 发布时间: 4年前

原文链接

Vincent Blanchon

go : select 的执行顺序

本文基于 go 1.14

select 允许在一个goroutine中管理多个channel。但是,当所有channel同时就绪的时候,go需要在其中选择一个执行。go还需要处理没有channel就绪的情况,我们先从就绪的channel开始。

Order

select 不会按照任何规则或者优先级选择到达的channel。go标准库在每次访问的时候,都会将他们顺序打乱,也就是说不能保证任何顺序。

看一个有三个就绪的channel的例子:

func main() {
    a := make(chan bool, 100)
    b := make(chan bool, 100)
    c := make(chan bool, 100)
    for i := 0; i < 10; i++ {
        a <- true
        b <- true
        c <- true
    }
    for i := 0; i < 10; i++ {
        select {
        case <-a:
            print("< a")

        case <-b:
            print("< b")

        case <-c:
            print("< c")

        default:
            print("< default")
        }
    }
}

这三个channel都有三个完整的buffer(不会阻塞),下面是程序的输出

< b< a< a< b< c< c< c< a< b< b

在 select 的每次迭代中,case 都会被打乱:

go : select 的执行顺序

由于go 不会删除重复的channel,所以可以使用多次添加case来影响结果,代码如下:

func main() {
   a := make(chan bool, 100)
   b := make(chan bool, 100)
   c := make(chan bool, 100)
   for i := 0; i < 10; i++ {
      a <- true
      b <- true
      c <- true
   }
   for i := 0; i < 10; i++ {
      select {
      case <-a:
         print("< a")
      case <-a:
         print("< a")
      case <-a:
         print("< a")
      case <-a:
         print("< a")
      case <-a:
         print("< a")
      case <-a:
         print("< a")
      case <-a:
         print("< a")

      case <-b:
         print("< b")

      case <-c:
         print("< c")

      default:
         print("< default")
      }
   }
}

输出的结果:

< c< a< b< a< b< a< a< c< a< a

当所有channel同时准备就绪时,有80%的机会选择通道a。下面来看一下channel未就绪的情况。

Non-ready channels

select 运行时,如果没有一个case channel就绪,那么他就会运行 default: ,如果 select 中没有写default,那么他就进入等待状态,如下面这个例子

func main() {
   a := make(chan bool, 100)
   b := make(chan bool, 100)
   go func() {
      time.Sleep(time.Minute)
      for i := 0; i < 10; i++ {
         a <- true
         b <- true
      }
   }()

   for i := 0; i < 10; i++ {
      select {
      case <-a:
         print("< a")
      case <-b:
         print("< b")
      }
   }
}

上面那个例子中,将在一分钟后打印结果。 select 阻塞在 channel上。这种情况下,处理 select 的函数将会订阅所有channel并且等待,下面是一个goroutine#7在select中等待的示例,其中另一个goroutine#4也在等待channel:

go : select 的执行顺序

Goroutine(G7)订阅所有频道并在列表末尾等待。 如果channel发送了一条消息,channel将通知已在等待该消息的另一个Goroutine。一旦收到通知, select 将取消订阅所有channel,并且返回到代码运行.

更多关于channel与等待队列的信息,请查看作者另外一篇文章 Go: Buffered and Unbuffered Channels .

上面介绍的逻辑,都是针对于有两个或者以上的活动的channel,实际上如果只有一个活动的channel,go乐意简化select

Simplification

如果只有一个case 加上一个default,例子:

func main() {
   t:= time.NewTicker(time.Second)
   for   {
      select {
      case <-t.C:
         print("1 second ")
      default:
         print("default branch")
      }
   }
}

这种情况下。Go会以非阻塞模式读取channel的操作替换select语句。如果channel在缓冲区中没有任何值,或者发送方准备发送消息,将会运行default。就像下面这张图

go : select 的执行顺序

如果没有default,则 Go 通过阻塞channel操作重写 select 语句。


以上所述就是小编给大家介绍的《go : select 的执行顺序》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

Head Rush Ajax

Head Rush Ajax

Brett McLaughlin、Eric Freeman、Elisabeth Freeman / O'Reilly Media, Inc. / 2006-03-01 / USD 34.99

Ajax, or Asynchronous JavaScript and XML, is a term describing the latest rage in web development. Ajax is used to create interactive web applications with XML-based web services, and using JavaScript......一起来看看 《Head Rush Ajax》 这本书的介绍吧!

在线进制转换器
在线进制转换器

各进制数互转换器

MD5 加密
MD5 加密

MD5 加密工具

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具