Go 中单向通道（

霞舞 2026-01-03 00:00:00 次阅读

go 的单向通道通过类型约束实现发送/接收职责分离：`chan

在 Go 中，单向通道（对双向通道（chan T）施加编译时方向约束的视图类型。其核心设计目标是提升代码安全性与可读性：通过类型系统强制限定协程间的数据流向，防止误用（如接收方意外尝试发送），而非改变底层通信机制。

❌ 常见错误：直接 make 单向通道

以下写法是非法且不可行的：

c := make(chan<- int, 3) // 编译错误：cannot make chan<- int

原因在于：make 只接受双向通道类型（chan T）作为参数。chan

✅ 正确做法：从双向通道派生单向视图

需分三步完成：

创建双向通道：c := make(chan int, 3)
显式转换为单向类型（推荐用类型断言或变量赋值）
按角色分发：发送方持有 chan

✅ 示例：安全的一对一单向通信

package main

import (
    "fmt"
    "time"
)

// 接收端函数：只声明接收通道 <-chan int
func Thread(r <-chan int) {
    for num := range r { // 使用 range 自动处理关闭信号
        fmt.Println("Thread:", num)
        time.Sleep(time.Second)
    }
    fmt.Println("Thread: channel closed, exiting.")
}

func main() {
    // 1. 创建带缓冲的双向通道
    c := make(chan int, 3)

    // 2. 显式转换为单向类型（两种等效方式）
    var sender chan<- int = c     // 发送视图
    var receiver <-chan int = c   // 接收视图

    // 3. 启动接收协程，传入只读通道
    go Thread(receiver)

    // 4. 主协程发送数据
    for i := 1; i <= 10; i++ {
        sender <- i
        fmt.Printf("Main sent: %d\n", i)
        time.Sleep(300 * time.Millisecond)
    }

    // 5. 关闭通道，通知接收方结束（关键！）
    close(c)
    time.Sleep(2 * time.Second) // 等待 Thread 完成打印
}

? 关键点说明：Thread 函数参数为

⚠️ 注意事项与最佳实践

单向通道是类型安全契约，不是运行时隔离：它们不改变底层通道行为，仅提供编译期检查；
不要忽略关闭通道：若接收方使用 range，未关闭会导致永久阻塞；若用 select + ok 判断，也需主动关闭；
避免过度使用类型转换：优先用变量赋值（var r
缓冲区大小需权衡：本例用 cap=3 避免主协程过早阻塞，但若生产者远快于消费者，仍可能因缓冲满而阻塞——应结合背压策略（如 select 非阻塞发送）或监控机制。