您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關Golang與.NET中怎么實現協程,文章內容質量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關知識有一定的了解。
實現下面的代碼可以顯式指定編譯器將goroutine調度到多個CPU上運行。
import "runtime"...runtime.GOMAXPROCS(4)
PS:runtime包中有幾個處理goroutine的函數,
函數 | 說明 |
Goexit | 退出當前執行的goroutine,但是defer函數還會繼續調用 |
Gosched | 讓出當前goroutine的執行權限,調度器安排其他等待的任務運行,并在下次某個時候從該位置恢復執行 |
NumCPU | 返回 CPU 核數量 |
NumGoroutine | 返回正在執行和排隊的任務總數 |
GOMAXPROCS | 用來設置可以并行計算的CPU核數的最大值,并返回之前的值 |
Go調度的幾個概念:
M:內核線程;
G:go routine,并發的最小邏輯單元,由程序員創建;
P:處理器,執行G的上下文環境,每個P會維護一個本地的go routine隊列;
除了每個P擁有一個本地的go routine隊列外,還存在一個全局的go routine隊列。
具體調度原理:
P的數量在初始化由GOMAXPROCS決定;
我們要做的就是添加G;
G的數量超出了M的處理能力,且還有空余P的話,runtime就會自動創建新的M;
M拿到P后才能干活,取G的順序:本地隊列>全局隊列>其他P的隊列,如果所有隊列都沒有可用的G,M會歸還P并進入休眠;
說到.NET的Task模型與Golang的協程大同小異:
M = Thread
G = Task
P = Processor
關于Golang與.NET中怎么實現協程就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。