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

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

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

1.1 Goroutine

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

1.2 M-P-G 模型

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

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

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

2.1 工作竊?。╓ork Stealing）

當(dāng)一個(gè)P的本地隊(duì)列中沒(méi)有可運(yùn)行的Goroutine時(shí)，它會(huì)嘗試從其他P的隊(duì)列中“竊取”Goroutine來(lái)執(zhí)行。這種機(jī)制可以平衡各個(gè)P的負(fù)載，避免某些P空閑而其他P過(guò)載。

2.2 搶占式調(diào)度

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

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

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

3. 代碼解析

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

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

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)建通過(guò)go關(guān)鍵字觸發(fā)，最終會(huì)調(diào)用runtime.newproc函數(shù)。該函數(shù)會(huì)將新的Goroutine放入當(dāng)前P的本地隊(duì)列中。

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ù)會(huì)從當(dāng)前P的本地隊(duì)列、全局隊(duì)列或其他P的隊(duì)列中獲取可運(yùn)行的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() {
            // 如果本地隊(duì)列為空，嘗試從全局隊(duì)列或其他P竊取Goroutine
            gp, inheritTime = runqget(_g_.m.p.ptr())
            if gp == nil {
                gp, inheritTime = findrunnable() // 阻塞直到找到可運(yùn)行的Goroutine
            }
        } else {
            // 從本地隊(duì)列獲取Goroutine
            gp, inheritTime = runqget(_g_.m.p.ptr())
        }
        execute(gp, inheritTime)
    }
}

3.4 搶占機(jī)制

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

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

4. 性能與并發(fā)

4.1 高效利用多核

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

4.2 低延遲

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

4.3 高吞吐量

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

5. 總結(jié)

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

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

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

最新評(píng)論