百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

Go中select用法(go for select)

wptr33 2025-03-25 18:09 25 浏览

什么是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 函数休眠6秒,然后将文本"from server1"写入通道ch。server2 函数休眠3秒钟,然后"from server2"写入通道ch。main 函数调用 go Goroutines server1 和 server2。

程序运行到达 select 语句,select 语句将阻塞,直到其中一个case准备就绪。在上面的程序中,server1 Goroutine在6秒后写入output1 channel,而server2在3秒后写入output2 channel。因此,select 语句将阻塞3秒,并等待 server2 Goroutine 写入output2 channle。3秒后,程序打印:

from server2 

之后程序中断。

select的实际用法

将上述程序中的函数命名为 server1 和 server2 的原因是为了说明 select 的实际用法。

假设我们有一个任务关键型应用程序,我们需要尽快将输出返回给用户。此应用程序的数据库被复制并存储在世界各地的不同服务器中。假设函数server1和server2实际上正在与2个这样的服务器通信,每个服务器的响应时间取决于每个服务器上的负载和网络延迟,我们将请求发送到两个服务器,然后使用 select 语句在相应的channel上等待响应。首先响应的服务器由select语句选择,另外的响应被忽略。这样,我们可以将相同的请求发送到多个服务器,并将最快的响应返回给用户。

select语句中的default case

当其他事例均未准备就绪时,将执行 select 语句中的default case。这通常用于防止 select 语句阻塞。

package main

import (  
    "fmt"
    "time"
)

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

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

在上面的程序中,process函数休眠10500毫秒(10.5 秒),然后将"process successful"写入 ch 通道。此函数在程序的main函数中被调用。同时调用Goroutine 后,在主 Goroutine 中启动一个无限的 for 循环。无限循环在每次迭代开始时休眠1000毫秒(1秒),然后执行select语句,在前10500毫秒内,select 语句的第一种情况,即 case v := <-ch,将不会准备就绪,因为进程 Goroutine 只会在10500毫秒后写入 ch 通道。因此,default case将在此期间执行,程序将打印10次"no value received"。在10.5 秒后,Goroutine 将"process successful"写入ch,将执行select语句的第一个情况,程序将打印"received value: process successful",然后它将终止。该程序将输出,

no value received  
no value received  
no value received  
no value received  
no value received  
no value received  
no value received  
no value received  
no value received  
no value received  
received value:  process successful  

死锁和default case

package main

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

在上面的程序中,创建了一个ch channel,尝试从select中的ch channel读取。select 语句将永远阻塞,因为没有其他 Goroutine 写入此通道,因此将导致死锁。该程序将在运行时死机并显示以下消息:

fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:  
main.main()  
    /tmp/sandbox627739431/prog.go:6 +0x4d

如果存在default case,则不会发生此死锁,因为default case将在没有其他case准备就绪时执行。上面的程序被重写如下:

package main

import "fmt"

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

上面的程序将打印:

default case executed  

同样地,如果select语句仅仅有nil channel,default case也会执行。

package main

import "fmt"

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

    }
}

上面的程序中,ch channel是nil,但是select语句中尝试从ch channel中读取值,如果select中没有default case,程序将一直阻塞并且导致死锁。因此当有nil channel时,在select语句中加上default case,此程序将输出如下:

default case executed 

随机选择

当在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)
    }
}

上面的程序中,server1和server2 goroutines分别被调用,当主程序sleep 1秒后,output1和output2将分别写入字符,因此select语句中的两个case都准备就绪,这时将随机选择一个case执行。你可以本地执行验证它的随机性。

陷阱--空select

package main

func main() {  
    select {}
}

你认为上面的程序将输出什么?

我们都知道select语句会一直阻塞直到它的case执行。在这个例子中,select语句中没有任何case,因为它会一直阻塞,直至产生死锁。这个程序将会panic并由如下的输出:

fatal error: all goroutines are asleep - deadlock!

goroutine 1 [select (no cases)]:  
main.main()  
    /tmp/sandbox246983342/prog.go:4 +0x25

