Go 언어에 GMP 스케줄링 모델이 존재하는 이유에 대한 심층 분석

Go에 GMP 일정 모델이 있는 이유는 무엇인가요? 다음 글에서는 Go 언어에 GMP 스케줄링 모델이 있는 이유를 소개하겠습니다. 이것이 여러분에게 도움이 되기를 바랍니다.

GMP 스케줄링 모델은 Go의 핵심입니다. 이는 다중 스레드 동시 스케줄링 코루틴의 효율성 문제를 합리적으로 해결합니다.

GMP란 무엇인가

우선 각 GMP가 무엇을 가리키는지 이해해야 합니다.

• G: 고루틴(Goroutine)의 약어는 스레드에서 실행되는 코루틴을 의미합니다.
• M: Machine의 약어, 즉 thead, thread, 순환 스케줄링 코루틴 및 실행입니다.
• P: 프로세서의 약어로, 로컬 대기열에 코루틴을 저장하고 잠자지 않는 사용 가능한 코루틴을 스레드에 제공하는 프로세서를 나타냅니다.

스레드 M은 각각 프로세서 P를 보유합니다. 코루틴을 얻으려는 경우 P에서 먼저 얻으므로 GMP 모델 다이어그램은 다음과 같습니다.

일반적인 프로세스는 스레드 M이 P의 큐에서 코루틴을 얻는 것입니다. 코루틴을 얻을 수 없으면 잠금을 놓고 경쟁하게 됩니다. 전역 대기열에서 가져옵니다.

프로세서 P

코루틴 G와 스레드 M의 구조는 이전 글에서 설명했습니다. 프로세서 P에 대한 분석은 다음과 같습니다.

Function

프로세서 P는 코루틴 배치를 저장하므로 스레드 M은 전역 대기열의 코루틴을 놓고 다른 스레드와 경쟁할 필요 없이 잠금 없이 코루틴에서 코루틴을 얻을 수 있으므로 코루틴 예약의 효율성이 향상됩니다.

소스 코드 분석

p 구조 소스 코드는 srcruntimeruntime2.go에 있으며, 여기에 몇 가지 중요한 필드가 표시됩니다. srcruntimeruntime2.go中，这里展示部分重要字段。

type p struct {
   ...
   m           muintptr   // back-link to associated m (nil if idle)
   // Queue of runnable goroutines. Accessed without lock.
   runqhead uint32
   runqtail uint32
   runq     [256]guintptr
   runnext guintptr
   ...
}

• m为处理器p所属的线程
• runq是一个储存协程的队列
• runqhead，runqtail表示队列的头尾指针
• runnext指向下一个可运行的协程

线程M与处理器P是如何协作的？

在srcruntimeproc.go中，有一个schedule方法，这是线程运行的第一个函数。这函数中，线程需要获取到可运行的协程，代码如下：

func schedule() {    
    ...
    // 寻找一个可运行的协程
    gp, inheritTime, tryWakeP := findRunnable() 
    ...
}

func findRunnable() (gp *g, inheritTime, tryWakeP bool) {
    // 从本地队列中获取协程
    if gp, inheritTime := runqget(pp); gp != nil {
       return gp, inheritTime, false
    }

    // 本地队列拿不到则从全局队列中获取协程
    if sched.runqsize != 0 {
       lock(&sched.lock)
       gp := globrunqget(pp, 0)
       unlock(&sched.lock)
       if gp != nil {
          return gp, false, false
       }
    }
}

从本地队列中获取协程

func runqget(pp *p) (gp *g, inheritTime bool) {
   next := pp.runnext // 队列中下一个可运行的协程
   if next != 0 && pp.runnext.cas(next, 0) {
      return next.ptr(), true
   }
   ...
}

那如果本地队列和全局队列中都没有协程了怎么办呢，难道就让线程这么闲着？

这时候处理器P就会任务窃取，从其他线程的本地队列中窃取一些任务，美其名曰分担其他线程的压力，还提高了自己线程的利用率。

源码在srcruntimeproc.gostealWork中，感兴趣可以看看。

新建的协程该分配到哪？

