2. Go 并发原语：goroutine 生命周期、channel 通信模式、select 多路复用

在支付系统中，并发是处理高吞吐、低延迟请求的核心手段。Go 语言通过 goroutine、channel 和 select 构建了 CSP（Communicating Sequential Processes）并发模型。本章深入剖析这三个原语在支付场景中的实战用法，帮助你在设计并发瓶颈时做出正确的技术决策。

2.1 goroutine 生命周期管理

goroutine 是 Go 运行时调度的轻量级线程，初始栈仅 2KB，可动态增长。支付系统中，每个请求、每个异步任务通常都对应一个 goroutine。理解其生命周期是避免 goroutine 泄漏、资源耗尽的前提。

2.1.1 生命周期阶段

2.1.2 泄漏防范：确保 goroutine 能正常退出

支付系统中，泄漏的 goroutine 会持续占用内存和 goroutine 栈，最终导致 OOM。常见泄漏原因包括：channel 未关闭导致永久阻塞、for 循环未设置退出条件、父 goroutine 退出后子 goroutine 仍在运行。

// 错误示例：goroutine 永久阻塞
func leak() {
    ch := make(chan int)
    go func() {
        val := <-ch // 永远阻塞，没有写入者
        fmt.Println(val)
    }()
}

// 正确示例：使用 context 控制生命周期
func safeProcess(ctx context.Context, orderID string) {
    go func() {
        select {
        case <-ctx.Done():
            log.Printf("goroutine for order %s cancelled", orderID)
            return
        case result := <-doPayment(ctx, orderID):
            handleResult(result)
        }
    }()
}

2.2 channel 通信模式

channel 是 goroutine 之间通信的桥梁。支付系统中，channel 常用于解耦生产者和消费者、实现工作池、传递事件通知。根据是否带缓冲，channel 分为无缓冲（同步）和有缓冲（异步）两种。

2.2.1 无缓冲 vs 有缓冲 channel

2.2.2 常见通信模式

• 点对点（1:1）： 一个生产者对应一个消费者，适合支付回调处理。
• 扇出（1:N）： 一个 channel 被多个 goroutine 读取，适合事件广播。
• 扇入（N:1）： 多个 channel 合并到一个 channel，适合聚合多个异步结果。
• 管道（Pipeline）： 多个 channel 串联，适合对账数据流处理。

// 扇入模式：合并多个支付渠道的异步结果
func fanIn(channels ...<-chan PaymentResult) <-chan PaymentResult {
    out := make(chan PaymentResult)
    for _, ch := range channels {
        go func(c <-chan PaymentResult) {
            for v := range c {
                out <- v
            }
        }(ch)
    }
    return out
}

2.3 select 多路复用

select 语句允许一个 goroutine 同时等待多个 channel 操作。支付系统中，select 常用于超时控制、多路事件监听、优雅关闭等场景。

2.3.1 基本语法与执行规则

• select 会阻塞直到某个 case 可以执行。
• 如果多个 case 同时就绪，随机选择一个执行。
• default 分支在没有任何 case 就绪时立即执行，用于非阻塞尝试。

// 支付超时控制：select + time.After
func payWithTimeout(ctx context.Context, amount int64) error {
    resultCh := make(chan PayResult, 1)
    go func() {
        resultCh <- callPaymentGateway(ctx, amount)
    }()

    select {
    case res := <-resultCh:
        return res.Err
    case <-time.After(5 * time.Second):
        return ErrPaymentTimeout
    case <-ctx.Done():
        return ctx.Err()
    }
}

2.3.2 优雅关闭与资源清理

支付服务在重启或缩容时，需要优雅关闭正在处理的 goroutine。select 配合 done channel 可以实现可控退出。

// 优雅关闭工作池
func worker(id int, jobs <-chan Job, done <-chan struct{}) {
    for {
        select {
        case job, ok := <-jobs:
            if !ok {
                return // jobs 关闭，退出
            }
            processJob(id, job)
        case <-done:
            log.Printf("worker %d shutting down", id)
            return
        }
    }
}

2.4 支付场景并发原语综合示例

以下 SVG 图展示了一个支付网关中 goroutine、channel 和 select 的协作流程：

2.5 并发原语选型对比