3、Channel基础：无缓冲channel与有缓冲channel、channel的发送与接收操作、channel关闭与range遍历

3.1 Channel 核心概念与分类

Channel 是 Go 并发模型中的一等公民，它既是 goroutine 之间的通信管道，也是同步原语。根据是否具有缓冲区，channel 分为两种基本类型：无缓冲 channel 和 有缓冲 channel。它们的发送与接收行为存在本质差异，直接影响 goroutine 的调度与阻塞。

3.2 无缓冲 channel：同步通信模型

无缓冲 channel 的发送与接收操作是同步阻塞的。发送操作会一直阻塞，直到另一个 goroutine 在该 channel 上执行接收操作；反之亦然。这种机制天然实现了 goroutine 之间的 rendezvous（会合点）。

// 无缓冲 channel 示例：同步通知
func worker(done chan struct{}) {
    // 模拟工作
    time.Sleep(100 * time.Millisecond)
    // 发送完成信号
    done <- struct{}{}
}

func main() {
    done := make(chan struct{})
    go worker(done)
    // 阻塞等待 worker 完成
    <-done
    fmt.Println("worker 已完成")
}

3.3 有缓冲 channel：异步通信模型

有缓冲 channel 允许发送方在缓冲区未满时非阻塞地发送数据，接收方在缓冲区非空时非阻塞地接收数据。缓冲区大小决定了 channel 的吞吐能力和背压（backpressure）特性。

// 有缓冲 channel 示例：任务队列
func producer(ch chan<- int) {
    for i := 0; i < 5; i++ {
        ch <- i
        fmt.Printf("发送: %d\n", i)
    }
    close(ch)
}

func consumer(ch <-chan int) {
    for v := range ch {
        fmt.Printf("接收: %d\n", v)
        time.Sleep(50 * time.Millisecond)
    }
}

func main() {
    ch := make(chan int, 3) // 缓冲区大小为 3
    go producer(ch)
    consumer(ch)
}

3.4 Channel 的发送与接收操作

Channel 的发送与接收使用 <- 运算符，方向决定了 channel 的角色。Go 编译器会在编译期检查 channel 的方向性，防止误用。

// 发送操作：ch <- value
// 接收操作：value := <-ch  ｜  value, ok := <-ch

ch := make(chan int, 2)

// 发送
ch <- 10
ch <- 20

// 接收（单返回值）
a := <-ch
fmt.Println(a) // 10

// 接收（双返回值：数据 + 是否成功）
b, ok := <-ch
fmt.Println(b, ok) // 20 true

// 从已关闭的空 channel 接收
close(ch)
c, ok := <-ch
fmt.Println(c, ok) // 0 false（零值 + 关闭标志）

3.5 Channel 关闭与 range 遍历

关闭 channel 使用内置函数 close(ch)。关闭后的 channel 具有以下语义：

• 向已关闭的 channel 发送数据会引发 panic。
• 从已关闭的 channel 接收数据：如果缓冲区还有数据，正常接收；缓冲区为空时，返回零值。
• 双值接收 v, ok := <-ch 中，ok 为 false 表示 channel 已关闭且无数据。
• 重复关闭 channel 会引发 panic。

range 遍历 channel 是处理 channel 数据流的惯用方式。当 channel 被关闭且缓冲区为空时，range 循环自动退出。

// 使用 range 遍历 channel
func sumValues(ch <-chan int) int {
    total := 0
    for v := range ch {
        total += v
    }
    return total
}

// 发送方负责关闭 channel
func generate(ch chan<- int) {
    for i := 1; i <= 5; i++ {
        ch <- i * 10
    }
    close(ch) // 关闭 channel，通知接收方结束
}

func main() {
    ch := make(chan int, 3)
    go generate(ch)
    result := sumValues(ch)
    fmt.Println("总和:", result) // 150
}

3.6 常见陷阱与最佳实践