select、定时器
应用场景举例:
一个任务管道满了,再往里面塞就塞不进去了,浏览器刷不出来了。用户即便关了浏览器可能依然在阻塞......
成都创新互联公司坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站设计、做网站、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的吕梁网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
package main import "fmt" import "time" func main() { var ch chan int ch = make(chan int, 10) ch3 := make(chan int, 10) go func() { var i int for { ch <- i time.Sleep(time.Second) ch3 <- i * i time.Sleep(time.Second) i++ } }() for { select { //这个case如果不能从ch中获取数据,则会立即走下一个 case v := <-ch: fmt.Println(v) //这个case如果不能从ch3中获取数据,则会立即走下一个 case v := <-ch3: fmt.Println(v) //然而这样写可能有内存泄漏! case <-time.After(time.Second): fmt.Println("get data timeout") time.Sleep(time.Second) default: fmt.Println("===================") time.Sleep(time.Second) } } }
上面的写法可能会有内存泄漏!
package main import ( "fmt" "runtime" "time" ) func main() { num := runtime.NumCPU() runtime.GOMAXPROCS(num - 1) for i := 0; i < 16; i++ { go func() { for { //每秒执行一次 t := time.NewTicker(time.Second) select { case <-t.C: fmt.Println("timeout") } //一定要关闭 t.Stop() } }() } time.Sleep(time.Second * 100) }
go官方文档的建议:
文章标题:select、定时器
文章分享:http://azwzsj.com/article/gsjohi.html