深入解析go语言 go语言解释器( 三 )


除了每个P维护的G队列以外,还有一个全局的队列 , 每个P会周期性地查看全局队列中是否有G待运行并将其调度到M中执行,全局队列中G的来源 , 主要有从系统调用中恢复的G 。之所以P会周期性地查看全局队列 , 也是为了防止全局队列中的G被饿死 。
M0
M0是启动程序后的编号为0的主线程,这个M对应的实例会在全局变量rutime.m0中,不需要在heap上分配,M0负责执行初始化操作和启动第一个G,在之后M0就和其他的M一样了
G0
G0是每次启动一个M都会第一个创建的goroutine,G0仅用于负责调度G,G0不指向任何可执行的函数,每个M都会有一个自己的G0,在调度或系统调用时会使用G0的栈空间,全局变量的G0是M0的G0
一个G由于调度被中断,此后如何恢复?
中断的时候将寄存器里的栈信息,保存到自己的G对象里面 。当再次轮到自己执行时,将自己保存的栈信息复制到寄存器里面 , 这样就接着上次之后运行了 。
我这里只是根据自己的理解进行了简单的介绍 , 想要详细了解有关GMP的底层原理可以去看Go调度器 G-P-M 模型的设计者的文档或直接看源码
参考:()
()
Golang 语言深入理解:channel 本文是对 Gopher 2017 中一个非常好的 Talk?: [Understanding Channel](GopherCon 2017: Kavya Joshi - Understanding Channels) 的学习笔记深入解析go语言,希望能够通过对 channel 的关键特性的理解深入解析go语言,进一步掌握其用法细节以及 Golang 语言设计哲学的管窥蠡测 。
channel是可以让一个 goroutine 发送特定值到另一个 gouroutine 的通信机制 。
【深入解析go语言 go语言解释器】 原生的 channel 是没有缓存的(unbuffered channel)深入解析go语言,可以用于 goroutine 之间实现同步 。
关闭后不能再写入,可以读取直到 channel 中再没有数据,并返回元素类型的零值 。
gopl/ch3/netcat3
首先从 channel 是怎么被创建的开始:
在 heap 上分配一个 hchan 类型的对象,并将其初始化,然后返回一个指向这个 hchan 对象的指针 。
理解了 channel 的数据结构实现,现在转到 channel 的两个最基本方法:sends和receivces,看一下以上的特性是如何体现在sends和receives中的:
假设发送方先启动,执行 ch - task0 :
如此为 channel 带来了goroutine-safe 的特性 。
在这样的模型里 ,  sender goroutine - channel - receiver goroutine之间,hchan 是唯一的共享内存,而这个唯一的共享内存又通过 mutex 来确保 goroutine-safe,所有在队列中的内容都只是副本 。
这便是著名的 golang 并发原则的体现:
发送方 goroutine 会阻塞 , 暂停 , 并在收到 receive 后才恢复 。
goroutine 是一种 用户态线程 , 由 Go runtime 创建并管理,而不是操作系统,比起操作系统线程来说,goroutine更加轻量 。
Go runtime scheduler 负责将 goroutine 调度到操作系统线程上 。
runtime scheduler 怎么将 goroutine 调度到操作系统线程上?
当阻塞发生时,一次 goroutine 上下文切换的全过程:
然而 , 被阻塞的 goroutine 怎么恢复过来?
阻塞发生时,调用 runtime sheduler 执行 gopark 之前,G1 会创建一个 sudog,并将它存放在 hchan 的 sendq 中 。sudog 中便记录了即将被阻塞的 goroutineG1 ,以及它要发送的数据元素 task4 等等 。
接收方 将通过这个 sudog 来恢复 G1
接收方 G2 接收数据, 并发出一个 receivce ,将 G1 置为runnable :
同样的, 接收方 G2 会被阻塞,G2 会创建 sudoq ,存放在 recvq,基本过程和发送方阻塞一样 。

推荐阅读