1. Go并发模型概述：Goroutine与Channel基础，MPG调度模型图解
1.1 并发与并行的本质区别
在深入Go并发模型之前，必须厘清两个核心概念：并发（Concurrency）与并行（Parallelism）。Go语言的设计哲学是“通过并发实现并行”，而非直接面向并行编程。
| 维度 | 并发（Concurrency） | 并行（Parallelism） |
|---|---|---|
| 定义 | 逻辑上同时处理多个任务（交替执行） | 物理上同时执行多个任务（真正同时） |
| 硬件依赖 | 单核CPU即可实现 | 必须多核/多CPU |
| 关注点 | 任务的结构与分解 | 任务的执行效率 |
| Go中的体现 | Goroutine的创建与调度 | GOMAXPROCS控制OS线程数 |
关键认知：Go的并发模型是CSP（Communicating Sequential Processes，通信顺序进程）的一种实现。核心思想是：不要通过共享内存来通信，而应通过通信来共享内存。这一理念直接塑造了Goroutine与Channel的设计。
1.2 Goroutine：轻量级执行体
Goroutine是Go语言并发编程的最小执行单元。与操作系统线程相比，Goroutine具有极低的创建和切换开销。
| 对比项 | OS线程 | Goroutine |
|---|---|---|
| 初始栈大小 | ~1MB（固定） | 2KB（动态伸缩） |
| 创建成本 | 高（系统调用） | 低（用户态） |
| 切换成本 | 高（内核态上下文切换） | 低（用户态调度器管理） |
| 数量级 | 数千 | 数百万 |
启动一个Goroutine只需在函数调用前加上关键字 go：
package main
import (
"fmt"
"time"
)
func sayHello() {
fmt.Println("Hello from goroutine")
}
func main() {
go sayHello() // 启动一个新的Goroutine
time.Sleep(100 * time.Millisecond) // 等待Goroutine执行
fmt.Println("Main function ends")
}1.3 Channel：Goroutine间的通信桥梁
Channel是Go中Goroutine之间传递数据的管道。它天然支持同步与异步两种模式，是CSP模型的核心组件。
- 无缓冲Channel（同步）：发送和接收操作必须同时准备好，否则一方会阻塞。
- 有缓冲Channel（异步）：发送方在缓冲区未满时不会阻塞，接收方在缓冲区非空时不会阻塞。
// 无缓冲Channel示例
ch := make(chan int)
go func() {
ch <- 42 // 发送，直到接收方准备好
}()
value := <-ch // 接收，与发送方同步
// 有缓冲Channel示例
bufferedCh := make(chan string, 3)
bufferedCh <- "A" // 不会阻塞
bufferedCh <- "B" // 不会阻塞
bufferedCh <- "C" // 不会阻塞
// bufferedCh <- "D" // 缓冲区满，会阻塞
常见陷阱：向已关闭的Channel发送数据会导致panic；从已关闭的Channel接收数据会立即返回零值，需使用
value, ok := <-ch模式检测Channel是否已关闭。
1.4 MPG调度模型图解
Go运行时调度器实现了著名的MPG模型，它是Goroutine高效调度的核心机制。M代表操作系统线程（Machine），P代表逻辑处理器（Processor），G代表Goroutine。
1.5 MPG调度流程详解
MPG模型的调度流程遵循以下关键步骤：
- Goroutine创建：使用
go关键字创建一个G，初始放入全局运行队列。 - P获取G：每个P（逻辑处理器）从全局队列或自己的本地队列中获取一个G。
- M执行G：P将G绑定到M（OS线程）上执行。M负责实际执行G的代码。
- 系统调用阻塞：当G执行系统调用（如文件读写）导致M阻塞时，P会解绑当前M，并绑定一个新的M（或从线程缓存中获取）继续执行其他G。
- Goroutine切换：当G主动让出（如Channel操作、
time.Sleep）或被抢占时，P将其放回队列，并调度下一个G。 - 工作窃取（Work Stealing）：当某个P的本地队列为空时，它会从全局队列或其他P的队列中窃取一半的Goroutine，以平衡负载。
性能调优启示：GOMAXPROCS（默认为CPU核心数）控制P的数量。在I/O密集型服务中，适当增加GOMAXPROCS可以提高并发吞吐；在CPU密集型计算中，设置超过核心数的P会导致不必要的上下文切换，反而降低性能。
1.6 Channel的底层实现与调度交互
Channel的底层实现依赖于Go调度器的协作。当Goroutine在Channel上阻塞时，调度器会将其状态标记为_Gwaiting，并调度其他可运行的Goroutine。
1.7 调度器关键数据结构
Go调度器的核心数据结构维护在运行时（runtime）中，理解这些结构有助于进行底层性能分析：
| 数据结构 | 作用 | 关键字段 |
|---|---|---|
| g | 表示一个Goroutine | stack（栈信息）、goid（唯一ID）、status（状态）、sched（调度上下文） |
| m | 表示一个OS线程 | g0（调度栈）、curg（当前运行的G）、p（绑定的P）、spinning（自旋标志） |
| p | 表示一个逻辑处理器 | runq（本地运行队列，容量256）、runnext（下一个运行的G）、m（绑定的M） |
| schedt | 全局调度器状态 | runq（全局运行队列）、runqsize（队列大小）、pidle（空闲P列表）、midle（空闲M列表） |
trace分析切入点：在Go trace数据中，重点关注
Goroutine等待时间、P的利用率和系统调用阻塞事件。如果大量Goroutine长时间处于_Gwaiting状态，说明Channel或锁竞争严重；如果P频繁处于idle状态，说明Goroutine数量不足或I/O等待占比过高。
1.8 本章小结
- Goroutine是Go并发的基本单元，轻量级、可动态伸缩栈，创建成本极低。
- Channel是Goroutine间通信的首选方式，支持同步（无缓冲）和异步（有缓冲）两种模式。
- MPG模型是Go调度器的核心架构：M（OS线程）执行代码，P（逻辑处理器）管理Goroutine队列，G（Goroutine）是执行体。
- 工作窃取机制保证了多核环境下的负载均衡，是Go调度器高效运行的关键。
- Channel阻塞会触发Goroutine状态切换，调度器借此实现高效的协作式调度。