## 无缓冲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。
有疑问加站长微信联系(非本文作者))