golang select典型用法
发布时间:2020-12-16 19:16:00 所属栏目:大数据 来源:网络整理
导读:code package mainimport ( "fmt" "time")func chanTest(ch chan int) { for { // select 外层需要循环 select { case value ,ok := -ch: fmt.Println( value ,ok, time .Now()) if ok == false { fmt.Println( "chan已经关闭" , time .Now()) // select 要
codepackage main
import (
"fmt"
"time"
)
func chanTest(ch chan int) {
for { //select外层需要循环 select { case value,ok := <-ch: fmt.Println(value,ok,time.Now()) if ok == false { fmt.Println("chan已经关闭",time.Now()) //select要自己判断退出,如果是for..range 形式,在读取完了关闭的chanel后,退出循环 return } default: fmt.Println("chan 空了",time.Now()) time.Sleep(time.Second * 5) //分支的处理会阻塞整个select } } } func main() { var ch = make(chan int,100) go chanTest(ch) ch <- 1 ch <- 2 time.Sleep(time.Second * 2) ch <- 3 ch <- 4 time.Sleep(time.Second) close(ch) for { time.Sleep(time.Second) } }
需要注意的是,select的 defalut会丢弃数据,chan已满的情况,入chan的数据会被丢弃 引用
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |