掌握Golang中的select语句实现并发编程
更新时间:2023年04月18日 10:02:58 作者:西直门三太子
Golang中的select语句用于在多个通道间选择可读或可写的操作,并阻塞等待其中一个通道进行操作。可以用于实现超时控制、取消和中断操作等。同时,select语句支持default分支,用于在没有任何通道可操作时执行默认操作
序文
select 是用来配合channel使用的
空select
- 没有内容的select 会阻塞
- 没有内容是指,没有case,也没有default
- 如果没有其它的任务指执行,将会触发死锁
package main import ( "fmt" "time" ) /** * 没有内容的select 会阻塞 * 没有内容是指,没有case,也没有default * 如果没有其它的任务指执行,将会触发死锁 */ func main() { go func() { time.Sleep(2 * time.Second) fmt.Println("没有内容的select 会阻塞") }() select {} }
只有default的select
只有default的select 和串行化没有区别
package main import "fmt" /** 只有default的select 和串行化没有区别 */ func main() { go func() { fmt.Println("quick") }() select { default: fmt.Println("end") } }
带 case 的 select
有case,有 default
- 如果能匹配到case 就 执行 case
- 匹配不到case,就执行default
- 有 default,就代表了不会阻塞
package main import ( "fmt" ) func main() { ch1 := make(chan int, 2) ch2 := make(chan int, 2) select { case v1 := <-ch1: fmt.Println(v1) case v2 := <-ch2: fmt.Println(v2) default: fmt.Println(22) } }
package main import ( "fmt" "time" ) func main() { ch1 := make(chan int, 2) ch2 := make(chan int, 2) go func() { ch1 <- 1 }() time.Sleep(1 * time.Second) select { case v1 := <-ch1: fmt.Printf("get v1 chan value %d", v1) case v2 := <-ch2: fmt.Printf("get v1 chan value %d", v2) default: fmt.Println(22) } }
有case,无default
会阻塞 一直等到case匹配上
package main import ( "fmt" "time" ) func main() { ch1 := make(chan int, 2) ch2 := make(chan int, 2) fmt.Printf("start unix:%d \n", time.Now().Unix()) go func() { time.Sleep(3 * time.Second) ch1 <- 1 }() select { case v1 := <-ch1: fmt.Printf("case unix: %d \n", time.Now().Unix()) fmt.Printf("get v1 chan value %d \n", v1) case v2 := <-ch2: fmt.Printf("get v1 chan value %d \n", v2) } fmt.Println("end") }
select 只匹配一次,如果要进行 n > 1 的 匹配,使用 for + select
package main import ( "fmt" "time" ) func main() { ch1 := make(chan int, 2) ch2 := make(chan int, 2) fmt.Printf("start unix:%d \n", time.Now().Unix()) go func() { for { time.Sleep(1 * time.Second) ch1 <- 1 } }() for { select { case v1 := <-ch1: fmt.Printf("case unix: %d \n", time.Now().Unix()) fmt.Printf("get v1 chan value %d \n", v1) case v2 := <-ch2: fmt.Printf("get v1 chan value %d \n", v2) } } }
匹配是无序的
package main import ( "fmt" "time" ) func test() { ch1 := make(chan int) ch2 := make(chan int) go func() { ch1 <- 1 close(ch1) }() go func() { time.Sleep(1 * time.Second) ch2 <- 1 close(ch2) }() time.Sleep(2 * time.Second) // 如果有顺序,那么因该每次都是v1 select { case v1 := <-ch1: fmt.Printf("case unix: %d \n", time.Now().Unix()) fmt.Printf("get v1 chan value %d \n", v1) case v2 := <-ch2: fmt.Printf("case unix: %d \n", time.Now().Unix()) fmt.Printf("get v2 chan value %d \n", v2) } } func main() { for i := 0; i < 10; i++ { test() } }
到此这篇关于掌握Golang中的select语句实现并发编程的文章就介绍到这了,更多相关Golang中的select语句内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
golang 中 channel 的详细使用、使用注意事项及死锁问题解析
这篇文章主要介绍了golang 中 channel 的详细使用、使用注意事项及死锁分析,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-03-03go中Excelize处理excel表实现带数据校验的文件导出
本文主要介绍了go中Excelize处理excel表实现带数据校验的文件导出,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-06-06
最新评论