本文旨在深入探讨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的交互
让我们分析以下代码，并解释其输出为何可能与预期不同：
package mainimport "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: hello10000000000
这表明sum Goroutine也完成了其计算和打印。这背后的原因正是Go调度器的非确定性以及无缓冲Channel的阻塞特性：
main Goroutine启动：main函数首先创建了一个无缓冲通道c，然后启动了display和sum两个新的Goroutine。display Goroutine执行：调度器可能会选择先运行display。display Goroutine打印出 “display first message: hello”。接着，它尝试执行 c 阻塞，等待一个接收者。sum Goroutine执行：当display Goroutine阻塞后，调度器会切换到其他可运行的Goroutine，例如sum。sum Goroutine开始执行其长时间的循环计算。在计算完成后，它打印出计算结果 10000000000。然后，sum Goroutine也尝试执行 c 阻塞。main Goroutine接收并退出：现在，display和sum都已阻塞在向通道c发送数据上。调度器最终会切换回main Goroutine。main Goroutine执行 程序终止：main Goroutine在接收到值后，其后续语句执行完毕，main函数返回。当main Goroutine退出时，Go运行时会终止所有剩余的Goroutine，包括sum Goroutine（它可能仍然阻塞在 c
因此，sum Goroutine的打印发生在main Goroutine接收并退出之前，是因为调度器在display阻塞后给了sum运行的机会。
关键点总结：
Go调度器是非确定性的，Goroutine的执行顺序和切换时机无法保证。无缓冲Channel的发送和接收操作是同步阻塞的。main Goroutine的
实现“只接收第一个结果并立即退出”
如果我们的目标是只获取第一个完成任务的Goroutine的结果，并立即终止程序，而不等待其他Goroutine，我们可以修改代码如下：
package mainimport ( "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)}
在这个修改后的版本中：
我们创建了一个resultChan来专门传递结果字符串。display和sum Goroutine不再发送简单的bool值，而是发送它们各自的实际结果（
以上就是深入理解Go并发：Goroutine、Channel与调度器行为的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1416574.html
微信扫一扫 
支付宝扫一扫 
