建站
咨詢
售后
建站咨詢
新聞中心
本篇內(nèi)容主要講解“如何理解go-zero對Go中g(shù)oroutine支持的并發(fā)組件 ”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“如何理解go-zero對Go中g(shù)oroutine支持的并發(fā)組件 ”吧!
堅(jiān)守“ 做人真誠 · 做事靠譜 · 口碑至上 · 高效敬業(yè) ”的價(jià)值觀，專業(yè)網(wǎng)站建設(shè)服務(wù)10余年為成都LED顯示屏小微創(chuàng)業(yè)公司專業(yè)提供成都定制網(wǎng)頁設(shè)計(jì)營銷網(wǎng)站建設(shè)商城網(wǎng)站建設(shè)手機(jī)網(wǎng)站建設(shè)小程序網(wǎng)站建設(shè)網(wǎng)站改版，從內(nèi)容策劃、視覺設(shè)計(jì)、底層架構(gòu)、網(wǎng)頁布局、功能開發(fā)迭代于一體的高端網(wǎng)站建設(shè)服務(wù)。
threading
雖然 go func() 已經(jīng)很方便，但是有幾個(gè)問題：
如果協(xié)程異常退出，無法追蹤異常棧
某個(gè)異常請求觸發(fā)panic，應(yīng)該做故障隔離，而不是整個(gè)進(jìn)程退出，容易被攻擊
我們看看 core/threading 包提供了哪些額外選擇：
func GoSafe(fn func()) {
go RunSafe(fn)
}
func RunSafe(fn func()) {
defer rescue.Recover()
fn()
}
func Recover(cleanups ...func()) {
for _, cleanup := range cleanups {
cleanup()
}
if p := recover(); p != nil {
logx.ErrorStack(p)
}
}GoSafe
threading.GoSafe() 就幫你解決了這個(gè)問題。開發(fā)者可以將自己在協(xié)程中需要完成邏輯，以閉包的方式傳入，由 GoSafe() 內(nèi)部 go func()；
當(dāng)開發(fā)者的函數(shù)出現(xiàn)異常退出時(shí)，會(huì)在 Recover() 中打印異常棧，以便讓開發(fā)者更快確定異常發(fā)生點(diǎn)和調(diào)用棧。
NewWorkerGroup
我們再看第二個(gè)：WaitGroup。日常開發(fā)，其實(shí) WaitGroup 沒什么好說的，你需要 N 個(gè)協(xié)程協(xié)作 ：wg.Add(N) ，等待全部協(xié)程完成任務(wù)：wg.Wait()，同時(shí)完成一個(gè)任務(wù)需要手動(dòng) wg.Done()。
可以看的出來，在任務(wù)開始 -> 結(jié)束 -> 等待，整個(gè)過程需要開發(fā)者關(guān)注任務(wù)的狀態(tài)然后手動(dòng)修改狀態(tài)。
NewWorkerGroup 就幫開發(fā)者減輕了負(fù)擔(dān)，開發(fā)者只需要關(guān)注：
任務(wù)邏輯【函數(shù)】
任務(wù)數(shù)【
workers】
然后啟動(dòng) WorkerGroup.Start()，對應(yīng)任務(wù)數(shù)就會(huì)啟動(dòng)：
func (wg WorkerGroup) Start() {
// 包裝了sync.WaitGroup
group := NewRoutineGroup()
for i := 0; i < wg.workers; i++ {
// 內(nèi)部維護(hù)了 wg.Add(1) wg.Done()
// 同時(shí)也是 goroutine 安全模式下進(jìn)行的
group.RunSafe(wg.job)
}
group.Wait()
}worker 的狀態(tài)會(huì)自動(dòng)管理，可以用來固定數(shù)量的 worker 來處理消息隊(duì)列的任務(wù)，用法如下：
func main() {
group := NewWorkerGroup(func() {
// process tasks
}, runtime.NumCPU())
group.Start()
}Pool
這里的 Pool 不是 sync.Pool。sync.Pool 有個(gè)不方便的地方是它池化的對象可能會(huì)被垃圾回收掉，這個(gè)就讓開發(fā)者疑惑了，不知道自己創(chuàng)建并存入的對象什么時(shí)候就沒了。
go-zero 中的 pool：
pool中的對象會(huì)根據(jù)使用時(shí)間做懶銷毀；使用
cond做對象消費(fèi)和生產(chǎn)的通知以及阻塞；開發(fā)者可以自定義自己的生產(chǎn)函數(shù)，銷毀函數(shù)；
那我來看看生產(chǎn)對象，和消費(fèi)對象在 pool 中時(shí)怎么實(shí)現(xiàn)的：
func (p *Pool) Get() interface{} {
// 調(diào)用 cond.Wait 時(shí)必須要持有c.L的鎖
p.lock.Lock()
defer p.lock.Unlock()
for {
// 1. pool中對象池是一個(gè)用鏈表連接的nodelist
if p.head != nil {
head := p.head
p.head = head.next
// 1.1 如果當(dāng)前節(jié)點(diǎn)：當(dāng)前時(shí)間 >= 上次使用時(shí)間+對象最大存活時(shí)間
if p.maxAge > 0 && head.lastUsed+p.maxAge < timex.Now() {
p.created--
// 說明當(dāng)前節(jié)點(diǎn)已經(jīng)過期了 -> 銷毀節(jié)點(diǎn)對應(yīng)的對象，然后繼續(xù)尋找下一個(gè)節(jié)點(diǎn)
// 【??：不是銷毀節(jié)點(diǎn)，而是銷毀節(jié)點(diǎn)對應(yīng)的對象】
p.destroy(head.item)
continue
} else {
return head.item
}
}
// 2. 對象池是懶加載的，get的時(shí)候才去創(chuàng)建對象鏈表
if p.created < p.limit {
p.created++
// 由開發(fā)者自己傳入：生產(chǎn)函數(shù)
return p.create()
}
p.cond.Wait()
}
}func (p *Pool) Put(x interface{}) {
if x == nil {
return
}
// 互斥訪問 pool 中nodelist
p.lock.Lock()
defer p.lock.Unlock()
p.head = &node{
item: x,
next: p.head,
lastUsed: timex.Now(),
}
// 放入head，通知其他正在get的協(xié)程【極為關(guān)鍵】
p.cond.Signal()
}上述就是 go-zero 對 Cond 的使用?？梢灶惐?生產(chǎn)者-消費(fèi)者模型，只是在這里沒有使用 channel 做通信，而是用 Cond 。這里有幾個(gè)特性：
Cond和一個(gè)Locker關(guān)聯(lián)，可以利用這個(gè)Locker對相關(guān)的依賴條件更改提供保護(hù)。
Cond可以同時(shí)支持
Signal和Broadcast方法，而Channel只能同時(shí)支持其中一種。
到此，相信大家對“如何理解go-zero對Go中g(shù)oroutine支持的并發(fā)組件 ”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！
名稱欄目：如何理解go-zero對Go中g(shù)oroutine支持的并發(fā)組件?
標(biāo)題路徑：http://www.dlmjj.cn/article/pphjei.html
