一、channel

channel分为有buffer的和没有buffer的。
没有buffer的能够当成有buffer然而buffersize为0的状况。
buffer数据结构：

type hchan struct {    qcount   uint           // 以后chan中有多少数据    dataqsiz uint           // 环形数组队列的大小，也就是咱们定义的缓冲区大小    buf      unsafe.Pointer // 指向环形数组队列的指针    elemsize uint16    closed   uint32    elemtype *_type // element type    sendx    uint   // 发送时插入的地位（环形数组的下标）    recvx    uint   // 接管时取数据的地位（环形数组的下标）    recvq    waitq  // 接管链表，当buf为空的时候，打包goroutine现场后放在这里    sendq    waitq  // 发送链表，当buf满的时候，打包goroutine现场后放在这里    // lock protects all fields in hchan, as well as several    // fields in sudogs blocked on this channel.    //    // Do not change another G's status while holding this lock    // (in particular, do not ready a G), as this can deadlock    // with stack shrinking.    lock mutex}

发送流程


像图中发送数据到channel中，每次qcount和sendx会随之变动，sendx会在插入前标记以后的插入地位变到插入后标记下一个数据插入地位（因为是环形数组，所以如果在最初地位插入后索引归0）
当buf外面的数据满的时候，再往里面发送数据，此时qcount==dataqsize示意满，此时咱们会将以后G的现场与channel打包成一个sudog的构造，链在sendq上。

上图为失常的发送流程，用以演示各个字段在流程中的变动。事实上发送时还须要判断recvq链表是否有sudog：

咱们晓得，sendq中寄存的是期待发送的sudog，那么同样的recvq寄存的就是期待接管的sudog。能够设想到，当recvq中有sudog节点的时候就阐明咱们的缓冲区曾经没有数据能够取了，才会将接管的g放到recvq中。此时，咱们须要发送的内容应该立刻被拿走，不该再放到buf或sendq中。
残缺的发送流程如下：

接管流程

同样的，当做从channel中接收数据的动作时，会先判断buf是否为空，为空的话进行现场打包成sudog链在recvq的链表上。
残缺的接管流程如下：

与发送流程有所不同的是，当buf数据满并且sendq中有sudog的时候，咱们还须要判断是否有缓冲区。

  1. 如果有缓冲区的话咱们须要保护buf：

    1. 先将以后的recvx索引的数据取出
    2. 而后将sudog中的elem数据取出
    3. 再将sudog取出的数据copy到buf空进去的地位。（sendq和recvq是链表构造然而也合乎先进先出，在waiq构造中会保留first sudog和last sudog的指针地位，不便进行链表的入队与出队操作）
  2. 如果没有缓冲区，那咱们间接就能够将sudog的数据取出接管。
为什么发送的时候不须要判断是否有缓冲区而接管的时候须要判断呢？

咱们能够从接管流程中发现，咱们会在buf为空的时候才会往recvq追加sudog，那么也就是说在接管流程中，recvq只有不为空那就阐明buf是空的，那么没有缓冲区和有缓冲区也都是等价于空的buf，所以无需判断。
然而在接管流程中，如果sendq不为空的话。

  • 如果有缓冲区，阐明buf肯定是满的，因为须要保护好先后顺序，所以咱们要保护buf和sendq链表。
  • 没有缓冲区，无需保护buf，所以间接从sendq中找数据内容。
ps：
  • gopark()是挂起的意思，会对应一个goready()唤醒。

  • 挂起与唤醒：

    • ①sender挂起的肯定是由receiver或close唤醒
    • ②receiver挂起的肯定是由sender或close唤醒。