Go 语言中文件写入阻塞时线程创建行为解析

心靈之曲 2026-01-14 00:00:00 次阅读

go 运行时对短时系统调用（如小文件写入）会复用 os 线程，避免频繁创建销毁；只有当 i/o 操作真正阻塞较长时间（如大文件同步写、磁盘高负载），调度器才会按需扩容 m（os 线程）以维持 g 的并发执行。

在 Go 中，goroutine（G）的阻塞行为与底层 OS 线程（M）的分配并非一一对应。当 goroutine 执行 ioutil.WriteFile 等同步文件 I/O 时，若该操作能快速完成（例如写入几 KB 小文件），系统调用会迅速返回，Go 调度器无需为其额外绑定新线程——原有 M 可立即继续调度其他 G，因此线程数保持稳定（如你实验中仅显示 5 个线程）。

但一旦 I/O 变为真实阻塞（如写入 128MB 大文件），内核层面的 write() 系统调用可能因页缓存压力、磁盘吞吐瓶颈或同步刷盘（fsync）而显著延迟。此时，Go 运行时检测到当前 M 被长期占用，便会启动新的 OS 线程（M）来接管其他就绪的 goroutine，从而体现为线程数激增（如修改后示例达 203 个线程）。

以下是一个可验证阻塞行为的增强版示例（使用 os.File.Write + f.Sync() 强制同步写）：

package main

import (
    "os"
    "runtime"
    "strconv"
    "time"
)

func main() {
    runtime.GOMAXPROCS(2)
    data := make([]byte, 10*1024*1024) // 10MB 数据，增大阻塞概率

    for i := 0; i < 50; i++ {
        go func(n int) {
            filename := "test_sync_" + strconv.Itoa(n) + ".bin"
            for j := 0; j < 3; j++ { // 每个 goroutine 写 3 次
                f, err := os.Create(filename)
                if err != nil {
                    return
                }
                _, _ = f.Write(data)
                f.Sync() // 强制落盘，显著延长阻塞时间
                f.Close()
                time.Sleep(10 * time.Millisecond) // 避免日志刷屏
            }
        }(i)
    }

    // 保持主 goroutine 活跃，便于观察线程数
    select {}
}

⚠️ 注意事项：

ioutil.WriteFile（已弃用，推荐 os.WriteFile）本质是 os.Create + Write + Close，其阻塞程度取决于文件大小、存储介质和内核缓冲策略；
Go 1.14+ 引入了异步抢占与更精细的系统调用封装
，但同步 I/O 仍遵循“阻塞即让出 M”的原则；
线程数不是性能指标，盲目追求高线程数反而增加调度开销；应优先使用 bufio.Writer、批量写入或异步 I/O（如 io_uring via CGO）优化吞吐。