type hchan struct {
 closed   uint32   // channel是否關(guān)閉的標(biāo)志
 elemtype *_type   // channel中的元素類型
 // channel分為無緩沖和有緩沖兩種。
 // 對于有緩沖的channel存儲數(shù)據(jù)，使用了 ring buffer（環(huán)形緩沖區(qū)) 來緩存寫入的數(shù)據(jù)，本質(zhì)是循環(huán)數(shù)組
 // 為啥是循環(huán)數(shù)組？普通數(shù)組不行嗎，普通數(shù)組容量固定更適合指定的空間，彈出元素時，普通數(shù)組需要全部都前移
 // 當(dāng)下標(biāo)超過數(shù)組容量后會回到第一個位置，所以需要有兩個字段記錄當(dāng)前讀和寫的下標(biāo)位置
 buf      unsafe.Pointer // 指向底層循環(huán)數(shù)組的指針（環(huán)形緩沖區(qū)）
 qcount   uint           // 循環(huán)數(shù)組中的元素數(shù)量
 dataqsiz uint           // 循環(huán)數(shù)組的長度
 elemsize uint16                 // 元素的大小
 sendx    uint           // 下一次寫下標(biāo)的位置
 recvx    uint           // 下一次讀下標(biāo)的位置
 // 嘗試讀取channel或向channel寫入數(shù)據(jù)而被阻塞的goroutine
 recvq    waitq  // 讀等待隊列
 sendq    waitq  // 寫等待隊列
 lock mutex //互斥鎖，保證讀寫channel時不存在并發(fā)競爭問題
}

type waitq struct {
   first *sudog
   last  *sudog
}
type sudog struct {
    g *g
    next *sudog
    prev *sudog
    elem unsafe.Pointer 
    c        *hchan 
    ...
}

func makechan64(t *chantype, size int64) *hchan {
    if int64(int(size)) != size {
        panic(plainError("makechan: size out of range"))
    }
    return makechan(t, int(size))
}

// 帶緩沖
ch := make(chan int, 3)
// 不帶緩沖
ch := make(chan int)

func chansend(c *hchan, ep unsafe.Pointer, block bool, callerpc uintptr) bool 

ch <- 10

select {
    case ch <- 10:
    ...
  default
}

func chanrecv(c *hchan, ep unsafe.Pointer, block bool) (selected, received bool) 

<ch
v := <ch
v, ok := <ch
// 當(dāng)channel關(guān)閉時，for循環(huán)會自動退出，無需主動監(jiān)測channel是否關(guān)閉，可以防止讀取已經(jīng)關(guān)閉的channel,造成讀到數(shù)據(jù)為通道所存儲的數(shù)據(jù)類型的零值
for i := range ch {
    fmt.Println(i)
}

select {
    case <-ch:
    ...
  default
}

close(ch)

func closechan(c *hchan) 

package main
import (
    "fmt"
    "time"
    "unsafe"
)
func main() {
  // ch是長度為4的帶緩沖的channel
  // 初始hchan結(jié)構(gòu)體重的buf為空，sendx和recvx均為0
    ch := make(chan string, 4)
    fmt.Println(ch, unsafe.Sizeof(ch))
    go sendTask(ch)
    go receiveTask(ch)
    time.Sleep(1 * time.Second)
}
// G1是發(fā)送者
// 當(dāng)G1向ch里發(fā)送數(shù)據(jù)時，首先會對buf加鎖，然后將task存儲的數(shù)據(jù)copy到buf中，然后sendx++，然后釋放對buf的鎖
func sendTask(ch chan string) {
    taskList := []string{"this", "is", "a", "demo"}
    for _, task := range taskList {
        ch <- task //發(fā)送任務(wù)到channel
    }
}
// G2是接收者
// 當(dāng)G2消費ch的時候，會首先對buf加鎖，然后將buf中的數(shù)據(jù)copy到task變量對應(yīng)的內(nèi)存里，然后recvx++,并釋放鎖
func receiveTask(ch chan string) {
    for {
        task := <-ch                  //接收任務(wù)
        fmt.Println("received", task) //處理任務(wù)
    }
}