您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
应用场景举例:
一个任务管道满了,再往里面塞就塞不进去了,浏览器刷不出来了。用户即便关了浏览器可能依然在阻塞......
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官方文档的建议:
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。