1. Go并发模型概览
Go语言以其内置的并发原语而闻名，其中Goroutine是其核心。Goroutine是Go运行时（Go Runtime）管理的轻量级执行单元，其创建和销毁的开销远低于传统操作系统线程。Go调度器采用M:N模型，将M个Goroutine高效地映射到N个操作系统线程上（通常也被称为P/M/G模型，其中P代表Processor，M代表Machine/OS Thread，G代表Goroutine）。这意味着多个Goroutine可以共享少数OS线程。当一个Goroutine因某种原因阻塞时，Go调度器能够迅速将其从当前OS线程上“摘下”，并调度其他可运行的Goroutine到该OS线程上，从而实现了高并发和资源的高效利用。
2. GOMAXPROCS的作用
GOMAXPROCS是一个重要的环境变量或通过runtime.GOMAXPROCS函数设置的参数，它决定了Go程序同时并行执行Go代码的操作系统线程的最大数量。
例如，如果将GOMAXPROCS设置为4，Go运行时将最多使用4个OS线程来并发执行纯Go代码。这意味着在任何给定时刻，最多有4个Goroutine可以真正地并行计算。GOMAXPROCS的默认值通常设置为CPU核心数，以充分利用多核处理器的性能。调整GOMAXPROCS可以影响Go程序的并发度，但并非越高越好，过高的值可能导致不必要的上下文切换开销，反而降低性能。
3. Goroutine阻塞时的线程行为
尽管GOMAXPROCS限制了并行执行Go代码的线程数，但程序实际使用的OS线程数量可能会超过这个值。这主要取决于Goroutine执行的操作类型，特别是当Goroutine被阻塞时，其对底层OS线程的占用情况会有所不同。
立即学习“go语言免费学习笔记（深入）”；
3.1 不占用OS线程的阻塞操作
Go运行时能够识别并管理某些类型的阻塞操作。当Goroutine在执行这些操作时被阻塞，Go调度器会将其从当前OS线程上“摘下”，并调度其他可运行的Goroutine到该OS线程上。因此，这些阻塞操作不会导致额外的OS线程被创建或占用。这类操作包括：
- 通道（Channel）操作：当Goroutine尝试向已满的通道发送数据或从空通道接收数据时，会被阻塞。
- 网络I/O操作：Go的net包中的大部分网络操作（如net.Dial、conn.Read、conn.Write）在底层通过网络轮询器（如epoll、kqueue）实现，是非阻塞的。
- 计时器（Timer）和睡眠（time.Sleep）：Goroutine会等待指定时间。
- sync包中的同步原语：例如sync.Mutex、sync.WaitGroup、sync.Cond等。
示例：Go运行时管理的阻塞
package main
import (
"fmt"
"runtime"
"time"
)
func main() {
runtime.GOMAXPROCS(1) // 限制Go代码并行执行的OS线程为1
fmt.Printf("GOMAXPROCS: %d\n", runtime.GOMAXPROCS(0))
fmt.Printf("Initial active goroutines: %d\n", runtime.NumGoroutine()) // 粗略指示活跃Goroutine数
// Goroutine 1: 阻塞在通道操作上
ch := make(chan struct{})
go func() {
fmt.Println("Goroutine 1: Waiting on channel...")
<-ch // 阻塞，等待通道关闭或接收数据
fmt.Println("Goroutine 1: Resumed from channel.")
}()
// Goroutine 2: 阻塞在time.Sleep上
go func() {
fmt.Println("Goroutine 2: Sleeping...")
time.Sleep(2 * time.Second) // 阻塞，等待时间流逝
fmt.Println("Goroutine 2: Woke up from sleep.")
}()
// 确保Goroutine 1和2有时间启动并阻塞
time.Sleep(100 * time.Millisecond)
fmt.Println("Main: After starting blocking goroutines (channel, sleep).")
// 此时，即使GOMAXPROCS=1，Go运行时也能在单个OS线程上调度其他Goroutine，
// 因为这些阻塞是Go运行时可管理的，不会导致额外OS线程的创建。
close(ch) // 解除Goroutine 1的阻塞
time.Sleep(3 * time.Second) // 等待所有Goroutine完成
fmt.Println("Main: All goroutines finished.")
}在上述示例中，尽管GOMAXPROCS被设置为1，但Goroutine 1和2的阻塞并不会导致额外的OS线程被创建。Go调度器会在它们阻塞时，将底层OS线程用于执行其他Go代码（例如main函数中的time.Sleep）。
3.2 占用OS线程的阻塞操作
当Goroutine执行的阻塞操作是Go运行时无法直接控制的底层系统调用（System Call）或Cgo调用时，情况则不同。这些操作会直接阻塞底层的OS线程，Go调度器无法在不解除该OS线程阻塞的情况下将其用于执行其他Goroutine。为了避免整个Go程序因此停滞，Go运行时会为这些阻塞的Goroutine创建或绑定额外的OS线程。
- 系统调用（System Calls）：例如，直接进行阻塞式的文件I/O操作（如读取/dev/ttyxx，或在某些操作系统上使用os.File.Read、os.File.Write进行阻塞I/O），以及等待外部进程完成（如exec.Command().Wait()）。
- Cgo调用：当Go代码调用C语言函数，并且该C函数内部执行了阻塞操作时。
示例：阻塞系统调用导致额外OS线程
package main
import (
"fmt"
"os/exec"
"runtime"
"time"
)
func main() {
runtime.GOMAXPROCS(1) // 限制Go代码并行执行的OS线程为1
fmt.Printf("GOMAXPROCS: %d\n", runtime.GOMAXPROCS(0))
fmt.Printf("Initial active goroutines: %d\n", runtime.NumGoroutine())
// Goroutine 1: 执行一个阻塞的系统调用 (例如，运行一个外部命令并等待其完成)
go func() {
fmt.Println("Goroutine 1: Starting blocking system call (sleep 5s)...")
cmd := exec.Command("sleep", "5") // 这是一个阻塞的系统调用
err := cmd.Run() // 阻塞直到外部命令完成
if err != nil {
fmt.Printf("Goroutine 1: Command failed: %v\n", err)
}
fmt.Println("Goroutine 1: System call finished.")
}()
// Goroutine 2: 执行一些非阻塞的Go代码
go func() {
for i := 0; i < 3; i++ {
fmt.Printf("Goroutine 2: Running non-blocking task %d...\n", i)
time.Sleep(500 * time.Millisecond) // 这里的sleep是Go运行时管理的，不会阻塞OS线程
}
fmt.Println("Goroutine 2: Non-blocking task finished.")
}()
fmt.Println("Main: After starting goroutines.")
// 由于Goroutine 1执行了阻塞的系统调用，Go运行时会为此绑定一个额外的OS线程，
// 使得Goroutine 2和Main Goroutine可以在GOMAXPROCS所管理的OS线程上继续执行。
time.Sleep(6 * time.Second) // 等待所有Goroutine完成
fmt.Println("Main: All goroutines finished.")
}在这个例子中，即使GOMAXPROCS=1，当Goroutine 1执行exec.Command("sleep", "5").Run()这个阻塞的系统调用时，Go运行时会为其分配一个独立的OS线程。这样，Goroutine 2仍然可以在GOMAXPROCS所管理的OS线程上继续执行其非阻塞任务，而不会被Goroutine 1的阻塞所影响。最终，系统使用的OS线程数将是GOMAXPROCS设定的数量（至少1个）加上执行阻塞系统调用或Cgo调用的Goroutine数量。
4. 总结与注意事项
- 线程数量的估算：Go程序运行时创建的OS线程数，通常是GOMAXPROCS的值（或至少1个，因为至少需要一个线程来运行Go调度器和Go代码），加上当前所有执行阻塞系统调用或Cgo调用的Goroutine数量。
-
性能考量：
- 避免不必要的阻塞系统调用：如果可能，应优先使用Go标准库提供的非阻塞I/O操作。例如，Go的网络I/O是异步的，但某些文件I/O操作（如`os.File
