0

0

Go Goroutines与操作系统线程:深度解析GOMAXPROCS与线程创建机制

心靈之曲

心靈之曲

发布时间:2025-07-02 18:42:02

|

777人浏览过

|

来源于php中文网

原创

Go Goroutines与操作系统线程:深度解析GOMAXPROCS与线程创建机制

本文深入探讨Go语言中Goroutine与操作系统线程的关系。阐明Goroutine如何多路复用到少量OS线程上,并详细解释GOMAXPROCS参数如何控制并发执行的Go代码所使用的最大线程数。同时,揭示了在特定阻塞场景下(如系统调用或C函数调用),即使GOMAXPROCS设置较低,Go运行时仍可能创建额外OS线程的机制,以及通道操作、网络I/O等不导致新线程创建的特殊情况。

go语言通过其轻量级的并发原语goroutine,实现了高效的并发编程。goroutine并非直接映射到操作系统线程,而是由go运行时(runtime)调度器进行管理,将大量的goroutine多路复用(multiplexing)到少量底层操作系统(os)线程上。这种m:n的调度模型使得go程序能够以极低的开销创建数以万计的并发任务。然而,理解goroutine如何与os线程交互,以及何时会创建新的os线程,对于编写高性能、高并发的go应用至关重要。

GOMAXPROCS:控制并行度而非线程数

GOMAXPROCS是一个环境变量或通过runtime.GOMAXPROCS()函数设置的参数,它决定了Go程序同时可以并行执行Go代码的OS线程的最大数量。更准确地说,它控制了Go调度器可以同时使用的P(Processor,逻辑处理器)的数量。每个P绑定一个M(Machine,OS线程),而M负责执行G(Goroutine)。

例如,如果GOMAXPROCS设置为1,即使系统有多个CPU核心,Go调度器也只会在一个OS线程上运行Go代码。这意味着,如果一个Goroutine正在执行CPU密集型任务,其他Go代码(包括其他Goroutine)将不得不等待该线程空闲。增加GOMAXPROCS的值可以提高Go程序的并行度,使其能够充分利用多核CPU资源。通常,GOMAXPROCS的默认值等于机器的CPU核心数,这在大多数情况下是最佳实践。

需要强调的是,GOMAXPROCS仅限制了Go调度器用于执行Go代码的线程数量,它并不限制Go程序可以创建的OS线程总数。Go程序在特定情况下,即使GOMAXPROCS设置为1,也可能创建超出此限制的OS线程。

导致额外OS线程创建的阻塞操作

尽管Go调度器能够高效地管理Goroutine,但在某些特定情况下,当一个Goroutine执行阻塞操作时,它会阻塞其所绑定的OS线程。为了不影响其他可运行的Goroutine的执行,Go运行时会采取措施,包括但不限于创建新的OS线程或从线程池中获取空闲线程,以确保GOMAXPROCS所设定的并行度得以维持。这些导致额外OS线程创建的主要场景是:

  1. 系统调用(System Calls): 当Goroutine执行阻塞的系统调用时,例如文件I/O(os.ReadFile)、网络I/O(非Go运行时管理的底层网络操作)、进程创建与等待(exec.Command().Wait())等,底层的OS线程会被操作系统挂起。此时,Go运行时会从该阻塞的OS线程上“解绑”该Goroutine,并将其标记为“系统调用阻塞”。为了继续执行其他可运行的Goroutine,Go调度器可能会启动一个新的OS线程,或者从已有的空闲线程池中选择一个线程,以保持GOMAXPROCS设定的并行度。
  2. C语言函数调用(CGO Calls): 当Go代码通过CGO调用C语言函数,并且该C函数是阻塞的(例如,执行长时间计算或阻塞I/O),Go运行时也会将当前Goroutine从其OS线程上分离,并可能创建或使用新的OS线程来运行其他Go代码。

示例:阻塞系统调用导致的线程增加

以下代码演示了当多个Goroutine同时执行阻塞文件读取(系统调用)时,即使GOMAXPROCS设置为1,也可能观察到OS线程数量的增加:

package main

import (
    "fmt"
    "io/ioutil"
    "os"
    "runtime"
    "sync"
    "time"
)

