深入理解Go并发：Goroutine、Channel与调度器行为-Golang-PHP中文网

深入理解Go并发：Goroutine、Channel与调度器行为

霞舞

发布： 2025-10-24 09:58:40

原创

415人浏览过

深入理解go并发：goroutine、channel与调度器行为

本文旨在深入探讨Go语言的并发模型，重点解析Goroutine、Channel的工作原理及其与Go调度器的交互。通过分析一个具体的并发代码示例，我们将揭示Go程序执行顺序的非确定性，理解通道的阻塞特性，并提供实现“只接收第一个结果并立即退出”的解决方案，帮助读者更好地掌握Go并发编程的精髓。

Go语言以其内置的并发原语——Goroutine和Channel——而闻名，它们使得编写并发程序变得简单而高效。然而，对于初学者来说，理解这些原语如何协同工作，以及Go运行时调度器如何管理Goroutine的执行，常常会遇到困惑。本教程将通过一个实际案例，深入剖析Go并发的这些核心概念。

Go并发基础：Goroutine与Channel

在Go中，Goroutine是轻量级的执行线程，由Go运行时管理。它们比操作系统线程的开销小得多，使得我们可以在一个程序中轻松创建成千上万个Goroutine。通过在函数调用前加上go关键字，即可启动一个新的Goroutine。

Channel是Goroutine之间进行通信的管道，它提供了一种安全、同步的方式来传递数据。Channel的设计理念是“不要通过共享内存来通信，而是通过通信来共享内存”，这有助于避免传统并发编程中常见的竞态条件。

Channel可以分为两类：

无缓冲Channel（Unbuffered Channel）：创建时未指定容量或容量为0。发送操作会阻塞，直到有接收方准备好接收；接收操作会阻塞，直到有发送方准备好发送。这意味着发送和接收是同步进行的。
有缓冲Channel（Buffered Channel）：创建时指定了容量。发送操作只有在Channel满时才会阻塞；接收操作只有在Channel空时才会阻塞。

Go调度器的工作原理

Go调度器是Go运行时的一个核心组件，负责在操作系统线程上调度和运行Goroutine。它的主要特点包括：

非确定性（Non-deterministic）：调度器在Goroutine之间切换的精确时机是不可预测的。它会根据内部启发式算法、Goroutine的状态（如是否阻塞）、以及操作系统线程的可用性来决定哪个Goroutine应该运行。这意味着程序的输出顺序可能因多次运行而异。
并发与并行：调度器尝试在单核CPU上通过时间片轮转实现Goroutine的并发执行（快速切换），在多核CPU上则可以实现真正的并行执行（同时运行多个Goroutine）。
协作式调度：Goroutine会在某些点（如I/O操作、Channel操作、函数调用等）主动或被动地将控制权交还给调度器，以便其他Goroutine有机会运行。

案例分析：理解Goroutine与Channel的交互

让我们分析以下代码，并解释其输出为何可能与预期不同：

钉钉 AI 助理

钉钉AI助理汇集了钉钉AI产品能力，帮助企业迈入智能新时代。

查看详情

package main

import "fmt"

func display(msg string, c chan bool){
    fmt.Println("display first message:", msg)
    c <- true // 尝试向通道发送数据
}

func sum(c chan bool){
    s := 0
    for i:=0; i < 10000000000; i++ { // 模拟长时间计算
        s++
    }
    fmt.Println(s)
    c <- true // 尝试向通道发送数据
}

func main(){
    c := make(chan bool) // 创建一个无缓冲通道

    go display("hello", c) // 启动display Goroutine
    go sum(c)              // 启动sum Goroutine

    <-c // main Goroutine等待从通道接收数据
}

登录后复制

预期的困惑：用户可能认为，display Goroutine会很快打印消息并向通道c发送true，由于main Goroutine正在等待接收，程序应该在display发送后立即接收并退出，从而阻止sum Goroutine完成其长时间的计算和打印。

实际输出及解释：观察到的输出可能是：

display first message: hello
10000000000

登录后复制

这表明sum Goroutine也完成了其计算和打印。这背后的原因正是Go调度器的非确定性以及无缓冲Channel的阻塞特性：

main Goroutine启动：main函数首先创建了一个无缓冲通道c，然后启动了display和sum两个新的Goroutine。
display Goroutine执行：调度器可能会选择先运行display。display Goroutine打印出 "display first message: hello"。接着，它尝试执行 c <- true。由于c是一个无缓冲通道，并且此时main Goroutine还没有执行到 <-c 来接收数据，display Goroutine会在此处阻塞，等待一个接收者。
sum Goroutine执行：当display Goroutine阻塞后，调度器会切换到其他可运行的Goroutine，例如sum。sum Goroutine开始执行其长时间的循环计算。在计算完成后，它打印出计算结果 10000000000。然后，sum Goroutine也尝试执行 c <- true。此时，main Goroutine仍然没有准备好接收，而且display Goroutine也还在尝试发送，因此sum Goroutine也会在此处阻塞。
main Goroutine接收并退出：现在，display和sum都已阻塞在向通道c发送数据上。调度器最终会切换回main Goroutine。main Goroutine执行 <-c，它会从通道c中接收一个值。由于display和sum都在等待发送，调度器会选择其中一个Goroutine（例如display）进行通信。main成功从display接收到true。
程序终止：main Goroutine在接收到值后，其后续语句执行完毕，main函数返回。当main Goroutine退出时，Go运行时会终止所有剩余的Goroutine，包括sum Goroutine（它可能仍然阻塞在 c <- true 上）。

因此，sum Goroutine的打印发生在main Goroutine接收并退出之前，是因为调度器在display阻塞后给了sum运行的机会。

关键点总结：

Go调度器是非确定性的，Goroutine的执行顺序和切换时机无法保证。
无缓冲Channel的发送和接收操作是同步阻塞的。
main Goroutine的 <-c 只会接收一个值。即使有多个Goroutine尝试向同一个通道发送数据，也只有一个能成功。一旦main接收到值并退出，所有其他Goroutine都会被终止。

实现“只接收第一个结果并立即退出”

如果我们的目标是只获取第一个完成任务的Goroutine的结果，并立即终止程序，而不等待其他Goroutine，我们可以修改代码如下：

package main

import (
    "fmt"
    "time"
    "os" // 引入os包用于程序退出
)

// display Goroutine向结果通道发送其消息
func display(msg string, result chan string) {
    // 模拟一些工作，确保它有机会在sum之前完成
    time.Sleep(50 * time.Millisecond)
    result <- "Display: " + msg // 将结果作为字符串发送到通道
}

// sum Goroutine计算并向结果通道发送其和
func sum(result chan string) {
    s := 0
    for i := 0; i < 1000000000; i++ { // 模拟长时间计算
        s++
    }
    result <- fmt.Sprintf("Sum: %d", s) // 将结果作为字符串发送到通道
}

func main() {
    resultChan := make(chan string) // 创建一个用于接收结果的通道

    go display("hello", resultChan) // 启动display Goroutine
    go sum(resultChan)              // 启动sum Goroutine

    // 接收第一个到达的结果
    firstResult := <-resultChan
    fmt.Println("Received first result:", firstResult)

    // 立即终止程序。
    // 如果不使用os.Exit(0)，程序会等待main Goroutine自然结束，
    // 但其他Goroutine可能仍在后台运行。
    // os.Exit(0)确保程序立即退出，防止其他Goroutine继续执行或打印。
    os.Exit(0)
}

登录后复制

在这个修改后的版本中：