Go并發(fā)中g(shù)oroutine模型與調(diào)度策略的示例分析

這篇文章給大家分享的是有關(guān)Go并發(fā)中g(shù)oroutine模型與調(diào)度策略的示例分析的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過來看看吧。

單進(jìn)程操作系統(tǒng)

早期的單進(jìn)程操作系統(tǒng)，可以理解為只有一個(gè)時(shí)間軸，CPU順序執(zhí)行每一個(gè)進(jìn)程/線程，這種順序執(zhí)行的方式，CPU同一時(shí)間智能處理一個(gè)指令，一個(gè)任務(wù)一個(gè)任務(wù)去處理

這樣就會(huì)導(dǎo)致進(jìn)程阻塞的話，CPU就會(huì)卡在當(dāng)前進(jìn)程，一直在等待，CPU就會(huì)浪費(fèi)

多線程/多進(jìn)程操作系統(tǒng)

CPU利用輪詢機(jī)制，調(diào)度各個(gè)進(jìn)程，每個(gè)進(jìn)程都分配固定的時(shí)間片，這個(gè)時(shí)間片很小，先執(zhí)行進(jìn)程A，如果A結(jié)束了，那沒問題切換到下一進(jìn)程B，但如果時(shí)間片內(nèi)A沒結(jié)束，CPU不管A沒結(jié)束，會(huì)強(qiáng)制切換到下一進(jìn)程B，以此類推，CPU就避免了阻塞在某一進(jìn)程

但這樣的問題是，在頻繁切換進(jìn)程的過程中，進(jìn)程的切換就必然會(huì)導(dǎo)致切換成本，例如保存當(dāng)前線程狀態(tài)，系統(tǒng)調(diào)用，環(huán)境的上下文切換，各種拷貝復(fù)制就會(huì)導(dǎo)致時(shí)間浪費(fèi)，大部分時(shí)間都用在切換了，進(jìn)程數(shù)量越多，切換的浪費(fèi)就越大

因此軟件的目標(biāo)就是提高CPU利用率

另一方面，進(jìn)程的內(nèi)存占用也是很大的問題

1:N模型

程序員的任務(wù)就是在用戶態(tài)調(diào)接口，開發(fā)業(yè)務(wù)，內(nèi)核態(tài)負(fù)責(zé)調(diào)硬件，調(diào)系統(tǒng)資源，用戶線程和內(nèi)核線程一一綁定，CPU只需要管內(nèi)核線程，這樣的內(nèi)核線程稱為thread，用戶線程稱為co-routine，thread通過管理協(xié)程調(diào)度器，管理多個(gè)協(xié)程，這樣CPU還是只管理一個(gè)線程

這樣就在用戶態(tài)實(shí)現(xiàn)了并發(fā)，CPU也不用切換了，只用在協(xié)程切換時(shí)消耗很少的資源，解決了CPU高消耗調(diào)度的問題

這樣的弊端是有一個(gè)協(xié)程阻塞了，下一個(gè)協(xié)程就不能執(zhí)行了

M:N模型

M個(gè)線程通過協(xié)程調(diào)度器，管理多個(gè)協(xié)程，CPU的調(diào)度優(yōu)化我們沒法做，這個(gè)協(xié)程調(diào)度器就非常重要了

goroutine

在go中，協(xié)程co-routine被改為goroutine，一個(gè)goroutine只占幾kb，因此可以有大量的goroutine存在，另一方面goroutine 的調(diào)度器非常靈活

goroutine早期調(diào)度器

早期的goroutine調(diào)度器有一個(gè)全局的goroutine隊(duì)列，這個(gè)隊(duì)列有一個(gè)鎖，每個(gè)線程要?jiǎng)?chuàng)建、銷毀、運(yùn)行一個(gè)goroutine都要先獲取一個(gè)鎖，然后執(zhí)行g(shù)oroutine，執(zhí)行完畢后再把鎖還回去

這樣的問題是激烈的鎖競(jìng)爭(zhēng)

另一方面，當(dāng)一個(gè)線程執(zhí)行一個(gè)goroutine時(shí)，這個(gè)goroutine新創(chuàng)建了一個(gè)goroutine，為了保證并發(fā)，這個(gè)新goroutine肯定得執(zhí)行，這個(gè)新創(chuàng)建的就被放在下一個(gè)線程去執(zhí)行，這實(shí)際上不滿足程序的局部性原理

另外系統(tǒng)在頻繁調(diào)用不同的線程還是會(huì)造成系統(tǒng)開銷

GMP

在操作系統(tǒng)中，有一個(gè)操作系統(tǒng)調(diào)度器，用來調(diào)度CPU，來處理不同的內(nèi)核線程，在這之上每個(gè)線程有一個(gè)處理器，這個(gè)處理器里有g(shù)oroutine的各種資源，堆、棧、數(shù)據(jù)等，這樣的處理器稱為P，每個(gè)P管理一個(gè)自己的本地隊(duì)列，這個(gè)隊(duì)列里存放著這個(gè)P要處理的goroutine，goroutine要被處理時(shí)，線程獲取一個(gè)P，P調(diào)度出一個(gè)goroutine交給線程，線程對(duì)goroutine進(jìn)行處理，除了P的本地隊(duì)列外，還有一個(gè)全局隊(duì)列，里面也存放著要運(yùn)行的goroutine

調(diào)度器設(shè)計(jì)策略

 復(fù)用線程

work stealing

當(dāng)一個(gè)線程正在執(zhí)行一個(gè)goroutine時(shí)，并且它的P本地隊(duì)列里還有待執(zhí)行的goroutine，別的P空閑的話就會(huì)幫它的線程偷取一個(gè)goroutine

↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓

hand off

如果說一個(gè)P正執(zhí)行的goroutine突然阻塞了，比如在等待輸入之類的，那么這時(shí)候這個(gè)P的線程，也就是這個(gè)CPU實(shí)際上沒有被利用，這時(shí)候就會(huì)創(chuàng)建/喚醒一個(gè)新的線程，這時(shí)候讓阻塞的goroutine繼續(xù)阻塞，當(dāng)前CPU變?yōu)樗郀顟B(tài)，但把物理CPU切換走到不阻塞的線程上，其余的P和P的本地隊(duì)列直接被轉(zhuǎn)移到新的線程上控制，如果之前的阻塞routine又不阻塞了，那把這個(gè)goroutine又加入到別的隊(duì)列后

↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓

并行

P的數(shù)量可以宏定義，例如為CPU核心數(shù)/2

搶占

在1:1模型中，一個(gè)協(xié)程和一個(gè)線程綁定，當(dāng)有別的協(xié)程需要運(yùn)行時(shí)，當(dāng)前的協(xié)程除非釋放出這個(gè)線程資源，否則新來的就只能等著

而goroutine的機(jī)制是，每個(gè)goroutine只有10ms，時(shí)間用完后新的goroutine一定會(huì)搶占這個(gè)CPU，沒有誰(shuí)優(yōu)先，大家都很平均

全局隊(duì)列

一個(gè)線程如果沒有要執(zhí)行的goroutine，根據(jù)work stealing，去別的本地隊(duì)列偷，如果別的隊(duì)列也沒得偷，就去全局隊(duì)列里拿，全局隊(duì)列里別的goroutine前移

感謝各位的閱讀！關(guān)于“Go并發(fā)中g(shù)oroutine模型與調(diào)度策略的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！