func main() {
    // 将GOMAXPROCS设置为1,以凸显系统调用对线程数的影响
    runtime.GOMAXPROCS(1)
    fmt.Printf("GOMAXPROCS 已设置为: %d\n", runtime.GOMAXPROCS(-1))

    var wg sync.WaitGroup
    numGoroutines := 10 // 创建10个Goroutine

    fmt.Println("启动执行阻塞文件读取的Goroutine...")

    for i := 0; i < numGoroutines; i++ {
        wg.Add(1)
        go func(id int) {
            defer wg.Done()
            fileName := fmt.Sprintf("temp_file_%d.txt", id)
            // 创建一个临时文件供读取
            err := ioutil.WriteFile(fileName, []byte(fmt.Sprintf("Hello from goroutine %d", id)), 0644)
            if err != nil {
                fmt.Printf("Goroutine %d: 写入文件错误: %v\n", id, err)
                return
            }
            defer os.Remove(fileName) // 确保文件被清理

            fmt.Printf("Goroutine %d: 尝试读取文件 %s\n", id, fileName)
            // ioutil.ReadFile 是一个阻塞的系统调用
            _, err = ioutil.ReadFile(fileName) 
            if err != nil {
                fmt.Printf("Goroutine %d: 读取文件错误: %v\n", id, err)
            } else {
                fmt.Printf("Goroutine %d: 完成读取文件 %s\n", id, fileName)
            }
            // 稍作延迟,给其他Goroutine执行的机会
            time.Sleep(100 * time.Millisecond) 
        }(i)
    }

    // 给予Goroutine启动并可能创建线程的时间
    time.Sleep(2 * time.Second)
    fmt.Println("--------------------------------------------------")
    fmt.Println("请在此处使用 'ps -efL | grep <你的进程名>' 或 'htop -t' 观察OS线程数量。")
    fmt.Println("--------------------------------------------------")

    wg.Wait()
    fmt.Println("所有Goroutine执行完毕。")
}

运行上述代码,并在程序输出提示时,打开另一个终端窗口执行 ps -efL | grep your_go_program_name (Linux/macOS) 或使用 htop -t,你将观察到即使GOMAXPROCS设置为1,Go进程的OS线程数也可能远超1个,因为多个Goroutine同时阻塞在ioutil.ReadFile这个系统调用上。

Narration Box
Narration Box

Narration Box是一种语音生成服务,用户可以创建画外音、旁白、有声读物、音频页面、播客等

下载

不会导致额外OS线程创建的阻塞操作

并非所有阻塞操作都会导致Go运行时创建新的OS线程。Go运行时对一些常见的阻塞原语进行了特殊优化,这些操作在Goroutine阻塞时不会阻塞其底层的OS线程,而是由Go调度器进行异步处理:

  1. 通道操作(Channel Operations): 当Goroutine在通道上发送或接收数据时,如果通道操作是阻塞的(例如,无缓冲通道等待另一端,或有缓冲通道已满/空),Go调度器会将该Goroutine置于等待状态,但会立即将底层的OS线程释放,使其可以执行其他可运行的Goroutine。
  2. 网络操作(Network Operations): Go语言内置的网络库(net包)使用了非阻塞I/O和网络轮询器(netpoller,如Linux上的epoll,macOS/BSD上的kqueue)。当Goroutine等待网络数据时,它不会阻塞OS线程;而是由网络轮询器负责监听I/O事件,并在事件就绪时唤醒相应的Goroutine。
  3. 睡眠(Sleeping): time.Sleep()函数由Go调度器管理。当Goroutine调用time.Sleep()时,它会被调度器挂起,但其绑定的OS线程会立即释放,用于执行其他Goroutine。
  4. sync 包中的并发原语: sync包中的所有同步原语,如sync.Mutex、sync.WaitGroup、sync.Cond等,都是由Go调度器内部实现的。当Goroutine因这些原语而阻塞时,它们不会导致底层OS线程的阻塞,而是由调度器进行高效的Goroutine上下文切换。

示例:Go运行时管理的阻塞操作

原始问题中提供的Vector.DoSome函数是一个很好的例子:

type Vector []float64

// Apply the operation to n elements of v starting at i.
func (v Vector) DoSome(i, n int, u Vector, c chan int) {
    for ; i < n; i++ {
        v[i] += u.Op(v[i]) // CPU密集型计算
    }
    c <- 1;    // signal that this piece is done (通道操作)
}

