Goroutine、操作系统线程和CPU的管理

【译文】原文地址
本文是基于Go 1.13版本
创建一个操作系统线程或从一个线程切换到另一个线程,对程序来说在内存和性能方面是代价很大的。Go为了充分利用cpu核的优势,在一开始就考虑了并发性。

M, P, G组合

为了解决性能问题,Go有自己的调度器来分配goroutine到线程上去。该调度器定义了三个主要概念,就如代码中所表示的:
G-指的是goroutine
M-工作线程,或者机器
P-处理器,执行代码需要的资源。M必须有相应的P才能运行代码。
如下是M, P, G模型图:


M, P, G模型图

每个goroutine(G)运行在一个OS线程上,这个线程会被分配到一个逻辑CPU(P)。通过一个例子来看下Go如何管理它们的:

package main

import "sync"

func main() {
    var wg sync.WaitGroup
    wg.Add(2)
    go func() {
        println(`hello`)
        wg.Done()
    }()
    go func() {
        println(`world`)
        wg.Done()
    }()
    wg.Wait()
}

Go首先将根据机器的逻辑cpu个数来创建不同的P,并存放在一个空闲的P列表中:


P初始化

然后,新的一个goroutine或多个goroutine将唤醒P来更好的分配工作。这个P将创建一个与操作系统线程相关的M:


OS Thread的创建

然而,空闲的P和M-即没有等待执行的goroutine,从系统调用中返回或甚至被垃圾收集器强制停止,将进入空闲队列中:
M, P空闲队列

在程序的启动过程中,Go已经创建了一些OS线程和相关的M。在以上例子中,第一个输出hello的goroutine将使用main goroutine,而第二个goroutine将从空闲列表中获取一个M和P:


从空闲列表获取M和P

以上我们看到了goroutine和线程的管理,下面看下在什么情况下Go会使用更多的M而不是P以及在系统调用下goroutine是如何管理的。

系统调用

Go优化系统调用的方法是通过在运行时对其进行包装,无论系统调用是否阻塞。这个包装器将自动将P和线程M分离,并允许其他线程在其上运行。让我们举一个读取文件的例子:

package main

import (
    "os"
)

func main() {
    buf := make([]byte, 0, 2)

    fd, _ := os.Open("main.go")
    fd.Read(buf)
    fd.Close()

    println(string(buf)) // 42
}

下面是文件打开的工作流程:


系统调用线程交出P

P0进入空闲队列,可供其他线程使用。一旦系统调用退出,Go将应用如下满足条件的规则:

  • 尝试获取对应的P,本例中的p0,并继续执行。
  • 尝试从空闲列表中获取一个新的P,恢复执行。
  • 将正在执行的goroutine放入全局队列,并将对于的M放回空闲队列。
    然而,Go也可以处理资源尚未就绪的情况,比如http调用这种非阻塞I/O情况。在这种情况下,第一个系统调用(遵循前面的共工作流程)因为资源未就绪将调用不成功,迫使Go使用网络轮询并使goroutine驻留。
func main() {
   http.Get(`https://httpstat.us/200`)
}

一旦第一个系统调用完成并显示资源未就绪,对应的goroutine就会驻留,直到网络轮询通知资源就绪。在这种情况下,线程M将不会被阻塞:


网络轮询等待资源就绪

当Go调度器寻找工作时,对应的goroutine将再次运行。然后调度器将询问网络轮询器,是否有等待就绪的gorotine需要执行。



如果就绪的goroutine不止一个的话,多出的goroutine将进入全局可执行队列等待调度。

操作系统线程约束

当使用系统调用时,Go不限制被阻塞的操作系统线程数量,如下所述:
GOMAXPROCS变量限制了能够同时执行用户态Go代码的操作系统线程数量。但并没有对Go代码中处于阻塞状态下系统调用的线程数量有限制。这些系统调用线程数量不会受影响。
以下就是这种情况的一个例子:

package main

import (
    "fmt"
    "net/http"
    "sync"
)

func main() {
        var wg sync.WaitGroup

        for i := 0;i < 100 ;i++  {
            wg.Add(1)

            go func(i int) {
                http.Get(`https://www.baidu.com`)
                fmt.Println(i)
                wg.Done()
            }(i)
        }

        wg.Wait()
    }

如下是跟踪工具查看到的线程个数:


image.png

因为Go优化了线程的使用,当goroutine被阻塞时线程会被复用,这就解释了为什么这个线程数和循环数量不一致。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,658评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,482评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,213评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,395评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,487评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,523评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,525评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,300评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,753评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,048评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,223评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,905评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,541评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,168评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,417评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,094评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,088评论 2 352

推荐阅读更多精彩内容