详细解读go语言中的chnanel
Channel
底层数据结构
type hchan struct {
qcount uint // 当前队列中剩余元素个数
dataqsiz uint // 环形队列长度，即可以存放的元素个数
buf unsafe.Pointer // 环形队列指针
elemsize uint16 // 每个元素的大小
closed uint32 // 标识关闭状态
elemtype *_type // 元素类型
sendx uint // 队列下标，指示元素写入时存放到队列中的位置
recvx uint // 队列下标，指示元素从队列的该位置读出
recvq waitq // 等待读消息的goroutine队列
sendq waitq // 等待写消息的goroutine队列
lock mutex // 互斥锁，chan不允许并发读写
}
waitq 是 sudog 的一个双向链表
1. type waitq struct {
2. first *sudog
3. last *sudog
4. }
而 sudog 实际上是对 goroutine 的一个封装，表示一个在等待队列中的goroutine，该结构
存储了两个分别指向前后sudog的指针用来构成链表
发送数据
- 如果当前channel的recvq上存在已经被阻塞的Goroutine（也就是说有goroutine在等待读消息），那么会直接将数据发送给当前的Goroutine并将其设置成下一个运行的Goroutine（设置处理器runnext属性，不会立刻调度）
- 如果channel存在缓冲区并且还有空余位置，会直接将数据存储到缓存区sendx所在的位置上
- 如果不满足上述两种情况，会创建一个sudog结构并将其加入channel的sendq队列中，当前Goroutine陷入阻塞等待其他协程从Channel接收数据
接收数据
-
如果Channel为空，那么会直接让出处理器的使用权。
-
如果Channel已经关闭并且缓存区没有任何数据，会直接返回
-
如果Channel的sendq队列中存在挂起的Goroutine（说明有阻塞发送的goroutine），根据缓冲区的大小分别处理不同的情况：
如果 Channel 不存在缓冲区， 将 Channel 发送队列中 Goroutine 存储的数据拷贝到目标内存地址中；
如果 Channel 存在缓冲区，将队列中的数据拷贝到接收方的内存地址；将发送队列头的数据拷贝到缓冲区中，释放一个阻塞的发送方；
-
如果Channel的缓冲区存在数据（没有阻塞的发送Goroutine），会将缓冲区中的数据拷贝到接收方的内存地址、清除队列中的数据并完成收尾工作。
-
当 Channel 的发送队列中不存在等待的 Goroutine 并且缓冲区中也不存在任何数据时，会使用
runtime.sudog将当前 Goroutine 包装成一个处于等待状态的 Goroutine 将其加入到接收队列中并陷入休眠等待调度器的唤醒；
关闭通道
当 Channel 是一个空指针或者已经被关闭时，Go 语言运行时都会直接崩溃并抛出异常
处理完了这些异常的情况之后就可以开始执行关闭 Channel 的逻辑了，close 函数先上一把大锁，接着把所有挂在这个 channel 上的 sender 和 receiver 全都连成一个 sudog 链表，再解锁。最后，再将所有的 sudog 全都唤醒。
唤醒之后，sender 会检测到channel已经关闭，panic。从一个有缓冲的 channel 里读数据，当 channel 被关闭，依然能读出有效值。只有当返回的 ok 为 false 时，读出的数据才是无效的，为对应类型的零值。
x, ok := <-ch
产生panic的情况
向一个关闭的 channel 进行写操作；关闭一个 nil 的 channel；重复关闭一个 channel。
总结
channel缓存区是由循环队列实现的
channel的等待队列是一个双向链表
channel 的发送和接收操作本质上都是 “值的拷贝”
从一个有缓冲的 channel 里读数据，当 channel 被关闭，依然能读出有效值。发数据会panic。
原文：https://www.cnblogs.com/CJ-cooper/p/15247317.html