golang的MPG調度模型是保障Go語言效率高的一個重要特性，本文詳細介紹了Go語言調度模型的設計。

前言

Please remember that at the end of the day， all programs that work on UNIX machines end up using C system calls to communicate with the UNIX kernel and perform most of their tasks. 所有在 UNIX 系統上運行的程序最終都會通過 C 系統調用來和內核打交道。

用其他語言編寫程序進行系統調用，方法不外乎兩個：一是自己封裝，二是依賴 glibc、或者其他的運行庫。Go 語言選擇了前者，把系統調用都封裝到了 syscall 包。封裝時也同樣得通過匯編實現。

異步系統調用 G 會和MP分離（G掛到netpoller），同步系統調用 GM 會和P分離（P另尋M），生動的說明了GPM相對GM的精妙之處。

阻塞

在 Go 里面阻塞主要分為以下 4 種場景：

由于原子、互斥量或通道操作調用導致 Goroutine 阻塞，調度器將把當前阻塞的 Goroutine 切換出去，重新調度 LRQ 上的其他 Goroutine；

由于網絡請求和 IO 操作導致 Goroutine 阻塞。Go 程序提供了網絡輪詢器（NetPoller）來處理網絡請求和 IO 操作的問題，其后臺通過 kqueue（MacOS），epoll（Linux）或 iocp（Windows）來實現 IO 多路復用。通過使用 NetPoller 進行網絡系統調用，調度器可以防止 Goroutine 在進行這些系統調用時阻塞 M。

這可以讓 M 執行 P 的 LRQ 中其他的 Goroutines，而不需要創建新的 M。執行網絡系統調用不需要額外的 M，網絡輪詢器使用系統線程，它時刻處理一個有效的事件循環，有助于減少操作系統上的調度負載。

用戶層眼中看到的 Goroutine 中的“block socket”，實現了 goroutine-per-connection 簡單的網絡編程模式。實際上是通過 Go runtime 中的 netpoller 通過 Non-block socket + I/O 多路復用機制“模擬”出來的。

當調用一些系統方法的時候（如文件 I/O），如果系統方法調用的時候發生阻塞，這種情況下，網絡輪詢器（NetPoller）無法使用，而進行系統調用的 G1 將阻塞當前 M1。調度器引入 其它M 來服務 M1 的P。

如果在 Goroutine 去執行一個 sleep 操作，導致 M 被阻塞了。Go 程序后臺有一個監控線程 sysmon，它監控那些長時間運行的 G 任務然后設置可以強占的標識符，別的 Goroutine 就可以搶先進來執行。

系統調用

Go 語言通過 Syscall 和 Rawsyscall 等使用匯編語言編寫的方法封裝了操作系統提供的所有系統調用，其中 Syscall 在 Linux 386 上的實現如下：

TEXT ·Syscall（SB），NOSPLIT，$0-28

CALL runtime·entersyscall（SB）

MOVL trap+0（FP）， AX // syscall entry

MOVL a1+4（FP）， BX

MOVL a2+8（FP）， CX

MOVL a3+12（FP）， DX

MOVL $0， SI

MOVL $0， DI

INVOKE_SYSCALL

CMPL AX， $0xfffff001

JLS ok

MOVL $-1， r1+16（FP）

MOVL $0， r2+20（FP）

NEGL AX

MOVL AX， err+24（FP）

CALL runtime·exitsyscall（SB）

RET

ok：

MOVL AX， r1+16（FP）

MOVL DX， r2+20（FP）

MOVL $0， err+24（FP）

CALL runtime·exitsyscall（SB）

RET

Golang - 調度剖析 https://segmentfault.com/a/1190000016611742

Go： Goroutine， OS Thread and CPU Management https://medium.com/a-journey-with-go/go-goroutine-os-thread-and-cpu-management-2f5a5eaf518a

Go optimizes the system calls — whatever it is blocking or not — by wrapping them up in the runtime. This wrapper will automatically dissociate the P from the thread M and allow another thread to run on it.

異步系統調用

通過使用網絡輪詢器進行網絡系統調用，調度器可以防止 Goroutine 在進行這些系統調用時阻塞M。這可以讓M執行P的 LRQ 中其他的 Goroutines，而不需要創建新的M。有助于減少操作系統上的調度負載。

G1正在M上執行，還有 3 個 Goroutine 在 LRQ 上等待執行

接下來，G1想要進行網絡系統調用，因此它被移動到網絡輪詢器并且處理異步網絡系統調用。然后，M可以從 LRQ 執行另外的 Goroutine。

最后：異步網絡系統調用由網絡輪詢器完成，G1被移回到P的 LRQ 中。一旦G1可以在M上進行上下文切換，它負責的 Go 相關代碼就可以再次執行。

同步系統調用

G1將進行同步系統調用以阻塞M1

調度器介入后：識別出G1已導致M1阻塞，此時，調度器將M1與P分離，同時也將G1帶走。然后調度器引入新的M2來服務P。

阻塞的系統調用完成后：G1可以移回 LRQ 并再次由P執行。如果這種情況需要再次發生，M1將被放在旁邊以備將來使用。

sysmon 協程

在 linux 內核中有一些執行定時任務的線程， 比如定時寫回臟頁的 pdflush， 定期回收內存的 kswapd0， 以及每個 cpu 上都有一個負責負載均衡的 migration 線程等。在 go 運行時中也有類似的協程 sysmon. sysmon 運行在 M，且不需要 P。它會每隔一段時間檢查 Go 語言runtime，確保程序沒有進入異常狀態。

系統監控的觸發時間就會穩定在 10ms，功能比較多：

檢查死鎖runtime.checkdead

運行計時器 — 獲取下一個需要被觸發的計時器；

定時從 netpoll 中獲取 ready 的協程

Go 的搶占式調度

當 sysmon 發現 M 已運行同一個 G（Goroutine）10ms 以上時，它會將該 G 的內部參數 preempt 設置為 true。然后，在函數序言中，當 G 進行函數調用時，G 會檢查自己的 preempt 標志，如果它為 true，則它將自己與 M 分離并推入“全局隊列”。由于它的工作方式（函數調用觸發），在 for{} 的情況下并不會發生搶占，如果沒有函數調用，即使設置了搶占標志，也不會進行該標志的檢查。

Go1.14 引入搶占式調度（使用信號的異步搶占機制），sysmon 仍然會檢測到運行了 10ms 以上的 G（goroutine）。然后，sysmon 向運行 G 的 P 發送信號（SIGURG）。Go 的信號處理程序會調用P上的一個叫作 gsignal 的 goroutine 來處理該信號，將其映射到 M 而不是 G，并使其檢查該信號。gsignal 看到搶占信號，停止正在運行的 G。

在滿足條件時觸發垃圾收集回收內存；

打印調度信息，歸還內存等定時任務。

轉自：bert.li@ximalaya.com

qiankunli.github.io/2020/11/21/goroutine_system_call.html

編輯：jq