Golang的調(diào)度器是其并發(fā)模型的核心組件，負責(zé)管理Goroutine的調(diào)度和執(zhí)行。Goroutine是Go語言中的輕量級線程，由Go運行時（runtime）管理。

調(diào)度器的設(shè)計目標是高效地利用多核CPU，同時保持低延遲和高吞吐量。下面我們從理論和代碼層面分析Golang調(diào)度器的關(guān)鍵機制。

1. 調(diào)度器的基本概念

1.1 Goroutine

Goroutine是Go語言中的并發(fā)執(zhí)行單元，比操作系統(tǒng)線程更輕量。每個Goroutine初始時只占用幾KB的?？臻g，?？臻g可以根據(jù)需要動態(tài)增長或縮減。

1.2 M-P-G 模型

Go調(diào)度器采用了M-P-G模型：

• M (Machine): 代表操作系統(tǒng)線程（OS Thread），由操作系統(tǒng)調(diào)度。
• P (Processor): 代表邏輯處理器，負責(zé)調(diào)度Goroutine。P的數(shù)量通常等于CPU核心數(shù)，可以通過GOMAXPROCS設(shè)置。
• G (Goroutine): 代表Go的并發(fā)執(zhí)行單元。

2. 調(diào)度器的核心機制

2.1 工作竊取（Work Stealing）

當(dāng)一個P的本地隊列中沒有可運行的Goroutine時，它會嘗試從其他P的隊列中“竊取”Goroutine來執(zhí)行。這種機制可以平衡各個P的負載，避免某些P空閑而其他P過載。

2.2 搶占式調(diào)度

Go調(diào)度器是搶占式的，意味著它可以在Goroutine執(zhí)行過程中強制切換執(zhí)行權(quán)。Go 1.14引入了基于信號的搶占機制，確保長時間運行的Goroutine不會阻塞其他Goroutine的執(zhí)行。

2.3 系統(tǒng)調(diào)用

當(dāng)Goroutine執(zhí)行系統(tǒng)調(diào)用時，調(diào)度器會將當(dāng)前的M與P分離，并創(chuàng)建一個新的M來執(zhí)行系統(tǒng)調(diào)用。這樣可以避免系統(tǒng)調(diào)用阻塞整個P的執(zhí)行。

3. 代碼解析

3.1 調(diào)度器的初始化

調(diào)度器的初始化在runtime/proc.go中的schedinit函數(shù)中完成。該函數(shù)設(shè)置了P的數(shù)量、初始化全局隊列等。

func schedinit() {
    // 初始化P的數(shù)量
    procs := int(ncpu)
    if n, ok := atoi32(gogetenv("GOMAXPROCS")); ok && n > 0 {
        procs = n
    }
    if procresize(procs) != nil {
        throw("unknown runnable goroutine during bootstrap")
    }
}

3.2 Goroutine的創(chuàng)建與調(diào)度

Goroutine的創(chuàng)建通過go關(guān)鍵字觸發(fā)，最終會調(diào)用runtime.newproc函數(shù)。該函數(shù)會將新的Goroutine放入當(dāng)前P的本地隊列中。

func newproc(siz int32, fn *funcval) {
    argp := add(unsafe.Pointer(&fn), sys.PtrSize)
    gp := getg()
    pc := getcallerpc()
    systemstack(func() {
        newg := newproc1(fn, argp, siz, gp, pc)
        _p_ := getg().m.p.ptr()
        runqput(_p_, newg, true)
        if mainStarted {
            wakep()
        }
    })
}

3.3 調(diào)度循環(huán)

調(diào)度器的核心是調(diào)度循環(huán)，位于runtime/proc.go中的schedule函數(shù)。該函數(shù)會從當(dāng)前P的本地隊列、全局隊列或其他P的隊列中獲取可運行的Goroutine并執(zhí)行。

func schedule() {
    _g_ := getg()

    if _g_.m.locks != 0 {
        throw("schedule: holding locks")
    }

    if _g_.m.lockedg != 0 {
        stoplockedm()
        execute(_g_.m.lockedg.ptr(), false) // Never returns.
    }

    // 調(diào)度循環(huán)
    for {
        if sched.gcwaiting != 0 {
            gcstopm()
            continue
        }
        if _g_.m.p.ptr().runqempty() {
            // 如果本地隊列為空，嘗試從全局隊列或其他P竊取Goroutine
            gp, inheritTime = runqget(_g_.m.p.ptr())
            if gp == nil {
                gp, inheritTime = findrunnable() // 阻塞直到找到可運行的Goroutine
            }
        } else {
            // 從本地隊列獲取Goroutine
            gp, inheritTime = runqget(_g_.m.p.ptr())
        }
        execute(gp, inheritTime)
    }
}

3.4 搶占機制

Go 1.14引入了基于信號的搶占機制，確保長時間運行的Goroutine不會阻塞其他Goroutine的執(zhí)行。搶占機制的實現(xiàn)位于runtime/signal_unix.go中。

func preemptM(mp *m) {
    if atomic.Cas(&mp.signalPending, 0, 1) {
        signalM(mp, sigPreempt)
    }
}

4. 性能與并發(fā)

4.1 高效利用多核

通過M-P-G模型，Go調(diào)度器能夠高效地利用多核CPU。每個P綁定到一個M上，M是操作系統(tǒng)線程，P負責(zé)調(diào)度Goroutine。P的數(shù)量通常等于CPU核心數(shù)，這樣可以最大限度地利用CPU資源。

4.2 低延遲

Go調(diào)度器的搶占式調(diào)度和基于信號的搶占機制確保了低延遲。即使某個Goroutine長時間運行，調(diào)度器也能及時切換執(zhí)行權(quán)，避免其他Goroutine被長時間阻塞。

4.3 高吞吐量

工作竊取機制確保了各個P之間的負載均衡，避免了某些P過載而其他P空閑的情況。這種機制提高了系統(tǒng)的整體吞吐量。

5. 總結(jié)

Golang的調(diào)度器通過M-P-G模型、工作竊取、搶占式調(diào)度等機制，實現(xiàn)了高效的并發(fā)和并行執(zhí)行。調(diào)度器的設(shè)計使得Go語言在處理高并發(fā)場景時表現(xiàn)出色，能夠充分利用多核CPU資源，同時保持低延遲和高吞吐量。

通過深入理解調(diào)度器的工作原理，開發(fā)者可以更好地編寫高效的并發(fā)程序，充分利用Go語言的并發(fā)特性。

到此這篇關(guān)于淺析Golang中調(diào)度器的關(guān)鍵機制與性能的文章就介紹到這了,更多相關(guān)Golang調(diào)度器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論