相关推荐

MySQL进阶五之自动读写分离mysql-proxy

自动读写分离目前,大量现网用户的业务场景中存在读多写少、业务负载无法预测等情况,在有大量读请求的应用场景下,单个实例可能无法承受读取压力,甚至会对业务产生影响。为了实现读取能力的弹性扩展,分担数据库压...

Postgres vs MySQL_vs2022连接mysql数据库

...

3分钟短文 | Laravel SQL筛选两个日期之间的记录,怎么写?

引言今天说一个细分的需求,在模型中,或者使用laravel提供的EloquentORM功能,构造查询语句时,返回位于两个指定的日期之间的条目。应该怎么写?本文通过几个例子,为大家梳理一下。学习时...

一文由浅入深带你完全掌握MySQL的锁机制原理与应用

本文将跟大家聊聊InnoDB的锁。本文比较长,包括一条SQL是如何加锁的,一些加锁规则、如何分析和解决死锁问题等内容,建议耐心读完,肯定对大家有帮助的。为什么需要加锁呢?...

验证Mysql中联合索引的最左匹配原则

后端面试中一定是必问mysql的,在以往的面试中好几个面试官都反馈我Mysql基础不行,今天来着重复习一下自己的弱点知识。在Mysql调优中索引优化又是非常重要的方法,不管公司的大小只要后端项目中用到...

MySQL索引解析(联合索引/最左前缀/覆盖索引/索引下推)

目录1.索引基础...

你会看 MySQL 的执行计划(EXPLAIN)吗?

SQL执行太慢怎么办?我们通常会使用EXPLAIN命令来查看SQL的执行计划,然后根据执行计划找出问题所在并进行优化。用法简介...

MySQL 从入门到精通(四)之索引结构

索引概述索引(index),是帮助MySQL高效获取数据的数据结构(有序),在数据之外,数据库系统还维护者满足特定查询算法的数据结构,这些数据结构以某种方式引用(指向)数据,这样就可以在这些数据结构...

mysql总结——面试中最常问到的知识点

mysql作为开源数据库中的榜一大哥,一直是面试官们考察的重中之重。今天,我们来总结一下mysql的知识点,供大家复习参照,看完这些知识点,再加上一些边角细节,基本上能够应付大多mysql相关面试了(...

mysql总结——面试中最常问到的知识点(2)

首先我们回顾一下上篇内容,主要复习了索引,事务,锁,以及SQL优化的工具。本篇文章接着写后面的内容。性能优化索引优化,SQL中索引的相关优化主要有以下几个方面:最好是全匹配。如果是联合索引的话,遵循最...

MySQL基础全知全解!超详细无废话!轻松上手~

本期内容提醒:全篇2300+字,篇幅较长,可搭配饭菜一同“食”用,全篇无废话(除了这句),干货满满,可收藏供后期反复观看。注:MySQL中语法不区分大小写,本篇中...

深入剖析 MySQL 中的锁机制原理_mysql 锁详解

在互联网软件开发领域,MySQL作为一款广泛应用的关系型数据库管理系统,其锁机制在保障数据一致性和实现并发控制方面扮演着举足轻重的角色。对于互联网软件开发人员而言,深入理解MySQL的锁机制原理...

Java 与 MySQL 性能优化:MySQL分区表设计与性能优化全解析

引言在数据库管理领域,随着数据量的不断增长,如何高效地管理和操作数据成为了一个关键问题。MySQL分区表作为一种有效的数据管理技术,能够将大型表划分为多个更小、更易管理的分区,从而提升数据库的性能和可...

MySQL基础篇:DQL数据查询操作_mysql 查

一、基础查询DQL基础查询语法SELECT字段列表FROM表名列表WHERE条件列表GROUPBY分组字段列表HAVING分组后条件列表ORDERBY排序字段列表LIMIT...

MySql:索引的基本使用_mysql索引的使用和原理

一、索引基础概念1.什么是索引?索引是数据库表的特殊数据结构(通常是B+树),用于...