go語(yǔ)言任務(wù)編排 go語(yǔ)言工作流

Go語(yǔ)言——goroutine并發(fā)模型

1、Go語(yǔ)言采用兩級(jí)線程模型，即用戶線程與內(nèi)核線程KSE（kernel scheduling entity）是M：N的。最終goroutine還是會(huì)交給OS線程執(zhí)行，但是需要一個(gè)中介，提供上下文。

在城子河等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè) 網(wǎng)站設(shè)計(jì)制作按需網(wǎng)站開發(fā),公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),成都品牌網(wǎng)站建設(shè),成都全網(wǎng)營(yíng)銷,外貿(mào)營(yíng)銷網(wǎng)站建設(shè),城子河網(wǎng)站建設(shè)費(fèi)用合理。

2、Go的CSP并發(fā)模型，是通過(guò) goroutine和channel 來(lái)實(shí)現(xiàn)的。 goroutine 是Go語(yǔ)言中并發(fā)的執(zhí)行單位。其實(shí)就是協(xié)程。 channel是Go語(yǔ)言中各個(gè)并發(fā)結(jié)構(gòu)體(goroutine)之前的通信機(jī)制。

3、Go就是基因里面支持的并發(fā)，可以充分的利用多核，很容易的使用并發(fā)。內(nèi)置runtime，支持垃圾回收，這屬于動(dòng)態(tài)語(yǔ)言的特性之一吧，雖然目前來(lái)說(shuō)GC不算完美，但是足以應(yīng)付我們所能遇到的大多數(shù)情況，特別是Go1之后的GC。

Golang的調(diào)度模型

多個(gè)協(xié)程分享操作系統(tǒng)分給線程的時(shí)間片，從而達(dá)到充分利用CPU的目的，協(xié)程調(diào)度器決定了則決定了協(xié)程運(yùn)行的順序。每個(gè)線程同一時(shí)刻只能運(yùn)行一個(gè)協(xié)程。

調(diào)度器為什么要維護(hù)多個(gè)上下文P 呢？ 因?yàn)楫?dāng)一個(gè)物理線程 M 被阻塞時(shí)，P 可以轉(zhuǎn)而投奔另一個(gè)OS線程 M （即 P 帶著 G 連莖拔起，去另一個(gè) M 節(jié)點(diǎn)下運(yùn)行）。這是 Golang調(diào)度器厲害的地方，也是高并發(fā)能力的保障。

Go語(yǔ)言運(yùn)行時(shí)，通過(guò)核心元素G，M，P 和 自己的調(diào)度器，實(shí)現(xiàn)了自己的并發(fā)線程模型。調(diào)度器通過(guò)對(duì)G，M，P的調(diào)度實(shí)現(xiàn)了兩級(jí)線程模型中操作系統(tǒng)內(nèi)核之外的調(diào)度任務(wù)。

原文出自： Golang調(diào)度器GPM原理與調(diào)度全分析 M想要執(zhí)行、放回G都必須訪問(wèn)全局G隊(duì)列，并且M有多個(gè)，即多線程訪問(wèn)同一資源需要加鎖進(jìn)行保證互斥/同步，所以全局G隊(duì)列是有互斥鎖進(jìn)行保護(hù)的。

Go語(yǔ)言采用兩級(jí)線程模型，即用戶線程與內(nèi)核線程KSE（kernel scheduling entity）是M：N的。最終goroutine還是會(huì)交給OS線程執(zhí)行，但是需要一個(gè)中介，提供上下文。

Go語(yǔ)言基于Etcd實(shí)現(xiàn)的定時(shí)任務(wù)

利用 Etcd 的Lease租約特性來(lái)實(shí)現(xiàn)定時(shí)功能，同時(shí)通過(guò)Watch機(jī)制來(lái)實(shí)現(xiàn)多節(jié)點(diǎn)情況下只有一個(gè)節(jié)點(diǎn)執(zhí)行該任務(wù)。通過(guò)定時(shí)任務(wù)庫(kù) Cron 的時(shí)間字符串解析器Parser來(lái)解析任務(wù)執(zhí)行時(shí)間。

這時(shí)候，我們關(guān)閉這個(gè)任務(wù) 我們可以看到，關(guān)閉這個(gè)任務(wù)，不會(huì)影響正在執(zhí)行的任務(wù) 節(jié)點(diǎn)對(duì)應(yīng)的服務(wù)器上的任務(wù)也正常在跑 PS：這個(gè)關(guān)閉任務(wù)對(duì)應(yīng)的是，完成當(dāng)前任務(wù)后不再執(zhí)行新的任務(wù)。

這里的關(guān)鍵就是ETCD集群也可以有watch 機(jī)制，如果ApiServer1，寫入ETCD，ApiServer2能夠watch ETCD 的event的話，那就可以實(shí)現(xiàn)在ApiServer集群內(nèi)部的Event 同步了。下面是個(gè)簡(jiǎn)單的例子。

基于這樣的特性我們可以通過(guò)while死循環(huán)+sleep()的方式實(shí)現(xiàn)簡(jiǎn)單的定時(shí)任務(wù)。使用Timeloop庫(kù)運(yùn)行定時(shí)任務(wù)。Timeloop是一個(gè)庫(kù)，可用于運(yùn)行多周期任務(wù)。這是一個(gè)簡(jiǎn)單的庫(kù)，它使用decorator模式在線程中運(yùn)行標(biāo)記函數(shù)。

4．etcd項(xiàng)目 網(wǎng)址為 https：//github點(diǎn)抗 /coreos/etcd 。介紹：一款分布式、可靠的KV存儲(chǔ)系統(tǒng)，可以快速進(jìn)行云配置。5．beego項(xiàng)目 網(wǎng)址為 https：//github點(diǎn)抗 /astaxie/beego 。

當(dāng)前名稱：go語(yǔ)言任務(wù)編排 go語(yǔ)言工作流
轉(zhuǎn)載來(lái)源：http://bm7419.com/article46/dcgcchg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供電子商務(wù)、網(wǎng)站收錄、微信公眾號(hào)、微信小程序、App設(shè)計(jì)、用戶體驗(yàn)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)