码迷,mamicode.com
首页 > 其他好文 > 详细

select实现斐波那契和超时机制

时间:2018-09-11 23:49:34      阅读:183      评论:0      收藏:0      [点我收藏+]

标签: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
超时
程序结束
 */

  

select实现斐波那契和超时机制

标签:package   return   实现   语句   time   pack   UNC   ++   随机   

原文地址:https://www.cnblogs.com/traditional/p/9630937.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!