這是另一篇關(guān)于Go調(diào)度器(scheduler)的文章。 原文: GO SCHEDULER: MS, PS & GS by Uber工程師 Povilas。

網(wǎng)上已經(jīng)有很多關(guān)于Go調(diào)度器的文章了， 比如 Golang調(diào)度器源碼分析 ,多看一些，可以加深記憶，也可以對比查看文章中是否有不準(zhǔn)確的地方,更全面的了解Go的調(diào)度器。

我決定深入了解Go的內(nèi)部機(jī)制， 因?yàn)楹荛L時(shí)間沒人寫關(guān)于Go scheduler的文章了， 我覺得這是一個(gè)很有趣的知識點(diǎn)，所以讓我們開始吧。

基礎(chǔ)知識

Go的運(yùn)行時(shí)管理著調(diào)度、垃圾回收以及goroutine的運(yùn)行環(huán)境。本文只關(guān)注于調(diào)度器。

運(yùn)行時(shí)負(fù)責(zé)運(yùn)行g(shù)oroutine并把它們影射到操作系統(tǒng)的線程上。goroutine比線程還輕量， 啟動(dòng)的時(shí)候花費(fèi)很少。每個(gè)goroutine都是由一個(gè) G 結(jié)構(gòu)來表示，

這個(gè)結(jié)構(gòu)體的字段用來跟蹤此goroutine的棧(stack)和狀態(tài)，所以你可以認(rèn)為 G = goroutine 。

運(yùn)行時(shí)管理著 G 并把它們映射到 Logical Processor (稱之為 P ). P 可以看作是一個(gè)抽象的資源或者一個(gè)上下文，它需要獲取以便操作系統(tǒng)線程(稱之為 M )可以運(yùn)行 G 。

通過 runtime.GOMAXPROCS (numLogicalProcessors) 可以控制多少 P 可以獲取。如果你需要調(diào)整這個(gè)參數(shù)(大部分情況下你無需調(diào)整)， 只設(shè)置一次， 因?yàn)樗枰?STW gc pause。

本質(zhì)上，操作系統(tǒng)運(yùn)行線程，線程運(yùn)行你的代碼。Go的技巧是編譯器會在Go運(yùn)行時(shí)的一些地方插入系統(tǒng)調(diào)用， (比如通過channel發(fā)送值,調(diào)用runtime包等)，所以Go可以通知調(diào)度器執(zhí)行特定的操作。

上圖的理解來自 Analysis of the Go runtime scheduler

M、P 和 G 之間的交互

M、 P 和 G 之間的交互有點(diǎn)復(fù)雜。看看下面這張來自 Gao Chao的 go runtime scheduler 幻燈片中的一張圖：

可以看到，Go運(yùn)行時(shí)存在兩種類型的queue： 一種是一個(gè)全局的queue(在 schedt結(jié)構(gòu)體中 ，很少用到)， 一種是每個(gè) P 都維護(hù)自己的 G 的queue。

為了運(yùn)行g(shù)oroutine, M 需要持有上下文 P 。 M 會從 P 的queue彈出一個(gè)goroutine并執(zhí)行。

當(dāng)你創(chuàng)建一個(gè)新的goroutine的時(shí)候( go func() 方法)，它會被放入 P 的queue。當(dāng)然還有一個(gè) work-stealing 調(diào)度算法，當(dāng) M 執(zhí)行了一些 G 后,如果它的queue為空，它會隨機(jī)的選擇另外一個(gè) P ,從它的queue中取走一半的 G 到自己的queue中執(zhí)行。(偷!)

當(dāng)你的goroutine執(zhí)行阻塞的系統(tǒng)調(diào)用的時(shí)候(syscall)，阻塞的系統(tǒng)調(diào)用會中斷(intercepted)，如果當(dāng)前有一些 G 在執(zhí)行，運(yùn)行時(shí)會把這個(gè)線程從 P 中摘除(detach)，然后再創(chuàng)建一個(gè)新的操作系統(tǒng)的線程(如果沒有空閑的線程可用的話)來服務(wù)于這個(gè) P 。

當(dāng)系統(tǒng)調(diào)用繼續(xù)的時(shí)候，這個(gè)goroutine被放入到本地運(yùn)行queue，線程會 park 它自己(休眠)， 加入到空閑線程中。

如果一個(gè)goroutine執(zhí)行網(wǎng)絡(luò)調(diào)用，運(yùn)行時(shí)會做類似的動(dòng)作。調(diào)用會被中斷，但是由于Go使用集成的network poller,它有自己的線程，所以還給它。

Go運(yùn)行時(shí)會在下面的goroutine被阻塞的情況下運(yùn)行另外一個(gè)goroutine：

• blocking syscall (for example opening a file),
• network input,
• channel operations,
• primitives in the sync package.

調(diào)度器跟蹤調(diào)試

Go可以跟蹤運(yùn)行時(shí)的調(diào)度器，這是通過 GODEBUG 環(huán)境變量實(shí)現(xiàn)的:

$ GODEBUG=scheddetail=1,schedtrace=1000 ./program 

下面是輸出的例子:

SCHED 0ms: gomaxprocs=8 idleprocs=7 threads=2 spinningthreads=0 idlethreads=0 runqueue=0 gcwaiting=0 nmidlelocked=0 stopwait=0 sysmonwait=0 
  P0: status=1 schedtick=0 syscalltick=0 m=0 runqsize=0 gfreecnt=0 
  P1: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P2: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P3: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P4: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P5: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P6: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  P7: status=0 schedtick=0 syscalltick=0 m=-1 runqsize=0 gfreecnt=0 
  M1: p=-1 curg=-1 mallocing=0 throwing=0 preemptoff= locks=1 dying=0 helpgc=0 spinning=false blocked=false lockedg=-1 
  M0: p=0 curg=1 mallocing=0 throwing=0 preemptoff= locks=1 dying=0 helpgc=0 spinning=false blocked=false lockedg=1 
  G1: status=8() m=0 lockedm=0 

注意輸出使用了 G 、 M 和 P 的概念以及她們的狀態(tài)， 比如 P 的queue的大小。 如果你不想關(guān)心這些細(xì)節(jié)，你可以使用：

$ GODEBUG=schedtrace=1000 ./program 

William Kennedy寫了一篇很好的 文章 , 解釋了這些細(xì)節(jié)。

當(dāng)然，還有一個(gè)go自己的工具 go tool trace , 它有一個(gè)UI, 允許你查看你的程序和運(yùn)行時(shí)的狀況。你可以閱讀這篇文章: Pusher 。