前言
首先有一个概念, 并发和并行
多线程程序在单核上运行,就是并发;
多线程程序在多核上运行,就是并行;
golang的并发, 是通过goroutine来实现的 , 采用了基于消息并发模型的方式 . 一个go关键字就可以轻易地启动一个Goroutine,而且在Goroutine之间是共享内存的。
不要以共享内存的方式来通信,相反,要通过通信来共享内存。
MPG
-
M指的是Machine,一个M直接关联了一个内核线程。
-
P指的是”processor”,代表了M所需的上下文环境,也是处理用户级代码逻辑的处理器。
-
G指的是Goroutine,其实本质上也是一种轻量级的线程。
GMP调度就是循环在与P(处理器)绑定的M(系统线程)上寻找可执行的G(协程)
在当前P(处理器)上创建G(groutine)后 , 会把G放入P的本地队列或者全局队列 , 本地队列限制256个 , 满了就放全局队列
在当前P(处理器)创建或者唤醒M(系统线程) , 去事件循环执行G(groutine)
在当前P(处理器)上如果全局/本地队列为空 , 会去从别的处理器上窃取一半的G拿来执行
限制
- P 的数量受环境变量 GOMAXPROCS 的直接影响 , 一般设置为当前机器的内核数
- M 的数量默认限制是10000 , 超出会报错
- G 的数量一般没有限制 ,理论上受内存影响