golang - channel

Posted 2023-04-08

参考技术A 通过var声明或者make函数创建的channel变量是一个存储在函数栈帧上的指针，占用8个字节，指向堆上的hchan结构体
源码包中src/runtime/chan.go定义了hchan的数据结构如下：

hchan结构体的主要组成部分有四个：
用来保存goroutine之间传递数据的循环数组：buf
用来记录此循环数组当前发送或接收数据的下标值：sendx和recvx
用于保存向该chan发送和从该chan接收数据被阻塞的goroutine队列： sendq 和 recvq
保证channel写入和读取数据时线程安全的锁：lock

环形数组作为channel 的缓冲区 数组的长度就是定义channnel 时channel 的缓冲大小

在hchan 中包括了读/写 等待队列， waitq是一个双向队列，包括了一个头结点和尾节点。 每个节点是一个sudog结构体变量

channel有2种类型：无缓冲、有缓冲， 在创建时 make(chan type cap) 通过cap 设定缓冲大小
channel有3种模式：写操作模式（单向通道）、读操作模式（单向通道）、读写操作模式（双向通道）

channel有3种状态：未初始化、正常、关闭

如下几种状态会引发panic

channel 是线程安全的，channel的底层实现中，hchan结构体中采用Mutex锁来保证数据读写安全。在对循环数组buf中的数据进行入队和出队操作时，必须先获取互斥锁，才能操作channel数据

golang 之 channel

 

channel的机制是先进先出

无缓冲的channel： 如果你给channel赋值了，那么必须要读取它的值，不然就会造成阻塞。

 

chreadandwrite :=make(chan int)

chonlyread := make(<-chan int) //创建只读channel 
chonlywrite := make(chan<- int) //创建只写channel 

 有缓冲的channel： 发送方会一直阻塞直到数据被拷贝到缓冲区；

如果缓冲区已满，则发送方只能在接收方取走数据后才能从阻塞状态恢复。

 

 ch :=make(chan int,1)

 

　　 

• 关于Channel的心得【摘抄】

1. 首先，永远是符号<-进行读取或者写入，譬如v,ok := <-c是读取，而c <- v是写入。
2. 其次，读取时，如果没有ok，也是可以读取的。不过如果closed也是能读的，没有赋值而已；如果要知道是否closed得加ok，也就是除非chan永远不关闭，否则读取应该用v,ok := <-c而不是用v := <-c的方式。
3. 再次，不能向closed的chan写入，所以一般写入时需要用一个信号的chan（一般buffer为1），来判断是否写入或者放弃，用select判断是写入成功了，还是正在关闭需要放弃写入。
4. 最后，如果closed后，chan有数据，ok还是true的，直到chan没有数据了才false。