Go语言的GPM调度器是什么？

😋我是平也，这有一个专一Gopher技术成长的开源项目「go home」

导读

相信不少人都据说过Go语言自然支持高并发，缘由是内部有协程（goroutine）加持，能够在一个进程中启动成千上万个协程。那么，它凭什么作到如此高的并发呢？那就须要先了解什么是并发模型。

并发模型

著名的C++专家Herb Sutter曾经说过“免费的午饭已经终结”。为了让代码运行的更快，单纯依靠更快的硬件已经没法获得知足，咱们须要利用多核来挖掘并行的价值，而并发模型的目的就是来告诉你不一样执行实体之间是如何协做的。

固然，不一样的并发模型的协做方式也不尽相同，常见的并发模型有七种：

• 线程与锁
• 函数式编程
• Clojure之道
• actor
• 通信顺序进程（CSP）
• 数据级并行
• Lambda架构

而今天，咱们只讲与Go语言相关的并发模型CSP，感兴趣的同窗能够自行查阅书籍《七周七并发模型》。

CSP篇

CSP，全称Communicating Sequential Processes，意为通信顺序进程，它是七大并发模型中的一种，它的核心观念是将两个并发执行的实体经过通道channel链接起来，全部的消息都经过channel传输。其实CSP概念早在1978年就被东尼·霍尔提出，因为近来Go语言的兴起，CSP又火了起来。

那么CSP与Go语言有什么关系呢？接下来咱们来看Go语言对CSP并发模型的实现——GPM调度模型。

GPM调度模型

GPM表明了三个角色，分别是Goroutine、Processor、Machine。

• Goroutine：就是我们经常使用的用go关键字建立的执行体，它对应一个结构体g，结构体里保存了goroutine的堆栈信息
• Machine：表示操做系统的线程
• Processor：表示处理器，有了它才能创建G、M的联系

Goroutine

Goroutine就是代码中使用go关键词建立的执行单元，也是你们熟知的有“轻量级线程”之称的协程，协程是不为操做系统所知的，它由编程语言层面实现，上下文切换不须要通过内核态，再加上协程占用的内存空间极小，因此有着很是大的发展潜力。

go func() {}()
复制代码

在Go语言中，Goroutine由一个名为runtime.go的结构体表示，该结构体很是复杂，有40多个成员变量，主要存储执行栈、状态、当前占用的线程、调度相关的数据。还有玩你们很想获取的goroutine标识，可是很抱歉，官方考虑到Go语言的发展，设置成私有了，不给你调用😏。

type g struct {
	stack struct {
		lo uintptr
		hi uintptr
	} 							// 栈内存：[stack.lo, stack.hi)
	stackguard0	uintptr
	stackguard1 uintptr

	_panic       *_panic
	_defer       *_defer
	m            *m				// 当前的 m
	sched        gobuf
	stktopsp     uintptr		// 指望 sp 位于栈顶，用于回溯检查
	param        unsafe.Pointer // wakeup 唤醒时候传递的参数
	atomicstatus uint32
	goid         int64
	preempt      bool       	// 抢占信号，stackguard0 = stackpreempt 的副本
	timer        *timer         // 为 time.Sleep 缓存的计时器

	...
}
复制代码

Goroutine调度相关的数据存储在sched，在协程切换、恢复上下文的时候用到。

type gobuf struct {
	sp   uintptr
	pc   uintptr
	g    guintptr
	ret  sys.Uintreg
	...
}
复制代码

Machine

M就是对应操做系统的线程，最多会有GOMAXPROCS个活跃线程可以正常运行，默认状况下GOMAXPROCS被设置为内核数，假若有四个内核，那么默认就建立四个线程，每个线程对应一个runtime.m结构体。线程数等于CPU个数的缘由是，每一个线程分配到一个CPU上就不至于出现线程的上下文切换，能够保证系统开销降到最低。

type m struct {
	g0   *g 
	curg *g
	...
}
复制代码

M里面存了两个比较重要的东西，一个是g0，一个是curg。

• g0：会深度参与运行时的调度过程，好比goroutine的建立、内存分配等
• curg：表明当前正在线程上执行的goroutine。

刚才说P是负责M与G的关联，因此M里面还要存储与P相关的数据。

type m struct {
  ...
	p             puintptr
	nextp         puintptr
	oldp          puintptr
}
复制代码

• p：正在运行代码的处理器
• nextp：暂存的处理器
• old：系统调用以前的线程的处理器

Processor

Proccessor负责Machine与Goroutine的链接，它能提供线程须要的上下文环境，也能分配G到它应该去的线程上执行，有了它，每一个G都能获得合理的调用，每一个线程都再也不浑水摸鱼，真是居家必备之良品。

一样的，处理器的数量也是默认按照GOMAXPROCS来设置的，与线程的数量一一对应。

type p struct {
	m           muintptr

	runqhead uint32
	runqtail uint32
	runq     [256]guintptr
	runnext guintptr
	...
}
复制代码

结构体P中存储了性能追踪、垃圾回收、计时器等相关的字段外，还存储了处理器的待运行队列，队列中存储的是待执行的Goroutine列表。

三者的关系

首先，默认启动四个线程四个处理器，而后互相绑定。

这个时候，一个Goroutine结构体被建立，在进行函数体地址、参数起始地址、参数长度等信息以及调度相关属性更新以后，它就要进到一个处理器的队列等待发车。

啥，又建立了一个G？那就轮流往其余P里面放呗，相信你排队取号的时候看到其余窗口没人排队也会过去的。

假若有不少G，都塞满了怎么办呢？那就不把G塞处处理器的私有队列里了，而是把它塞到全局队列里（候车大厅）。

除了往里塞以外，M这边还要疯狂往外取，首先去处理器的私有队列里取G执行，若是取完的话就去全局队列取，若是全局队列里也没有的话，就去其余处理器队列里偷，哇，这么饥渴，简直是恶魔啊！

若是哪里都没找到要执行的G呢？那M就会由于太失望和P断开关系，而后去睡觉（idle）了。

那若是两个Goroutine正在经过channel作一些恩恩爱爱的事阻塞住了怎么办，难道M要等他们完事了再继续执行？显然不会，M并不稀罕这对Go男女，而会转身去找别的G执行。

系统调用

若是G进行了系统调用syscall，M也会跟着进入系统调用状态，那么这个P留在这里就浪费了，怎么办呢？这点精妙之处在于，P不会傻傻的等待G和M系统调用完成，而会去找其余比较闲的M执行其余的G。

当G完成了系统调用，由于要继续往下执行，因此必需要再找一个空闲的处理器发车。

若是没有空闲的处理器了，那就只能把G放回全局队列当中等待分配。

sysmon

sysmon是咱们的保洁阿姨，它是一个M，又叫监控线程，不须要P就能够独立运行，每20us~10ms会被唤醒一次出来打扫卫生，主要工做就是回收垃圾、回收长时间系统调度阻塞的P、向长时间运行的G发出抢占调度等等。

词条解释

东尼·霍尔

东尼·霍尔，英国计算机科学家，图灵奖得主，他设计了牛气冲天的快速排序算法、霍尔逻辑以及CSP模型。2011年获颁约翰·冯诺依曼奖。

---

感谢你们的观看，若是以为文章对你有所帮助，欢迎关注公众号「平也」，聚焦Go语言与技术原理。