go一个协程安全协程调度的问题

举报
仙士可 发表于 2023/06/26 17:10:31 2023/06/26
【摘要】 go一个协程安全协程调度的问题发布于 2022-01-25 10:01:554650编辑删除看一段代码,请问输出什么?package mainimport "time"func main() { var testNum = 0 go func() { time.Sleep(10000) testNum = 1 }() for testNum == 0 { ...

go一个协程安全协程调度的问题

发布于 2022-01-25 10:01:55
4650
删除

看一段代码,请问输出什么?

package main

import "time"

func main() {
   var testNum = 0
   go func() {
      time.Sleep(10000)
      testNum = 1
   }()
   for testNum == 0 {
      if testNum==1 {
         println("testNum=1")
      }
      println("testNum=",testNum)
   }
   println("loop end.")
}
复制

输出结果:

从结果中,能发现2个问题:

1:循环确实结束了,说明testNum!=0 2:timeNum!=0,则说明TetsNum = 1赋值成功了,但是里面的=1判断却没有打印,为什么呢?

这是因为 main协程和 子协程共享变量造成的问题,主要执行流程如下:

package main

import "time"

func main() {
   var testNum = 0
   go func() {
      time.Sleep(10000)  //隔了10000纳秒
      testNum = 1  //赋值为1
   }()
   for testNum == 0 { 
      //在10000纳秒之前,这个值都为0
      if testNum==1 { //在执行完这次判断后,testNum才更新为1,此时已经没有条件进入此循环,所以此代码永远不执行
         println("testNum=1") 
      }
      println("testNum=",testNum)
      //10000纳秒之前,为0
      //在执行完这条后,testNum突然被更新为了1,所以不会进行下一次循环
   }
   println("loop end.")
}
复制

那么,这里面又涉及到了一个新的问题:

为什么是刚好在执行完一次循环之后,才刚好轮到testNum=1,而不是在执行前之前轮转到呢?

这就涉及到了go的协程调度问题了,具体是怎么调度的呢?

go的协程调度

go的协程调度为 [典藏版] Golang 调度器 GMP 原理与调度全分析

简单说明:

G:协程

M:运行的线程

P:执行线程的处理器,可以理解为cpu中的线程/进程

- 在运行时,G必须绑定在M上,M必须在P上才可以运行程序,而cpu调度器执行的是P,也就是有多少核心,或者有多少个P,就可以同时运行多少个M/G

- 多个G绑定在M上,在发生syscall或者io阻塞时,会自动挂起,M将切换其他G执行,当G运行时间超过10ms(1.14后加入),会自动切换成其他协程

理解这2句话就够了,我们回到代码:

因为加了输出,导致了协程一定会切换,所以100%可以复现上面的问题,如果这句输出放到上面去运行,则变成了100%输出 testNum=1:

刚刚我们看到了GMP的第一点,有多少个P,就应该有多少个M/G同时运行,那么问题来了,为什么上面的2个协程没有并行呢?

GMP的另一个特点:

- P可能会有多个M绑定,当M阻塞后,P将绑定其他M进行执行

- M会有多个G绑定,当一个G阻塞后,将获取一个新的G进行运行 - 如果M的G已经超出数量后,将会分一半给其他的M

- 如果M没有可以执行的G后,将会偷其他M的G

在示例代码,由于是先执行的go func,sleep(协程2),所以M在执行main开始之后,立即开始执行协程2,同时由于协程2 sleep阻塞,所以切回main协程运行,在刚执行的时候,由于并没有繁忙情况,所以没有启用M2和P2进行运行,所以没有实现并行


【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。