golang chan详解

bytemode · · 5143 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

## 无缓冲chan 进和出都会阻塞. ## 有缓冲chan 先进先出队列, 出会一直阻塞到有数据, 进时当队列未满不会阻塞, 队列已满则阻塞. ## select 1. select 先遍历所有case, 所有channel表达式都会被求值、所有被发送的表达式都会被求值。求值顺序:自上而下、从左到右. 2. 当case没有阻塞则随机执行一个没有阻塞的case就退出select 3. 当所有case阻塞时, 则一直阻塞直到某个case解除阻塞, 但是如果有default则直接执行default 4. 也就是一个select最多只执行一次case里的代码 5. 要一直检测case则必须外层使用for循环包起来 ## close(chan) 1. close没有make的chan会引起panic 2. close以后不能再写入,写入会出现panic 3. close之后可以读取,无缓冲chan读取返回0值和false,有缓冲chan可以继续读取,返回的都是chan中数据和true,直到读取完所有队列中的数据,返回默认值和false 4. 重复close会引起panic 5. 只读chan不能close 6. 不close chan也是可以的,当没有被引用时系统会自动垃圾回收。 ## 只读和只写chan read_only := make (<-chan int) write_only := make (chan<- int) 只读或者只写一般用在参数传递中。 ## chan和mutex mutex的性能比chan高不少。 比如开源的消息队列gnatsd(NATS)就很少用chan而使用mutex,其性能是非常高的,比另一个消息队列nsq高很多。 ## 读写Chan 永远是符号<-进行读取或者写入,譬如v,ok := <-c是读取,而c <- v是写入。 ```go c := make(chan int, 1) c <- 10 // 写入chan v := <- c // 从chan中读取 ``` 下面的例子判断chan是否关闭: ```go c := make(chan int, 1) c <- 10 v,ok := <- c // 读取,v=10,ok=true close(c) v,ok := <- c // 读取,v=0,ok=false ``` 如果写不进去就丢弃,可以用select: ```go c := make(chan int, 1) select { case c <- 10: // c中放入了10,因为chan的buffer为1 default: } select { case c <- 11: default: // c中只有10,没有11 } select { case v,ok := <- c: // 读出来一个,v=10, ok=true default: } select { case v,ok := <- c: default: // 没有可读的,走这个分支 } ``` 超时控制 ```go select { case <-timeout: fmt.Println("定时任务") case dd := <-time.After(time.Second * 3): fmt.Println(dd, "任务超时") } ``` ## 判断closed 读取时,如果没有ok,也是可以读取的。不过如果closed也是能读的,没有赋值而已;如果要知道是否closed得加ok,也就是除非chan永远不关闭,否则读取应该用v,ok := <-c而不是用v := <-c的方式。 ```go c := make(chan int, 1) c <- 10 close(c) v := <- c // c=10,读取出来一个 v = <- c // c=0,实际上没有读出来,但是判断不了 c := make(chan int, 1) c <- 10 close(c) v,ok := <- c // c=10,ok=true,读取出来一个 v,ok = <- c // c=0,ok=false,实际上没有读出来 ``` ## For-Range for-range语法可以用到通道上。循环会一直接收channel里面的数据,**直到channel关闭**。不同于array/slice/map上的for-range,channel的for-range只允许有一个变量。 ```go for v:=range aChannel { // use v } ``` 等价于 ```go for { v, ok := <- aChannel if !ok { break } // use v } ``` 注意,for-range对应的channel不能是只写channel。

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

5143 次点击  ∙  2 赞  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传