标签:package return 实现 语句 time pack UNC ++ 随机
package main
import "fmt"
func fib(ch chan <-int, quit <- chan bool){
x, y := 1, 1
for {
//监听channel的流动
select {
case ch <- x:
x, y = y, x+y
case flag := <-quit:
fmt.Println("flag=", flag)
return
}
}
}
func main(){
ch := make(chan int)
quit:=make(chan bool)
go func() {
for i:=0;i<8;i++{
num:=<-ch
fmt.Println(num)
/*
1
1
2
3
5
8
13
21
flag= true
*/
}
quit <- true
}()
fib(ch, quit)
}
/*
分析一下代码的逻辑
首先,对于select,是用来监听管道的流动,多个case,那么能执行,就执行哪个,如果都能执行会随机选择一个
对于case ch<-x,会先往ch里面写进去一个1。然后在子协程中num会接收到。此时x, y = y, x+y,然后继续往ch里面放入数据,然后num接收
当子协程里的for循环执行完毕,那么对于case ch<-x,即便往ch里面放入数据,也没办法取了,因为循环结束了,无法执行num:= <- ch了
所以对于第一个case就卡在那里了,会一直等待着有人把ch里面的数据取走.
然后设置quit<-true,一开始第二个case flag:= <- quit里面是没有数据的,当我们设置值之后有数据了,那么便可以取了,会取到flag=true
然后执行第二个case里面的语句,return结束函数,从而结束程序。
需要注意的是:如果想跳出函数,在select里面不要使用break,因为break也对select起作用,使用break跳出select,但并没有跳出for循环,然后会又来执行select
*/
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan int)
quit := make(chan bool)
go func() {
for {
select {
case num:=<-ch:
fmt.Println(num)
case <-time.After(time.Second * 3):
fmt.Println("超时")
quit <- true
}
}
}()
for i:=0;i<5;i++{
ch <- i
}
<-quit//主协程会卡在这里,直到超时
fmt.Println("程序结束")
}
/*
0
1
2
3
4
超时
程序结束
*/
标签:package return 实现 语句 time pack UNC ++ 随机
原文地址:https://www.cnblogs.com/traditional/p/9630937.html