4. Channel高级：Channel关闭与检测、单向Channel、Select多路复用

Channel 是 Go 并发模型中的一等公民，其高级用法直接决定了并发系统的健壮性与可组合性。本章聚焦三个核心主题：Channel 的关闭与检测（如何安全地通知协程终止）、单向 Channel（通过类型系统约束 Channel 的读写权限）、Select 多路复用（在多个 Channel 间实现非阻塞或优先级调度）。掌握这些模式，是构建高可靠、高性能并发聚合系统的关键。

4.1 Channel 关闭与检测

关闭 Channel 是向所有接收方广播“不再有数据”的唯一方式。错误的关闭或重复关闭会导致 panic，而未能检测关闭则可能引发死锁或无限阻塞。

4.1.1 关闭原则与安全模式

Go 官方推荐 “由发送方关闭 Channel” 的原则。发送方知道数据何时发送完毕，关闭后接收方可通过 value, ok := <-ch 检测关闭状态。

4.1.2 安全关闭模式：sync.Once + select

当多个发送方可能尝试关闭同一个 Channel 时，必须使用 sync.Once 保证关闭只执行一次：

type SafeCloser struct {
    once    sync.Once
    ch      chan int
}

func (s *SafeCloser) Close() {
    s.once.Do(func() {
        close(s.ch)
    })
}

func (s *SafeCloser) Send(v int) bool {
    select {
    case s.ch <- v:
        return true
    default:
        // Channel 已关闭或满，优雅降级
        return false
    }
}

4.2 单向 Channel

单向 Channel 通过类型系统约束 Channel 的读写方向，在编译期防止误用。Go 使用 chan<- T（只写）和 <-chan T（只读）语法。

4.2.1 双向转单向的隐式转换

双向 Channel 可以隐式转换为单向 Channel，反之不行。这一特性在函数签名中广泛用于声明意图：

// 生产者：只写 Channel
func producer(out chan<- int) {
    for i := 0; i < 10; i++ {
        out <- i
    }
    close(out) // 只写 Channel 允许关闭
}

// 消费者：只读 Channel
func consumer(in <-chan int) {
    for v := range in {
        fmt.Println(v)
    }
}

func main() {
    ch := make(chan int) // 双向
    go producer(ch)      // 隐式转换为 chan<- int
    consumer(ch)         // 隐式转换为 <-chan int
}

4.2.2 单向 Channel 的架构价值

4.3 Select 多路复用

select 语句是 Go 并发调度的核心原语，允许在多个 Channel 操作间等待，实现非阻塞、超时、优先级和扇入/扇出模式。

4.3.1 Select 执行语义

• 随机公平选择： 当多个 case 同时就绪时，Go 运行时使用伪随机算法选择其中一个执行，保证公平性。
• 非阻塞模式： 包含 default 分支时，若无任何 case 就绪，立即执行 default。
• nil Channel 永远阻塞： 对 nil Channel 的发送或接收操作在 select 中会被永久忽略，可用于动态禁用 case。

// 带超时的 Select 模式
func fetchWithTimeout(ch <-chan Result, timeout time.Duration) (Result, error) {
    select {
    case result := <-ch:
        return result, nil
    case <-time.After(timeout):
        return Result{}, errors.New("timeout")
    }
}

// 优先级调度：高优先级 Channel 优先检查
func prioritySelect(high, low <-chan int) {
    select {
    case v := <-high:
        processHigh(v)
    default:
        select {
        case v := <-low:
            processLow(v)
        default:
            // 都无数据，可做其他工作
        }
    }
}

4.3.2 Select 性能特征

4.4 综合架构：Channel 高级模式聚合

下图展示了 Channel 关闭检测、单向约束和 Select 多路复用在典型并发聚合系统中的协作关系：

4.5 实战模式：优雅退出与资源清理

结合 Channel 关闭检测和 Select 多路复用，可以实现协程的优雅退出：

type Worker struct {
    stopCh chan struct{}
    dataCh chan int
}

func (w *Worker) Run() {
    for {
        select {
        case v, ok := <-w.dataCh:
            if !ok {
                // dataCh 已关闭，进入退出流程
                w.cleanup()
                return
            }
            process(v)
        case <-w.stopCh:
            // 收到停止信号，立即退出
            w.cleanup()
            return
        }
    }
}

func (w *Worker) Stop() {
    close(w.stopCh) // 广播停止信号
}

func (w *Worker) StopAndDrain() {
    close(w.dataCh) // 关闭数据通道，让 Run 自然退出
    close(w.stopCh)
}