当前位置: 首页 > news >正文

Golang的协程调度器GMP

目录

GMP 含义

设计策略

全局队列

P的本地队列

GMP模型以及场景过程 

场景一

场景2 

场景三

场景四

场景五

场景六


GMP 含义

协程调度器,它包含了运行协程的资源,如果线程想运行协程,必须先获取P,P中还包含了可运行的G队列。以P 为主体 运行调度逻辑

设计策略

复用线程:避免频繁的创建、销毁线程,而是对线程的复用。

1 work stealing机制

        当本线程无可运行的G时,尝试从其他线程绑定的P偷取G,而不是销毁线程。

2 hand off机制

        当本线程因为G进行系统调用阻塞时,线程释放绑定的P,把P转移给其他空闲的线程执行。

利用并行:

GOMAXPROCS设置P的数量,最多有GOMAXPROCS个线程分布在多个CPU上同时运行。GOMAXPROCS也限制了并发的程度,

比如GOMAXPROCS = 核数/2,则最多利用了一半的CPU核进行并行。

抢占:

在coroutine中要等待一个协程主动让出CPU才执行下一个协程,

在Go中,一个goroutine最多占用CPU 10ms,防止其他goroutine被饿死,

这就是goroutine不同于coroutine的一个地方。

全局G队列:

在新的调度器中依然有全局G队列,当P的本地队列为空时,优先从全局队列获取,如果全局队列为空时则通过work stealing机制从其他P的本地队列偷取G。

全局队列

全局队列(Global Queue):存放等待运行的G。出队和入队时,都需要加锁,因为是临界资源

P的本地队列

P的本地队列:同全局队列类似,存放的也是等待运行的G,存的数量有限,不超过256个。

新建G 时,G优先加入到P的本地队列,如果队列满了,会把本地队列中一半的G移动到全局队列

GMP模型以及场景过程 

场景一

P拥有G1,M1获取P后开始运行G1,G1使用go func()创建了G2,为了局部性G2优先加入到P1的本地队列。

场景2 

G1运行完成后(函数:goexit),M上运行的goroutine切换为G0,G0负责调度时协程的切换

从P的本地队列取G2,从G0切换到G2,并开始运行G2。实现了线程M1的复用。

场景三

当一个协程开辟太多的协程后,如果本地队列已经满了,把协程顺序打乱后,让一半的协程加入到全局队列中

负载均衡(把P1中本地队列中前一半的G,还有新创建G转移到全局队列)

场景四

负载均衡后,再创建协程,可以加入到本地队列

场景五

规定:在创建G时,运行的G会尝试唤醒其他空闲的P和M组合去执行。

拿的话至少从全局队列取1个g,但每次不要从全局队列移动太多的g到p本地队列,给其他p留点。

这是从全局队列到P本地队列的负载均衡

场景六

全局队列已经没有G,那m就要执行work stealing(偷取):

从其他有G的P哪里偷取一半G过来,放到自己的P本地队列。

P2从P1的本地队列尾部取一半的G,本例中一半则只有1个G4,放到P2的本地队列并执行。

为什么新的协程要加入到本地队列呢? 

缓存局部性:协程在执行过程中可能会访问某些数据或资源。将它们放在 P 的本地队列中有助于保持缓存局部性即相关的数据或资源更有可能保留在 CPU 缓存中,从而减少了访问延迟。

文章思路来自 : 刘丹冰老师 Golang修养之路

http://www.lryc.cn/news/375468.html

相关文章:

  • C++ 后端,Vue前端
  • 使用Navicat Premium向mysql插入2000000条数据
  • docker命令记录
  • Java学习七
  • 麒麟Kylin | 操作系统的安装与管理
  • 数据结构预备知识(Java):包装类泛型
  • 掌握Linux Vim:从基础到高级的全面指南
  • 打好“组合拳”,实现国有企业降本增效
  • 四川古力未来科技有限公司抖音小店解锁电商新机遇
  • Maven之介绍
  • 简单了解java中的File类
  • 边缘检测(一)-灰度图像边缘检测方法
  • 2025计算机毕业设计选题题目推荐-毕设题目汇总大全
  • 简易版 | 代码生成器(包含插件)
  • 【Python】Redis数据库
  • 理解并应用:JavaScript响应式编程与事件驱动编程的差异
  • 第4天:用户认证系统实现
  • PostgreSQL源码分析 —— FunctionScan
  • 数据结构-十大排序算法集合(四万字精讲集合)
  • SpringBoot三层架构
  • uniapp微信小程序局部刷新,无感刷新,修改哪条数据刷新哪条
  • golan的雪花id
  • RK3568 CAN波特率500K接收数据导致CPU4满载
  • AI实战 | 使用元器打造浪漫仪式小管家
  • 什么是隐马尔可夫模型?
  • qt中使用qsqlite连接数据库,却没有在本地文件夹中生成db文件
  • Django的‘通用视图TemplateView’
  • java功能实现在某个时间范围之内输出true,不在某个范围输出false,时间精确到分钟
  • macbook屏幕录制技巧,这2个方法请你收好
  • vue-loader