zl程序教程

您现在的位置是:首页 >  后端

当前栏目

Go调度器: M,P和G

Go 调度
2023-09-27 14:21:19 时间

这是另一篇关于Go调度器(scheduler)的文章。 原文: GO SCHEDULER: MS, PS GS by Uber工程师 Povilas。

网上已经有很多关于Go调度器的文章了, 比如 Golang调度器源码分析 ,多看一些,可以加深记忆,也可以对比查看文章中是否有不准确的地方,更全面的了解Go的调度器。

我决定深入了解Go的内部机制, 因为很长时间没人写关于Go scheduler的文章了, 我觉得这是一个很有趣的知识点,所以让我们开始吧。

基础知识

Go的运行时管理着调度、垃圾回收以及goroutine的运行环境。本文只关注于调度器。

运行时负责运行goroutine并把它们影射到操作系统的线程上。goroutine比线程还轻量, 启动的时候花费很少。每个goroutine都是由一个 G 结构来表示,

这个结构体的字段用来跟踪此goroutine的栈(stack)和状态,所以你可以认为 G = goroutine 。

运行时管理着 G 并把它们映射到 Logical Processor (称之为 P ). P 可以看作是一个抽象的资源或者一个上下文,它需要获取以便操作系统线程(称之为 M )可以运行 G 。

通过 runtime.GOMAXPROCS (numLogicalProcessors) 可以控制多少 P 可以获取。如果你需要调整这个参数(大部分情况下你无需调整), 只设置一次, 因为它需要 STW gc pause。

本质上,操作系统运行线程,线程运行你的代码。Go的技巧是编译器会在Go运行时的一些地方插入系统调用, (比如通过channel发送值,调用runtime包等),所以Go可以通知调度器执行特定的操作。

Go调度器: M,P和G

上图的理解来自 Analysis of the Go runtime scheduler

M、P 和 G 之间的交互

M、 P 和 G 之间的交互有点复杂。看看下面这张来自 Gao Chao的 go runtime scheduler 幻灯片中的一张图:

Go调度器: M,P和G

可以看到,Go运行时存在两种类型的queue: 一种是一个全局的queue(在 schedt结构体中 ,很少用到), 一种是每个 P 都维护自己的 G 的queue。

为了运行goroutine, M 需要持有上下文 P 。 M 会从 P 的queue弹出一个goroutine并执行。

当你创建一个新的goroutine的时候( go func() 方法),它会被放入 P 的queue。当然还有一个 work-stealing 调度算法,当 M 执行了一些 G 后,如果它的queue为空,它会随机的选择另外一个 P ,从它的queue中取走一半的 G 到自己的queue中执行。(偷!)

当你的goroutine执行阻塞的系统调用的时候(syscall),阻塞的系统调用会中断(intercepted),如果当前有一些 G 在执行,运行时会把这个线程从 P 中摘除(detach),然后再创建一个新的操作系统的线程(如果没有空闲的线程可用的话)来服务于这个 P 。

当系统调用继续的时候,这个goroutine被放入到本地运行queue,线程会 park 它自己(休眠), 加入到空闲线程中。

如果一个goroutine执行网络调用,运行时会做类似的动作。调用会被中断,但是由于Go使用集成的network poller,它有自己的线程,所以还给它。

Go运行时会在下面的goroutine被阻塞的情况下运行另外一个goroutine:

blocking syscall (for example opening a file), network input, channel operations, primitives in the sync package.

调度器跟踪调试

Go可以跟踪运行时的调度器,这是通过 GODEBUG 环境变量实现的:


$ GODEBUG=scheddetail=1,schedtrace=1000 ./program 

下面是输出的例子:


SCHED 0ms: gomaxprocs=8 idleprocs=7 threads=2 spinningthreads=0 idlethreads=0 runqueue=0 gcwaiting=0 nmidlelocked=0 stopwait=0 sysmonwait=0    P0: status=1 schedtick=0 syscalltick=0 m=0 runqsize=0 gfreecnt=0    P1: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P2: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P3: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P4: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P5: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P6: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    P7: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0    M1: p=-1 curg=-1 mallocing=0 throwing=0 preemptoff= locks=1 dying=0 helpgc=0 spinning=false blocked=false lockedg=-1    M0: p=0 curg=1 mallocing=0 throwing=0 preemptoff= locks=1 dying=0 helpgc=0 spinning=false blocked=false lockedg=1    G1: status=8() m=0 lockedm=0 

注意输出使用了 G 、 M 和 P 的概念以及她们的状态, 比如 P 的queue的大小。 如果你不想关心这些细节,你可以使用:


$ GODEBUG=schedtrace=1000 ./program 

William Kennedy写了一篇很好的 文章 , 解释了这些细节。

当然,还有一个go自己的工具 go tool trace , 它有一个UI, 允许你查看你的程序和运行时的状况。你可以阅读这篇文章: Pusher 。


作者:佚名

来源:51CTO


Go语言的GPM调度器是什么? 云栖号资讯:【点击查看更多行业资讯】在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! 相信很多人都听说过Go语言天然支持高并发,原因是内部有协程(goroutine)加持,可以在一个进程中启动成千上万个协程。
GO语言-12了解Go语言的终端输出、进制转换 GO语言的学习与记录,第十二篇了解Go的终端输出、进制转换,介绍fmt包下的三种常用输出以及区别,给出格式化输出的常用占位符,以及各种进制转换。
GO语言-11Go语言的I/O操作 GO语言的学习与记录,第十一篇了解Go语言的I/O操作,学习Go语言中两种打开文件的方式,一种是默认只读,另外一种是以权限的方式打开文件,并对文件的读写基本操作进行介绍入门
GO语言-10了解Go并发中锁的概念和使用(下) GO语言的学习与记录,10了解Go并发中锁的概念和使用(下),学习锁的概念,为什么需要锁;使用互斥锁解决临界区资源的问题
GO语言-10了解Go并发的使用(上) GO语言的学习与记录,第十篇了解Go语言并发的使用(上),围绕的使用go关键字开启协程,学习协程之间数据传输,了解阻塞式通道和非阻塞式通道,学习如何取通道的值还有怎么遍历通道。最后两个案例助于理解。
GO语言-09通过例子了解通过反射进行实例化 GO语言的学习与记录,第九篇:通过一个例子了解通过反射进行实例化。内容用到了接口、结构体和JSON互转、反射的类型和实例化的内容
GO语言-07派生类型:结构体和方法(下) 自己学习Go语言学习过程中的记录与总结,希望对你能有帮助。 第七篇(下):学习Go语言的结构体与方法的结合使用,了解指针,值传递,地址传递,变量作用域范围的概念
GO语言-07派生类型:map和结构体(上) 自己学习Go语言学习过程中的记录与总结,希望对你能有帮助。 第七篇(上):学习Go语言的Map,以及使用type定义自己的类型,包括type+struct定义结构体
GO语言-06数据类型 自己学习Go语言学习过程中的记录与总结,希望对你能有帮助。 第六篇:学习Go语言的数据类型分为基本类型和派生类型;了解使用new和make分配内存的方式。