3. Channel 基础：创建、类型与优雅退出

Channel 是 Go 并发模型中的核心通信原语，遵循“不要通过共享内存来通信，而应通过通信来共享内存”的设计哲学。本章将系统讲解 Channel 的创建方式、类型体系、缓冲机制以及关闭与优雅退出的最佳实践，为后续构建 goroutine 池奠定基础。

3.1 Channel 的创建与类型

Channel 使用 make 内置函数创建，其类型由元素类型和方向共同决定。创建时必须指定元素类型，方向默认为双向。

// 无缓冲 Channel
ch := make(chan int)

// 有缓冲 Channel（容量为 10）
ch := make(chan string, 10)

// 只读 Channel（类型声明）
var readOnly <-chan int = ch

// 只写 Channel（类型声明）
var writeOnly chan<- int = ch

Channel 的类型体系可通过下表快速对照：

3.2 无缓冲 Channel 与有缓冲 Channel

无缓冲 Channel 与有缓冲 Channel 在行为上存在本质差异，直接影响 goroutine 的同步与调度。

3.2.1 无缓冲 Channel（同步 Channel）

无缓冲 Channel 的发送操作会阻塞，直到有对应的接收操作就绪；反之亦然。这种机制实现了 goroutine 之间的同步握手。

// 无缓冲 Channel 示例：同步通信
func main() {
    ch := make(chan string)

    go func() {
        // 发送操作会阻塞，直到 main goroutine 接收
        ch <- "hello"
        fmt.Println("goroutine: 发送完成")
    }()

    // 接收操作会阻塞，直到子 goroutine 发送
    msg := <-ch
    fmt.Println("main: 收到", msg)

    // 输出顺序：
    // main: 收到 hello
    // goroutine: 发送完成
}

3.2.2 有缓冲 Channel（异步 Channel）

有缓冲 Channel 在缓冲区未满时，发送操作不会阻塞；在缓冲区非空时，接收操作不会阻塞。缓冲区的存在解耦了发送方与接收方的执行时序。

// 有缓冲 Channel 示例：异步通信
func main() {
    ch := make(chan int, 3)

    // 发送 3 个元素，不会阻塞
    ch <- 1
    ch <- 2
    ch <- 3
    fmt.Println("发送完成，缓冲区已满")

    // 第 4 次发送会阻塞，等待接收
    go func() {
        ch <- 4
        fmt.Println("第 4 个元素发送成功")
    }()

    // 接收一个元素，腾出空间
    <-ch
    time.Sleep(100 * time.Millisecond)
}

3.2.3 核心差异对比

下图展示了无缓冲与有缓冲 Channel 在发送/接收流程上的核心差异：

3.3 Channel 的关闭与优雅退出

Channel 的关闭是 goroutine 协作退出的关键机制。关闭 Channel 意味着不再有数据发送，接收方可以通过特殊语法检测关闭状态，从而优雅地终止处理循环。

3.3.1 关闭规则与检测

// 关闭 Channel
close(ch)

// 接收时检测关闭状态（推荐方式）
for {
    value, ok := <-ch
    if !ok {
        fmt.Println("Channel 已关闭，退出循环")
        break
    }
    fmt.Println("收到:", value)
}

// 使用 range 自动检测关闭（更简洁）
for value := range ch {
    fmt.Println("收到:", value)
}
// range 循环在 Channel 关闭且缓冲区为空时自动退出

3.3.2 关闭原则与常见陷阱

3.3.3 优雅退出模式

在 goroutine 池中，通常使用 close 结合 select 实现优雅退出：

// 优雅退出模式：使用 close 通知所有 worker 退出
func worker(id int, tasks <-chan Task, quit <-chan struct{}) {
    for {
        select {
        case task, ok := <-tasks:
            if !ok {
                // Channel 已关闭，没有更多任务
                fmt.Printf("Worker %d: 任务队列关闭，退出\n", id)
                return
            }
            process(task)
        case <-quit:
            // 收到退出信号
            fmt.Printf("Worker %d: 收到退出信号\n", id)
            return
        }
    }
}

// 关闭流程
close(taskCh)      // 通知 worker 任务结束
close(quitCh)      // 或发送退出信号
wg.Wait()          // 等待所有 worker 退出

下图展示了 goroutine 池中 Channel 关闭与优雅退出的完整流程：