分享
GO语言练习:channel select 超时机制
fengbohello · · 7643 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
1、代码
2、运行
3、解析
1、代码
1 package main
2
3 import (
4 "time"
5 "fmt"
6 )
7
8 func waitFor(ch chan int) {
9 fmt.Println(time.Now(), "writing ...")
10 time.Sleep(1e9)
11 ch <- 10
12 fmt.Println(time.Now(), "wrote ...")
13 }
14
15 func main() {
16 var a chan int = make(chan int)
17 var b chan int = make(chan int)
18 var ch chan int = make(chan int)
19
20 go waitFor(ch)
21
22 var r int = 0
23 fmt.Println(time.Now(), "select ...")
24 select {
25 case x := <-a :
26 fmt.Println(time.Now(), "read from a...")
27 r = x
28 case x := <-b :
29 fmt.Println(time.Now(), "read from b...")
30 r = x
31 case x := <-ch :
32 fmt.Println(time.Now(), "read from ch...")
33 r = x
34 }
35 fmt.Println(time.Now(), "select over.., r = ", r)
36 time.Sleep(1e9)
37 fmt.Println(time.Now(), "over..")
38 }
2、运行
1 $ go run timeout.go
2 2015年07月19日 00:35:23.859684465 +0800 CST select ...
3 2015年07月19日 00:35:23.861022451 +0800 CST writing ...
4 2015年07月19日 00:35:24.864462549 +0800 CST wrote ...
5 2015年07月19日 00:35:24.865185396 +0800 CST read from ch...
6 2015年07月19日 00:35:24.874655353 +0800 CST select over.., r = 10
7 2015年07月19日 00:35:25.888486739 +0800 CST over..
3、解析
1)主线程中的select开始运行,对select中的3个channel进行阻塞等待
2)在线程(协程)waitFor中向ch写入数据
3)select收到数据,进行读取
4)主线程退出
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信7643 次点击
上一篇:学习go语言的第一天
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
1、代码
2、运行
3、解析
1、代码
1 package main
2
3 import (
4 "time"
5 "fmt"
6 )
7
8 func waitFor(ch chan int) {
9 fmt.Println(time.Now(), "writing ...")
10 time.Sleep(1e9)
11 ch <- 10
12 fmt.Println(time.Now(), "wrote ...")
13 }
14
15 func main() {
16 var a chan int = make(chan int)
17 var b chan int = make(chan int)
18 var ch chan int = make(chan int)
19
20 go waitFor(ch)
21
22 var r int = 0
23 fmt.Println(time.Now(), "select ...")
24 select {
25 case x := <-a :
26 fmt.Println(time.Now(), "read from a...")
27 r = x
28 case x := <-b :
29 fmt.Println(time.Now(), "read from b...")
30 r = x
31 case x := <-ch :
32 fmt.Println(time.Now(), "read from ch...")
33 r = x
34 }
35 fmt.Println(time.Now(), "select over.., r = ", r)
36 time.Sleep(1e9)
37 fmt.Println(time.Now(), "over..")
38 }
2、运行
1 $ go run timeout.go
2 2015年07月19日 00:35:23.859684465 +0800 CST select ...
3 2015年07月19日 00:35:23.861022451 +0800 CST writing ...
4 2015年07月19日 00:35:24.864462549 +0800 CST wrote ...
5 2015年07月19日 00:35:24.865185396 +0800 CST read from ch...
6 2015年07月19日 00:35:24.874655353 +0800 CST select over.., r = 10
7 2015年07月19日 00:35:25.888486739 +0800 CST over..
3、解析
1)主线程中的select开始运行,对select中的3个channel进行阻塞等待
2)在线程(协程)waitFor中向ch写入数据
3)select收到数据,进行读取
4)主线程退出