Go语言并发深度解析：Goroutine、GOMAXPROCS与操作系统线程管理

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.")
}

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.")
}