Question

同步和异步通道的区别在于是否创建缓冲区。

// chan.go

type hchan struct {
    qcount   uint             // 数据项数量。
    dataqsiz uint             // 缓冲区容量。
    buf      unsafe.Pointer   // 缓冲区指针。
    
    elemsize uint16           // 元素长度。
    elemtype *_type           // 元素类型。
    
    closed   uint32
    
    sendx    uint             // 缓冲区发送索引。
    recvx    uint             // 缓冲区接收索引。
    recvq    waitq            // 接收等待列表。
    sendq    waitq            // 发送等待列表。
    
    lock mutex
}

根据是否包含指针，来选择内存分配模式。

func makechan(t *chantype, size int) *hchan {

    elem := t.elem
    
    // 元素长度不能超过 64KB。
    if elem.size >= 1<<16 {
        throw("makechan: invalid channel element type")
    }
    
    // 缓冲区内存限制。
    mem, overflow := math.MulUintptr(elem.size, uintptr(size))  // 元素大小 * 数量
    if overflow || mem > maxAlloc-hchanSize || size < 0 {
        panic(plainError("makechan: size out of range"))
    }
    
    var c *hchan
    switch {
    case mem == 0:
        // 队列或元素长度为零，不分配缓冲区。
        c = (*hchan)(mallocgc(hchanSize, nil, true))
        c.buf = unsafe.Pointer(c)
    case elem.ptrdata == 0:
        // 非指针类型，连同缓冲区一同分配。
        c = (*hchan)(mallocgc(hchanSize+mem, nil, true))
        c.buf = add(unsafe.Pointer(c), hchanSize)
    default:
        // 单独分配内存。
        c = new(hchan)
        c.buf = mallocgc(mem, elem, true)
    }
    
    c.elemsize = uint16(elem.size)
    c.elemtype = elem
    c.dataqsiz = uint(size)
    
    return c
}