select 信道好帮手

  • select 概念
  • select 应用场景
  • 死锁
  • select 重要特性

select 概念

select 语句用于在多个发送/接收信道操作中进行选择。select 语句会一直阻塞,直到发送/接收操作准备就绪。如果有多个信道操作准备完毕,select 会随机地选取其中之一执行。该语法与 switch 类似,所不同的是,这里的每个 case 语句都是信道操作

package main

import (  
    "fmt"
    "time"
)

func server1(ch chan string) {  
    time.Sleep(6 * time.Second)
    ch <- "from server1"
}
func server2(ch chan string) {  
    time.Sleep(3 * time.Second)
    ch <- "from server2"

}
func main() {  
    output1 := make(chan string)
    output2 := make(chan string)
    go server1(output1)
    go server2(output2)
    select {
    case s1 := <-output1:
        fmt.Println(s1)
    case s2 := <-output2:
        fmt.Println(s2)
    }
}

在上面程序里,server1 函数(第 8 行)休眠了 6 秒,接着将文本 from server1 写入信道 ch。而 server2 函数(第 12 行)休眠了 3 秒,然后把 from server2 写入了信道 ch。

而 main 函数在第 20 行和第 21 行,分别调用了 server1 和 server2 两个 Go 协程。

在第 22 行,程序运行到了 select 语句。select 会一直发生阻塞,除非其中有 case 准备就绪。在上述程序里,server1 协程会在 6 秒之后写入 output1 信道,而server2 协程在 3 秒之后就写入了 output2 信道。因此 select 语句会阻塞 3 秒钟,等着 server2 向 output2 信道写入数据。3 秒钟过后,程序会输出:

如果是下面的代码呢?

package main

import (
    "fmt"
    "time"
)

func server1(ch chan string) {
    time.Sleep(6 * time.Second)
    ch <- "from server1"
}
func server2(ch chan string) {
    time.Sleep(3 * time.Second)
    ch <- "from server2"

}
func main() {
    output1 := make(chan string)
    output2 := make(chan string)
    go server1(output1)
    go server2(output2)
    select {
    case s1 := <-output1:
        fmt.Println(s1)
    case s2 := <-output2:
        fmt.Println(s2)
    default:fmt.Println("不好意思,我先结束了")
    }
}

image.png


select 应用场景

假设我们有一个关键性应用,需要尽快地把输出返回给用户。这个应用的数据库复制并且存储在世界各地的服务器上。假设函数 server1 和 server2 与这样不同区域的两台服务器进行通信。每台服务器的负载和网络时延决定了它的响应时间。我们向两台服务器发送请求,并使用 select 语句等待相应的信道发出响应。select 会选择首先响应的服务器,而忽略其它的响应。使用这种方法,我们可以向多个服务器发送请求,并给用户返回最快的响应了。:)

package main

import (
    "fmt"
    "time"
)

func process(ch chan string) {
    time.Sleep(6 * time.Second)
    ch <- "process successful"
}

func main() {
    ch := make(chan string)
    go process(ch)
    for {
        time.Sleep(5 * time.Second)
        select {
        case v := <-ch:
            fmt.Println("received value: ", v)
            return
        default:
            fmt.Println("no value received")
        }
    }
}

for 是一个无限循环的操作,当5秒达到后,没有收到信道的数据,会执行默认分支,在第6秒的时候信道中有数据了,这个时候,不会立马执行分支,知道第二轮循环的时候,分支从信道中取到了数据所以执行了`fmt.Println("received value: ", v)

产生死锁

package main

func main() {  
    ch := make(chan string)
    select {
    case <-ch:
    }
}

因为没有线程给chan 写数据,所以代码会一致卡在select 这里,它已经卡死了,系统会差生panic

select的重要特性

1.如果select 有默认分支就不会死锁

package main

import "fmt"

func main() {  
    ch := make(chan string)
    select {
    case <-ch:
    default:
        fmt.Println("default case executed")
    }
}

2.若果信道的默认值为nil 也会死锁

package main

import "fmt"

func main() {  
    var ch chan string
    select {
    case v := <-ch:
        fmt.Println("received value", v)
    }
}

3.当 select 由多个 case 准备就绪时,将会随机地选取其中之一去执行。

package main

import (  
    "fmt"
    "time"
)

func server1(ch chan string) {  
    ch <- "from server1"
}
func server2(ch chan string) {  
    ch <- "from server2"

}
func main() {  
    output1 := make(chan string)
    output2 := make(chan string)
    go server1(output1)
    go server2(output2)
    time.Sleep(1 * time.Second)
    select {
    case s1 := <-output1:
        fmt.Println(s1)
    case s2 := <-output2:
        fmt.Println(s2)
    }
}

4.空 select 会一致阻塞,引发panic

package main

func main() {
   select {}
}

image.png

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • chan 信道

    信道是实现 Go 协程间的通信的桥梁,信道可以想像成 Go 协程之间通信的管道。如同管道中的水会从一端流到另一端,通过使用信道,数据也可以从一端发送,在另一端接...

    酷走天涯
  • go-runtime/debug

    FreeOSMemory强制进行一次垃圾收集,以释放尽量多的内存回操作系统。(即使没有调用,运行时环境也会在后台任务里逐渐将内存释放给系统)

    酷走天涯
  • 反射

    在学习反射时,所有人首先面临的疑惑就是:如果程序中每个变量都是我们自己定义的,那么在编译时就可以知道变量类型了,为什么我们还需要在运行时检查变量,求出它的类型呢

    酷走天涯
  • .NET Core 3.0 本地工具

    .NET Core从最早期的版本就开始支持全局工具了。如果仅仅需要在某个项目中或某个文件夹中使用特定的工具,那么.NET Core 3.0就允许您这样做。

    solenovex
  • 如何结合 Core Data 和 SwiftUI

    SwiftUI 和 Core Data 之间相差将近十年——SwiftUI 随着 iOS 13面世而 Core Data 则是iPhoneOS 3的产物;很久以...

    韦弦zhy
  • JFinal框架使用

    表单直接提交页面,不用ajax 后台; /** * 修改 */ public void edit() { Strin...

    二十三年蝉
  • System.currentTimeMillis() 竟然存在性能问题?

    在之前的文章中就提到了,System.currentTimeMillis()并非最佳实践。但是令人没想到的是,除了精度问题,竟还存在性能问题。

    良月柒
  • .NET Core 3和对Windows桌面应用程序的支持

    在今天的微软Build Live大会上,微软.Net Core团队公开了.net Core3的开发计划的预览。.Net Core 3 的亮点是支持Windows...

    程序你好
  • 不敢相信?System.currentTimeMillis()存在性能问题

    System.currentTimeMillis()是极其常用的基础Java API,广泛地用来获取时间戳或测量代码执行时长等,在我们的印象中应该快如闪电。但...

    用户5224393
  • HBase 异步查询导致的死锁和zookeeper通信中断问题追踪与总结[非技术]

    机房T和机房Y共十台前端机,Y机房请求量是T的两倍,主要用于数据查询,开始问题是Y机房tomcat 相继僵死 1) tomcat僵死处理步骤 a 检查代码,发现...

    财主刀刀

扫码关注云+社区

领取腾讯云代金券