Goroutine調(diào)度是一個(gè)很復(fù)雜的機(jī)制,下面嘗試用簡單的語言描述一下Goroutine調(diào)度機(jī)制,想要對其有更深入的了解可以去研讀一下源碼。
成都創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),都昌企業(yè)網(wǎng)站建設(shè),都昌品牌網(wǎng)站建設(shè),網(wǎng)站定制,都昌網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,都昌網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿,時(shí)刻以成就客戶成長自我,堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
首先介紹一下GMP什么意思:
G ----------- goroutine: 即Go協(xié)程,每個(gè)go關(guān)鍵字都會(huì)創(chuàng)建一個(gè)協(xié)程。
M ---------- thread內(nèi)核級線程,所有的G都要放在M上才能運(yùn)行。
P ----------- processor處理器,調(diào)度G到M上,其維護(hù)了一個(gè)隊(duì)列,存儲(chǔ)了所有需要它來調(diào)度的G。
Goroutine 調(diào)度器P和 OS 調(diào)度器是通過 M 結(jié)合起來的,每個(gè) M 都代表了 1 個(gè)內(nèi)核線程,OS 調(diào)度器負(fù)責(zé)把內(nèi)核線程分配到 CPU 的核上執(zhí)行
模型圖:
避免頻繁的創(chuàng)建、銷毀線程,而是對線程的復(fù)用。
1)work stealing機(jī)制
當(dāng)本線程無可運(yùn)行的G時(shí),嘗試從其他線程綁定的P偷取G,而不是銷毀線程。
2)hand off機(jī)制
當(dāng)本線程M0因?yàn)镚0進(jìn)行系統(tǒng)調(diào)用阻塞時(shí),線程釋放綁定的P,把P轉(zhuǎn)移給其他空閑的線程執(zhí)行。進(jìn)而某個(gè)空閑的M1獲取P,繼續(xù)執(zhí)行P隊(duì)列中剩下的G。而M0由于陷入系統(tǒng)調(diào)用而進(jìn)被阻塞,M1接替M0的工作,只要P不空閑,就可以保證充分利用CPU。M1的來源有可能是M的緩存池,也可能是新建的。當(dāng)G0系統(tǒng)調(diào)用結(jié)束后,根據(jù)M0是否能獲取到P,將會(huì)將G0做不同的處理:
如果有空閑的P,則獲取一個(gè)P,繼續(xù)執(zhí)行G0。
如果沒有空閑的P,則將G0放入全局隊(duì)列,等待被其他的P調(diào)度。然后M0將進(jìn)入緩存池睡眠。
如下圖
GOMAXPROCS設(shè)置P的數(shù)量,最多有GOMAXPROCS個(gè)線程分布在多個(gè)CPU上同時(shí)運(yùn)行
在Go中一個(gè)goroutine最多占用CPU 10ms,防止其他goroutine被餓死。
具體可以去看另一篇文章
【Golang詳解】go語言調(diào)度機(jī)制 搶占式調(diào)度
當(dāng)創(chuàng)建一個(gè)新的G之后優(yōu)先加入本地隊(duì)列,如果本地隊(duì)列滿了,會(huì)將本地隊(duì)列的G移動(dòng)到全局隊(duì)列里面,當(dāng)M執(zhí)行work stealing從其他P偷不到G時(shí),它可以從全局G隊(duì)列獲取G。
協(xié)程經(jīng)歷過程
我們創(chuàng)建一個(gè)協(xié)程 go func()經(jīng)歷過程如下圖:
說明:
這里有兩個(gè)存儲(chǔ)G的隊(duì)列,一個(gè)是局部調(diào)度器P的本地隊(duì)列、一個(gè)是全局G隊(duì)列。新創(chuàng)建的G會(huì)先保存在P的本地隊(duì)列中,如果P的本地隊(duì)列已經(jīng)滿了就會(huì)保存在全局的隊(duì)列中;處理器本地隊(duì)列是一個(gè)使用數(shù)組構(gòu)成的環(huán)形鏈表,它最多可以存儲(chǔ) 256 個(gè)待執(zhí)行任務(wù)。
G只能運(yùn)行在M中,一個(gè)M必須持有一個(gè)P,M與P是1:1的關(guān)系。M會(huì)從P的本地隊(duì)列彈出一個(gè)可執(zhí)行狀態(tài)的G來執(zhí)行,如果P的本地隊(duì)列為空,就會(huì)想其他的MP組合偷取一個(gè)可執(zhí)行的G來執(zhí)行;
一個(gè)M調(diào)度G執(zhí)行的過程是一個(gè)循環(huán)機(jī)制;會(huì)一直從本地隊(duì)列或全局隊(duì)列中獲取G
上面說到P的個(gè)數(shù)默認(rèn)等于CPU核數(shù),每個(gè)M必須持有一個(gè)P才可以執(zhí)行G,一般情況下M的個(gè)數(shù)會(huì)略大于P的個(gè)數(shù),這多出來的M將會(huì)在G產(chǎn)生系統(tǒng)調(diào)用時(shí)發(fā)揮作用。類似線程池,Go也提供一個(gè)M的池子,需要時(shí)從池子中獲取,用完放回池子,不夠用時(shí)就再創(chuàng)建一個(gè)。
work-stealing調(diào)度算法:當(dāng)M執(zhí)行完了當(dāng)前P的本地隊(duì)列隊(duì)列里的所有G后,P也不會(huì)就這么在那躺尸啥都不干,它會(huì)先嘗試從全局隊(duì)列隊(duì)列尋找G來執(zhí)行,如果全局隊(duì)列為空,它會(huì)隨機(jī)挑選另外一個(gè)P,從它的隊(duì)列里中拿走一半的G到自己的隊(duì)列中執(zhí)行。
如果一切正常,調(diào)度器會(huì)以上述的那種方式順暢地運(yùn)行,但這個(gè)世界沒這么美好,總有意外發(fā)生,以下分析goroutine在兩種例外情況下的行為。
Go runtime會(huì)在下面的goroutine被阻塞的情況下運(yùn)行另外一個(gè)goroutine:
用戶態(tài)阻塞/喚醒
當(dāng)goroutine因?yàn)閏hannel操作或者network I/O而阻塞時(shí)(實(shí)際上golang已經(jīng)用netpoller實(shí)現(xiàn)了goroutine網(wǎng)絡(luò)I/O阻塞不會(huì)導(dǎo)致M被阻塞,僅阻塞G,這里僅僅是舉個(gè)栗子),對應(yīng)的G會(huì)被放置到某個(gè)wait隊(duì)列(如channel的waitq),該G的狀態(tài)由_Gruning變?yōu)開Gwaitting,而M會(huì)跳過該G嘗試獲取并執(zhí)行下一個(gè)G,如果此時(shí)沒有可運(yùn)行的G供M運(yùn)行,那么M將解綁P,并進(jìn)入sleep狀態(tài);當(dāng)阻塞的G被另一端的G2喚醒時(shí)(比如channel的可讀/寫通知),G被標(biāo)記為,嘗試加入G2所在P的runnext(runnext是線程下一個(gè)需要執(zhí)行的 Goroutine。), 然后再是P的本地隊(duì)列和全局隊(duì)列。
系統(tǒng)調(diào)用阻塞
當(dāng)M執(zhí)行某一個(gè)G時(shí)候如果發(fā)生了阻塞操作,M會(huì)阻塞,如果當(dāng)前有一些G在執(zhí)行,調(diào)度器會(huì)把這個(gè)線程M從P中摘除,然后再創(chuàng)建一個(gè)新的操作系統(tǒng)的線程(如果有空閑的線程可用就復(fù)用空閑線程)來服務(wù)于這個(gè)P。當(dāng)M系統(tǒng)調(diào)用結(jié)束時(shí)候,這個(gè)G會(huì)嘗試獲取一個(gè)空閑的P執(zhí)行,并放入到這個(gè)P的本地隊(duì)列。如果獲取不到P,那么這個(gè)線程M變成休眠狀態(tài), 加入到空閑線程中,然后這個(gè)G會(huì)被放入全局隊(duì)列中。
隊(duì)列輪轉(zhuǎn)
可見每個(gè)P維護(hù)著一個(gè)包含G的隊(duì)列,不考慮G進(jìn)入系統(tǒng)調(diào)用或IO操作的情況下,P周期性的將G調(diào)度到M中執(zhí)行,執(zhí)行一小段時(shí)間,將上下文保存下來,然后將G放到隊(duì)列尾部,然后從隊(duì)列中重新取出一個(gè)G進(jìn)行調(diào)度。
除了每個(gè)P維護(hù)的G隊(duì)列以外,還有一個(gè)全局的隊(duì)列,每個(gè)P會(huì)周期性地查看全局隊(duì)列中是否有G待運(yùn)行并將其調(diào)度到M中執(zhí)行,全局隊(duì)列中G的來源,主要有從系統(tǒng)調(diào)用中恢復(fù)的G。之所以P會(huì)周期性地查看全局隊(duì)列,也是為了防止全局隊(duì)列中的G被餓死。
除了每個(gè)P維護(hù)的G隊(duì)列以外,還有一個(gè)全局的隊(duì)列,每個(gè)P會(huì)周期性地查看全局隊(duì)列中是否有G待運(yùn)行并將其調(diào)度到M中執(zhí)行,全局隊(duì)列中G的來源,主要有從系統(tǒng)調(diào)用中恢復(fù)的G。之所以P會(huì)周期性地查看全局隊(duì)列,也是為了防止全局隊(duì)列中的G被餓死。
M0
M0是啟動(dòng)程序后的編號為0的主線程,這個(gè)M對應(yīng)的實(shí)例會(huì)在全局變量rutime.m0中,不需要在heap上分配,M0負(fù)責(zé)執(zhí)行初始化操作和啟動(dòng)第一個(gè)G,在之后M0就和其他的M一樣了
G0
G0是每次啟動(dòng)一個(gè)M都會(huì)第一個(gè)創(chuàng)建的goroutine,G0僅用于負(fù)責(zé)調(diào)度G,G0不指向任何可執(zhí)行的函數(shù),每個(gè)M都會(huì)有一個(gè)自己的G0,在調(diào)度或系統(tǒng)調(diào)用時(shí)會(huì)使用G0的??臻g,全局變量的G0是M0的G0
一個(gè)G由于調(diào)度被中斷,此后如何恢復(fù)?
中斷的時(shí)候?qū)⒓拇嫫骼锏臈P畔?,保存到自己的G對象里面。當(dāng)再次輪到自己執(zhí)行時(shí),將自己保存的棧信息復(fù)制到寄存器里面,這樣就接著上次之后運(yùn)行了。
我這里只是根據(jù)自己的理解進(jìn)行了簡單的介紹,想要詳細(xì)了解有關(guān)GMP的底層原理可以去看Go調(diào)度器 G-P-M 模型的設(shè)計(jì)者的文檔或直接看源碼
參考: ()
()
類型 在變量名后邊
也可不顯式聲明類型, 類型推斷, 但是是靜態(tài)語言, name一開始放字符串就不能再賦值數(shù)字
方法,屬性 分開 方法名首字母大寫就是就是外部可調(diào)的
面向?qū)ο笤O(shè)計(jì)的一個(gè)重要原則:“優(yōu)先使用組合而不是繼承”
Dog 也是Animal , 要復(fù)用Animal 的屬性和方法,
只需要在結(jié)構(gòu)體 type 里面寫 Animal
入口也是main, 用用試試
多態(tài), 有這個(gè)方法就是這個(gè)接口的實(shí)現(xiàn), 具體的類 不需要知道自己實(shí)現(xiàn)了什么接口,
使用: 在一個(gè)函數(shù)調(diào)用之前加上關(guān)鍵字go 就啟動(dòng)了一個(gè)goroutine
創(chuàng)建一個(gè)goroutine,它會(huì)被加入到一個(gè)全局的運(yùn)行隊(duì)列當(dāng)中,
調(diào)度器 會(huì)把他們分配給某個(gè) 邏輯處理器 的隊(duì)列,
一個(gè)邏輯處理器 綁定到一個(gè) 操作系統(tǒng)線程 ,在上面運(yùn)行g(shù)oroutine,
如果goroutine需要讀寫文件, 阻塞 ,就脫離邏輯處理器 直接 goroutine - 系統(tǒng)線程 綁定
編譯成同名.exe 來執(zhí)行, 不通過虛擬機(jī), 直接是機(jī)器碼, 和C 一樣, 所以非常快
但是也有自動(dòng)垃圾回收,每個(gè)exe文件當(dāng)中已經(jīng)包含了一個(gè)類似于虛擬機(jī)的runtime,進(jìn)行g(shù)oroutine的調(diào)度
默認(rèn)是靜態(tài)鏈接的,那個(gè)exe會(huì)把運(yùn)行時(shí)所需要的所有東西都加進(jìn)去,這樣就可以把exe復(fù)制到任何地方去運(yùn)行了, 因此 生成的 .exe 文件非常大
參考:
Goroutine并發(fā)調(diào)度模型深度解析手?jǐn)]一個(gè)協(xié)程池
Golang 的 goroutine 是如何實(shí)現(xiàn)的?
Golang - 調(diào)度剖析【第二部分】
OS線程初始棧為2MB。Go語言中,每個(gè)goroutine采用動(dòng)態(tài)擴(kuò)容方式,初始2KB,按需增長,最大1G。此外GC會(huì)收縮??臻g。
BTW,增長擴(kuò)容都是有代價(jià)的,需要copy數(shù)據(jù)到新的stack,所以初始2KB可能有些性能問題。
更多關(guān)于stack的內(nèi)容,可以參見大佬的文章。 聊一聊goroutine stack
用戶線程的調(diào)度以及生命周期管理都是用戶層面,Go語言自己實(shí)現(xiàn)的,不借助OS系統(tǒng)調(diào)用,減少系統(tǒng)資源消耗。
Go語言采用兩級線程模型,即用戶線程與內(nèi)核線程KSE(kernel scheduling entity)是M:N的。最終goroutine還是會(huì)交給OS線程執(zhí)行,但是需要一個(gè)中介,提供上下文。這就是G-M-P模型
Go調(diào)度器有兩個(gè)不同的運(yùn)行隊(duì)列:
go1.10\src\runtime\runtime2.go
Go調(diào)度器根據(jù)事件進(jìn)行上下文切換。
調(diào)度的目的就是防止M堵塞,空閑,系統(tǒng)進(jìn)程切換。
詳見 Golang - 調(diào)度剖析【第二部分】
Linux可以通過epoll實(shí)現(xiàn)網(wǎng)絡(luò)調(diào)用,統(tǒng)稱網(wǎng)絡(luò)輪詢器N(Net Poller)。
文件IO操作
上面都是防止M堵塞,任務(wù)竊取是防止M空閑
每個(gè)M都有一個(gè)特殊的G,g0。用于執(zhí)行調(diào)度,gc,棧管理等任務(wù),所以g0的棧稱為調(diào)度棧。g0的棧不會(huì)自動(dòng)增長,不會(huì)被gc,來自os線程的棧。
go1.10\src\runtime\proc.go
G沒辦法自己運(yùn)行,必須通過M運(yùn)行
M通過通過調(diào)度,執(zhí)行G
從M掛載P的runq中找到G,執(zhí)行G
內(nèi)核線程(Kernel-Level Thread ,KLT)
輕量級進(jìn)程(Light Weight Process,LWP):輕量級進(jìn)程就是我們通常意義上所講的線程,由于每個(gè)輕量級進(jìn)程都由一個(gè)內(nèi)核線程支持,因此只有先支持內(nèi)核線程,才能有輕量級進(jìn)程
用戶線程與系統(tǒng)線程一一對應(yīng),用戶線程執(zhí)行如lo操作的系統(tǒng)調(diào)用時(shí),來回切換操作開銷相對比較大
多個(gè)用戶線程對應(yīng)一個(gè)內(nèi)核線程,當(dāng)內(nèi)核線程對應(yīng)的一個(gè)用戶線程被阻塞掛起時(shí)候,其他用戶線程也阻塞不能執(zhí)行了。
多對多模型是可以充分利用多核CPU提升運(yùn)行效能的
go線程模型包含三個(gè)概念:內(nèi)核線程(M),goroutine(G),G的上下文環(huán)境(P);
GMP模型是goalng特有的。
P與M一般是一一對應(yīng)的。P(上下文)管理著一組G(goroutine)掛載在M(內(nèi)核線程)上運(yùn)行,圖中左邊藍(lán)色為正在執(zhí)行狀態(tài)的goroutine,右邊為待執(zhí)行狀態(tài)的goroutiine隊(duì)列。P的數(shù)量由環(huán)境變量GOMAXPROCS的值或程序運(yùn)行runtime.GOMAXPROCS()進(jìn)行設(shè)置。
當(dāng)一個(gè)os線程在執(zhí)行M1一個(gè)G1發(fā)生阻塞時(shí),調(diào)度器讓M1拋棄P,等待G1返回,然后另起一個(gè)M2接收P來執(zhí)行剩下的goroutine隊(duì)列(G2、G3...),這是golang調(diào)度器厲害的地方,可以保證有足夠的線程來運(yùn)行剩下所有的goroutine。
當(dāng)G1結(jié)束后,M1會(huì)重新拿回P來完成,如果拿不到就丟到全局runqueue中,然后自己放到線程池或轉(zhuǎn)入休眠狀態(tài)??臻e的上下文P會(huì)周期性的檢查全局runqueue上的goroutine,并且執(zhí)行它。
另一種情況就是當(dāng)有些P1太閑而其他P2很忙碌的時(shí)候,會(huì)從其他上下文P2拿一些G來執(zhí)行。
詳細(xì)可以翻看下方第一個(gè)參考鏈接,寫得真好。
最后用大佬的總結(jié)來做最后的收尾————
Go語言運(yùn)行時(shí),通過核心元素G,M,P 和 自己的調(diào)度器,實(shí)現(xiàn)了自己的并發(fā)線程模型。調(diào)度器通過對G,M,P的調(diào)度實(shí)現(xiàn)了兩級線程模型中操作系統(tǒng)內(nèi)核之外的調(diào)度任務(wù)。整個(gè)調(diào)度過程中會(huì)在多種時(shí)機(jī)去觸發(fā)最核心的步驟 “一整輪調(diào)度”,而一整輪調(diào)度中最關(guān)鍵的部分在“全力查找可運(yùn)行G”,它保證了M的高效運(yùn)行(換句話說就是充分使用了計(jì)算機(jī)的物理資源),一整輪調(diào)度中還會(huì)涉及到M的啟用停止。最后別忘了,還有一個(gè)與Go程序生命周期相同的系統(tǒng)監(jiān)測任務(wù)來進(jìn)行一些輔助性的工作。
淺析Golang的線程模型與調(diào)度器
Golang CSP并發(fā)模型
Golang線程模型
Go有四大核心模塊,基本全部體現(xiàn)在runtime,有調(diào)度系統(tǒng)、GC、goroutine、channel,那么深入理解其中的精髓可以幫助我們理解Go這一門語言!
參考: 調(diào)度系統(tǒng)設(shè)計(jì)精要
下面是我用Go語言簡單寫的一個(gè)調(diào)度器,大家可以看看設(shè)計(jì)思路,以及存在的問題!
1、測試條件,調(diào)度器只啟動(dòng)兩個(gè)線程,然后一個(gè)線程主要是負(fù)責(zé)循環(huán)的添加任務(wù),一個(gè)線程循環(huán)的去執(zhí)行任務(wù)
2、測試條件,調(diào)度器啟動(dòng)三個(gè)線程,然后兩個(gè)線程去執(zhí)行任務(wù),一個(gè)添加任務(wù)
3、繼續(xù)測試,啟動(dòng)十個(gè)線程,一個(gè)添加任務(wù),九個(gè)執(zhí)行任務(wù)
4、我們添加一些阻塞的任務(wù)
執(zhí)行可以看到完全不可用
1、 可以看到隨著M的不斷的增加,可以發(fā)現(xiàn)執(zhí)行任務(wù)的數(shù)量也不斷的減少,原因是什么呢?有興趣的同學(xué)可以加一個(gè)pprof可以看看,其實(shí)大量的在等待鎖的過程!
2、如果我的M運(yùn)行了類似于Sleep操作的方法如何解決了,我的調(diào)度器還能支撐這個(gè)量級的調(diào)度嗎?
關(guān)于pprof如何使用:在代碼頭部加一個(gè)這個(gè)代碼:
我們查看一下 go tool pprof main/prof.pporf
可以看到真正執(zhí)行代碼的時(shí)間只有 0.17s + 0.02s 其他時(shí)間都被阻塞掉了!
1、GM模型中的所有G都是放入到一個(gè)queue,那么導(dǎo)致所有的M取執(zhí)行任務(wù)時(shí)都會(huì)去競爭鎖,我們插入G也會(huì)去競爭鎖,所以解決這種問題一般就是減少對單一資源的競爭,那就是桶化,其實(shí)就是每個(gè)線程都分配一個(gè)隊(duì)列
2、GM模型中沒有任務(wù)狀態(tài),只有runnable,假如任務(wù)遇到阻塞,完全可以把任務(wù)掛起再喚醒
這里其實(shí)會(huì)遇到一個(gè)問題,假如要分配很多個(gè)線程,那么此時(shí)隨著線程的增加,也會(huì)造成隊(duì)列的增加,其實(shí)也會(huì)造成調(diào)度器的壓力,因?yàn)樗枰闅v全部線程的隊(duì)列去分配任務(wù)以及后續(xù)會(huì)講到的竊取任務(wù)!
因?yàn)槲覀冎繡PU的最大并行度其實(shí)取決于CPU的核數(shù),也就是我們沒必要為每個(gè)線程都去分配一個(gè)隊(duì)列,因?yàn)榫退闶墙o他們分配了,他們自己去那執(zhí)行調(diào)度,其實(shí)也會(huì)出現(xiàn)大量阻塞,原因就是CPU調(diào)度不過來這些線程!
Go里面是只分配了CPU個(gè)數(shù)的隊(duì)列,這里就是P這個(gè)概念,你可以理解為P其實(shí)是真正的資源分配器,M很輕只是執(zhí)行程序,所有的資源內(nèi)存都維護(hù)在P上!M只有綁定P才能執(zhí)行任務(wù)(強(qiáng)制的)!
這樣做的好處:
1、首先調(diào)度程序其實(shí)就是調(diào)度不同狀態(tài)的任務(wù),go里面為Go標(biāo)記了不同的狀態(tài),其實(shí)大概就是分為:runnable,running,block等,所以如何充分調(diào)度不同狀態(tài)的G成了問題,那么關(guān)于阻塞的G如何解決,其實(shí)可以很好的解決G調(diào)度的問題!
上面這些情況其實(shí)就分為:
2、用戶態(tài)阻塞,一般Go里面依靠 gopark 函數(shù)去實(shí)現(xiàn),大體的代碼邏輯基本上和go的調(diào)度綁定死了
源碼在:
3、其實(shí)對于netpool 這種nio模型,其實(shí)內(nèi)核調(diào)用是非阻塞的,所以go開辟了一個(gè)網(wǎng)絡(luò)輪訓(xùn)器隊(duì)列,來存放這些被阻塞的g,等待內(nèi)核被喚醒!那么什么時(shí)候會(huì)被喚醒了,其實(shí)就是需要等待調(diào)度器去調(diào)度了!
4、如果是內(nèi)核態(tài)阻塞了(內(nèi)核態(tài)阻塞一般都會(huì)將線程掛起,線程需要等待被喚醒),我們此時(shí)P只能放棄此線程的權(quán)利,然后再找一個(gè)新的線程去運(yùn)行P!
關(guān)于著新線程:找有沒有idle的線程,沒有就會(huì)創(chuàng)建一個(gè)新的線程!
關(guān)于當(dāng)內(nèi)核被喚醒后的操作:因?yàn)镚PM模型所以需要找到個(gè)P綁定,所以G會(huì)去嘗試找一個(gè)可用的P,如果沒有可用的P,G會(huì)標(biāo)記為runnable放到全局隊(duì)列中!
5、其實(shí)了解上面大致其實(shí)就了解了Go的基本調(diào)度模型
答案文章里慢慢品味!
如果某個(gè) G 執(zhí)行時(shí)間過長,其他的 G 如何才能被正常的調(diào)度? 這便涉及到有關(guān)調(diào)度的兩個(gè)理念:協(xié)作式調(diào)度與搶占式調(diào)度。協(xié)作式和搶占式這兩個(gè)理念解釋起來很簡單: 協(xié)作式調(diào)度依靠被調(diào)度方主動(dòng)棄權(quán);搶占式調(diào)度則依靠調(diào)度器強(qiáng)制將被調(diào)度方被動(dòng)中斷。
例如下面的代碼,我本地的版本是 go1.13.5
執(zhí)行: GOMAXPROCS=1 配置全局只能有一個(gè)P
可以看到main函數(shù)無法執(zhí)行!也就是那個(gè)go 空轉(zhuǎn)搶占了整個(gè)程序
備注:
但是假如我換為用 1.14+版本執(zhí)行,有興趣的話可以使用我的docker鏡像,直接可以拉取: fanhaodong/golang:1.15.11 和 fanhaodong/golang:1.13.5
首先我們知道G/M/P,G可能和M也可能和P解除綁定,那么關(guān)于數(shù)據(jù)變量放在哪哇!其實(shí)這個(gè)就是逃逸分析!
輸出可以看到其實(shí)沒有發(fā)生逃逸,那是因?yàn)?demo被拷貝它自己的??臻g內(nèi)
備注:
-gcflags"-N -l -m" 其中 -N禁用優(yōu)化-l禁止內(nèi)聯(lián)優(yōu)化,-m打印逃逸信息
那么繼續(xù)改成這個(gè)
可以看到發(fā)現(xiàn) demo對象其實(shí)被逃逸到了堆上!這就是不會(huì)出現(xiàn)類似于G如果被別的M執(zhí)行,其實(shí)不會(huì)出現(xiàn)內(nèi)存分配位置的問題!
所以可以看到demo其實(shí)是copy到了堆上!這就是g逃逸的問題,和for循環(huán)一樣的
執(zhí)行可以發(fā)現(xiàn),其實(shí)x已經(jīng)逃逸到了堆上,所以你所有的g都引用的一個(gè)對象,如何解決了
如何解決了,其實(shí)很簡單
也談goroutine調(diào)度器
圖解Go運(yùn)行時(shí)調(diào)度器
Go語言回顧:從Go 1.0到Go 1.13
Go語言原本
調(diào)度系統(tǒng)設(shè)計(jì)精要
Scalable Go Scheduler Design Doc
線程:
多線程是為了解決CPU利用率的問題,線程則是為了減少上下文切換時(shí)的開銷,進(jìn)程和線程在Linux中沒有本質(zhì)區(qū)別,最大的不同就是進(jìn)程有自己獨(dú)立的內(nèi)存空間,而線程是共享內(nèi)存空間。
在進(jìn)程切換時(shí)需要轉(zhuǎn)換內(nèi)存地址空間,而線程切換沒有這個(gè)動(dòng)作,所以線程切換比進(jìn)程切換代價(jià)要小得多。
協(xié)程:
想要簡單,又要性能高,協(xié)程就可以達(dá)到我們的目的,它是用戶視角的一種抽象,操作系統(tǒng)并沒有這個(gè)概念,主要思想是在用戶態(tài)實(shí)現(xiàn)調(diào)度算法,用少量線程完成大量任務(wù)的調(diào)度。
Goroutine是GO語言實(shí)現(xiàn)的協(xié)程,其特點(diǎn)是在語言層面就支持,使用起來十分方便,它的核心是MPG調(diào)度模型:M即內(nèi)核線程;P即處理器,用來執(zhí)行Goroutine,它維護(hù)了本地可運(yùn)行隊(duì)列;G即Goroutine,代碼和數(shù)據(jù)結(jié)構(gòu);S及調(diào)度器,維護(hù)M和P的信息。
當(dāng)前題目:go語言的調(diào)度系統(tǒng) go語言 運(yùn)行
文章出自:http://aaarwkj.com/article46/doodgeg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供Google、定制網(wǎng)站、網(wǎng)站制作、網(wǎng)站營銷、網(wǎng)站設(shè)計(jì)、建站公司
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)