当前位置：首页 > Go > 正文

深入理解Go语言并发核心（goroutine的创建与调度原理详解）

主机测评网
Go
2025-12-11
263

在现代软件开发中，Go语言因其简洁、高效和强大的并发能力而广受欢迎。其中，goroutine 是 Go 实现并发的核心机制。本文将从零开始，详细讲解 goroutine 的创建方式、底层调度原理，帮助初学者轻松掌握 Go语言并发编程 的精髓。

什么是 Goroutine？

Goroutine 是 Go 运行时（runtime）管理的轻量级线程。与操作系统线程不同，goroutine 的开销极小（初始栈仅 2KB），可以轻松创建成千上万个而不影响性能。你只需在函数调用前加上 go 关键字，即可启动一个新的 goroutine。

package mainimport (    "fmt"    "time")func sayHello() {    fmt.Println("Hello from goroutine!")}func main() {    go sayHello() // 启动一个 goroutine    time.Sleep(time.Second) // 等待 goroutine 执行完成}

注意：主 goroutine（main 函数）如果提前结束，其他 goroutine 也会被强制终止。因此上面使用 time.Sleep 来确保子 goroutine 有时间执行。

Goroutine 的创建过程

当你使用 go func() 时，Go 运行时会执行以下步骤：

分配一个最小栈空间（通常为 2KB）；
将函数指针和参数封装为一个 goroutine 结构体；
将该 goroutine 放入本地 P（Processor）的运行队列中等待调度。

深入理解Go语言并发核心（goroutine的创建与调度原理详解） Go语言 goroutine 调度原理并发编程第1张

Go 调度器：GMP 模型

Go 的调度器采用 GMP 模型，这是理解 调度原理 的关键：

G（Goroutine）：代表一个 goroutine，包含其栈、状态、指令指针等信息；
M（Machine/OS Thread）：代表一个操作系统线程，真正执行代码的实体；
P（Processor）：逻辑处理器，负责管理 goroutine 队列，并将 G 分配给 M 执行。

每个 P 维护一个本地 runqueue（运行队列），当 M 需要执行任务时，会从关联的 P 中获取 G。如果本地队列为空，调度器会尝试从其他 P 的队列“偷”任务（work-stealing），以实现负载均衡。

为什么 Goroutine 更高效？

相比传统线程，goroutine 具有以下优势：

内存占用小（初始 2KB，可动态伸缩）；
创建和销毁成本极低；
由 Go runtime 统一调度，避免频繁陷入内核态；
支持高并发场景（轻松处理数万并发连接）。

实战：使用 sync.WaitGroup 管理 Goroutine

在实际开发中，我们通常使用 sync.WaitGroup 来等待所有 goroutine 完成，而不是用 time.Sleep：

package mainimport (    "fmt"    "sync")func worker(id int, wg *sync.WaitGroup) {    defer wg.Done() // 任务完成后通知 WaitGroup    fmt.Printf("Worker %d is working\n", id)}func main() {    var wg sync.WaitGroup    for i := 1; i <= 3; i++ {        wg.Add(1) // 每启动一个 goroutine，计数加 1        go worker(i, &wg)    }    wg.Wait() // 阻塞直到所有 goroutine 调用 Done()    fmt.Println("All workers finished.")}