七叶笔记 » golang编程 » golang chan简介

golang chan简介

分类: golang编程 | 浏览: 328

无缓冲chan

进和出都会阻塞.

有缓冲chan

先进先出队列, 出会一直阻塞到有数据, 进时当队列未满不会阻塞, 队列已满则阻塞.

select

  1. select 先遍历所有case, 所有channel表达式都会被求值、所有被发送的表达式都会被求值。求值顺序：自上而下、从左到右.
  2. 当case没有阻塞则随机执行一个没有阻塞的case就退出select
  3. 当所有case阻塞时, 则一直阻塞直到某个case解除阻塞, 但是如果有default则直接执行default
  4. 也就是一个select最多只执行一次case里的代码
  5. 要一直检测case则必须外层使用 for循环 包起来
  6. close (chan)
  7. close没有make的chan会引起panic
  8. close以后不能再写入，写入会出现panic
  9. close之后可以读取，无缓冲chan读取返回0值和false，有缓冲chan可以继续读取，返回的都是chan中数据和true，直到读取完所有队列中的数据，返回默认值和false
  10. 重复close会引起panic
  11. 只读chan不能close
  12. 不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是写入。 

c := make(chan int, 1)
c <- 10 // 写入chan
v := <- c // 从chan中读取

下面的例子判断chan是否关闭： 

c := make(chan int, 1)
c <- 10
v,ok := <- c // 读取，v=10，ok=true
close(c)
v,ok := <- c // 读取，v=0，ok=false

如果写不进去就丢弃，可以用select： 

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: // 没有可读的，走这个分支
}

超时控制 

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的方式。 

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只允许有一个变量。 

for v:=range aChannel {
 // use v
}

等价于 

for {
 v, ok := <- aChannel
 if !ok {
  break 
 }
 // use v
}

注意，for-range对应的channel不能是只写channel。

相关文章