2. Goroutine 生命周期：创建、调度、阻塞与退出

Goroutine 是 Go 并发模型的核心执行单元，理解其完整生命周期——从创建、调度运行、阻塞等待到最终退出——是进行并发调优和避免资源泄漏的基础。本章将深入剖析 Goroutine 在各阶段的底层机制，并重点识别 Goroutine 泄漏的常见场景。

2.1 Goroutine 的创建与栈管理

Goroutine 的创建成本极低，这是 Go 能够支撑数十万甚至百万级并发的关键。使用 go 关键字即可启动一个 Goroutine：

go func() {
    // 并发执行的任务
    fmt.Println("Hello from goroutine")
}()

创建时，Go 运行时（runtime）会分配一个初始栈（通常为 2KB），并为其维护一个 g 结构体。与操作系统线程（默认栈 1-8MB）相比，Goroutine 的栈空间占用极小，且支持动态扩缩容（通过 stack copying 技术）。

2.2 Goroutine 调度模型：GMP

Go 运行时实现了用户态调度器，核心模型为 GMP（Goroutine、Machine、Processor）。调度器负责将 Goroutine 公平、高效地分配到 OS 线程上执行。

2.3 Goroutine 的阻塞与退出

Goroutine 在生命周期中可能因多种原因进入阻塞状态。理解阻塞类型是排查性能瓶颈的关键。

Goroutine 正常退出时，会执行 goexit 流程：清理 defer、释放栈、将 G 结构体归还到空闲池。若主函数 main 返回，所有 Goroutine 会被强制终止，无论其是否执行完毕。

2.4 Goroutine 泄漏的常见场景

Goroutine 泄漏是指 Goroutine 在完成任务后未能正常退出，永久阻塞在某个状态，导致其占用的栈空间和关联资源无法被 GC 回收。泄漏的 Goroutine 会持续消耗内存，最终导致 OOM 或性能严重下降。

2.5 泄漏场景代码示例与修复

以下展示一个典型的 Channel 未关闭导致的 Goroutine 泄漏，以及对应的修复方案。

泄漏代码：

// 泄漏：Goroutine 永远阻塞在 ch <- result
func leakyProcess(data []int) []int {
    ch := make(chan int)
    for _, v := range data {
        go func(val int) {
            result := heavyCompute(val)
            ch <- result  // 如果接收者退出，这里永久阻塞
        }(v)
    }

    var results []int
    for i := 0; i < len(data); i++ {
        results = append(results, <-ch)
    }
    return results
}

修复方案：使用带缓冲 channel 或 context 超时：

// 修复：使用带缓冲 channel，确保发送不阻塞
func fixedProcess(data []int) []int {
    ch := make(chan int, len(data)) // 缓冲大小等于任务数
    for _, v := range data {
        go func(val int) {
            result := heavyCompute(val)
            ch <- result
        }(v)
    }

    var results []int
    for i := 0; i < len(data); i++ {
        results = append(results, <-ch)
    }
    close(ch)
    return results
}

// 修复：使用 context 超时控制
func processWithTimeout(ctx context.Context, data []int) ([]int, error) {
    ch := make(chan int)
    for _, v := range data {
        go func(val int) {
            select {
            case ch <- heavyCompute(val):
            case <-ctx.Done():
                // 超时或取消，Goroutine 安全退出
            }
        }(v)
    }

    var results []int
    for i := 0; i < len(data); i++ {
        select {
        case result := <-ch:
            results = append(results, result)
        case <-ctx.Done():
            return nil, ctx.Err()
        }
    }
    return results, nil
}

2.6 生命周期总结