在这个函数中,v[i] += u.Op(v[i]) 是一个CPU密集型操作。当多个Goroutine执行此操作时,GOMAXPROCS将直接决定并行执行的Goroutine数量。而c

总结与注意事项

  • Goroutine与OS线程的关系: Goroutine是Go运行时管理的轻量级并发单元,它们多路复用到少数OS线程上执行。
  • GOMAXPROCS的作用: 它控制了Go程序可以并行执行Go代码的OS线程(即逻辑处理器P)的最大数量,主要影响CPU密集型任务的并行度。
  • 额外线程的创建: 当Goroutine执行阻塞的系统调用(如文件I/O、exec)或CGO调用时,即使GOMAXPROCS设置较低,Go运行时为了维持并行度,也可能创建额外的OS线程。
  • 不创建额外线程的阻塞: Go运行时对通道操作、网络I/O、time.Sleep以及sync包中的同步原语进行了优化,这些操作在阻塞时不会导致新的OS线程被创建,而是由Go调度器进行高效的Goroutine调度。

在设计高并发Go应用时,理解这些机制至关重要。尽量利用Go运行时优化的并发原语,避免在Goroutine中直接执行大量阻塞的系统调用,尤其是在GOMAXPROCS设置较低的情况下,以防止创建过多OS线程,从而增加上下文切换开销,影响程序性能。如果必须进行阻塞系统调用,应合理设计并发模型,例如使用有限的Goroutine池来执行这些操作,以控制OS线程的数量。

相关专题

更多
C语言变量命名
C语言变量命名

c语言变量名规则是:1、变量名以英文字母开头;2、变量名中的字母是区分大小写的;3、变量名不能是关键字;4、变量名中不能包含空格、标点符号和类型说明符。php中文网还提供c语言变量的相关下载、相关课程等内容,供大家免费下载使用。

379

2023.06.20

c语言入门自学零基础
c语言入门自学零基础

C语言是当代人学习及生活中的必备基础知识,应用十分广泛,本专题为大家c语言入门自学零基础的相关文章,以及相关课程,感兴趣的朋友千万不要错过了。

608

2023.07.25

c语言运算符的优先级顺序
c语言运算符的优先级顺序

c语言运算符的优先级顺序是括号运算符 > 一元运算符 > 算术运算符 > 移位运算符 > 关系运算符 > 位运算符 > 逻辑运算符 > 赋值运算符 > 逗号运算符。本专题为大家提供c语言运算符相关的各种文章、以及下载和课程。

348

2023.08.02

c语言数据结构
c语言数据结构

数据结构是指将数据按照一定的方式组织和存储的方法。它是计算机科学中的重要概念,用来描述和解决实际问题中的数据组织和处理问题。数据结构可以分为线性结构和非线性结构。线性结构包括数组、链表、堆栈和队列等,而非线性结构包括树和图等。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

255

2023.08.09

c语言random函数用法
c语言random函数用法

c语言random函数用法:1、random.random,随机生成(0,1)之间的浮点数;2、random.randint,随机生成在范围之内的整数,两个参数分别表示上限和下限;3、random.randrange,在指定范围内,按指定基数递增的集合中获得一个随机数;4、random.choice,从序列中随机抽选一个数;5、random.shuffle,随机排序。

583

2023.09.05

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

519

2023.09.20

c语言get函数的用法
c语言get函数的用法

get函数是一个用于从输入流中获取字符的函数。可以从键盘、文件或其他输入设备中读取字符,并将其存储在指定的变量中。本文介绍了get函数的用法以及一些相关的注意事项。希望这篇文章能够帮助你更好地理解和使用get函数 。

631

2023.09.20

c数组初始化的方法
c数组初始化的方法

c语言数组初始化的方法有直接赋值法、不完全初始化法、省略数组长度法和二维数组初始化法。详细介绍:1、直接赋值法,这种方法可以直接将数组的值进行初始化;2、不完全初始化法,。这种方法可以在一定程度上节省内存空间;3、省略数组长度法,这种方法可以让编译器自动计算数组的长度;4、二维数组初始化法等等。

595

2023.09.22

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

7

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL 教程
PostgreSQL 教程

共48课时 | 6.3万人学习

Git 教程
Git 教程

共21课时 | 2.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号