新建的协程该分配到本地还是全局队列呢，得分情况：

• Go认为新协程的优先级高，于是先寻找本地队列放入，而且还插队。
• 本队队列满了才放入全局队列。

实际流程为：

1. 随机寻找P
2. 将新协程放入P的runnext中，意味着下一个就运行该协程，插队了
3. 若P的协程满了，则放入全局队列

源码在srcruntimeproc.gonewproc

// Create a new g running fn.
// Put it on the queue of g's waiting to run.
// The compiler turns a go statement into a call to this.
func newproc(fn *funcval) {
   gp := getg()
   pc := getcallerpc()
   systemstack(func() {
      newg := newproc1(fn, gp, pc) // 创建新协程

      pp := getg().m.p.ptr()
      runqput(pp, newg, true) // 寻找本地队列放入

      if mainStarted {
         wakep()
      }
   })
}

m은 프로세서 p가 속한 스레드입니다. runq는 코루틴을 저장하는 대기열입니다.

runqhead, <code>runqtail은 대기열의 헤드 및 테일 포인터를 나타냅니다.

runnext는 실행 가능한 다음 코루틴을 가리킵니다.

스레드 남 프로세서 P에서는 어떻게 작동하나요? 🎜🎜🎜srcruntimeproc.go에는 스레드가 실행하는 첫 번째 함수인 schedule 메서드가 있습니다. 이 함수에서 스레드는 실행 가능한 코루틴을 가져와야 합니다. 코드는 다음과 같습니다. 🎜rrreeerrreee🎜로컬 큐에서 코루틴 가져오기🎜rrreee🎜로컬 큐와 글로벌 큐에 코루틴이 없으면 어떻게 되나요? let 스레드가 너무 유휴 상태입니까? 🎜🎜이때 프로세서 P는 작업을 훔치고 다른 스레드의 로컬 대기열에서 일부 작업을 훔칩니다. 이를 다른 스레드의 압력을 공유하고 자체 스레드의 활용도를 향상시킨다고 합니다. 🎜🎜소스코드는 srcruntimeproc.gostealWork에 있으니 관심있으신 분들은 한번 살펴보시면 됩니다. 🎜

🎜새로 생성된 코루틴을 어디에 할당해야 하나요? 🎜🎜🎜새로 생성된 코루틴을 로컬 큐에 할당해야 할까요, 아니면 글로벌 큐에 할당해야 할까요? 점수: 🎜🎜🎜Go는 새 코루틴의 우선순위가 높다고 생각하여 이를 넣을 로컬 큐를 먼저 찾고 점프합니다. 대기열. 🎜🎜팀 대기열이 가득 찬 경우에만 글로벌 대기열에 추가됩니다. 🎜🎜🎜실제 프로세스는 다음과 같습니다. 🎜

🎜P를 무작위로 찾습니다🎜🎜새 코루틴을 P의 runnext에 넣습니다. 이는 코루틴이 다음에 실행되고 대기열이 점프된다는 의미입니다🎜 🎜P의 코루틴이 가득 차면 전역 대기열에 추가됩니다🎜

🎜소스 코드는 srcruntimeproc.gonewproc 함수에 있습니다. 🎜rrreee🎜🎜결론🎜🎜🎜이 문서에서는 처음에 GMP 스케줄링 모델을 소개하고, 프로세서 P와 스레드 M이 코루틴을 얻는 방법을 구체적으로 소개합니다. 🎜🎜프로세서 P는 코루틴을 얻기 위해 다중 스레드 상호 배제 문제를 해결하고 코루틴 예약의 효율성을 향상시킵니다. 그러나 코루틴이 로컬 큐에 있든 글로벌 큐에 있든 상관없이 순차적으로만 실행되는 것 같습니다. 코루틴을 비동기식으로 구현하면 동시 실행이 어떻게 되나요? 다음 기사에서 분석을 계속하겠습니다(아무도 읽지 않을지라도...). 🎜🎜추천 학습: 🎜Golang 튜토리얼🎜🎜

위 내용은 Go 언어에 GMP 스케줄링 모델이 존재하는 이유에 대한 심층 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!