快捷導(dǎo)航

golang?sync.Cond同步機(jī)制運(yùn)用及實(shí)現(xiàn)

更新時(shí)間：2023年09月27日 10:35:36 作者：lincoln_hlf1

在?Go?里有專門為同步通信而生的?channel,所以較少看到?sync.Cond?的使用,不過它也是并發(fā)控制手段里的一種,今天我們就來認(rèn)識下它的相關(guān)實(shí)現(xiàn),加深對同步機(jī)制的運(yùn)用

sync.Cond

Go同步通信channel

sync.Cond 提供了三個(gè)方法：Wait()、Signal()、Broadcast()，它們的用法如下：

Wait()：阻塞當(dāng)前的 goroutine，等待喚起。
Signal()：喚起一個(gè)阻塞的 goroutine。
Broadcast()：喚起所有阻塞的 goroutine。

通過上面的方法描述，我們就可以簡單的實(shí)現(xiàn)一個(gè)任務(wù)池功能：先批量的創(chuàng)建 goroutine，然后調(diào)用 sync.Cond 的 Wait() 方法讓其阻塞的等待。

當(dāng)有一個(gè)任務(wù)到來時(shí)，則通過 Signal() 喚起剛剛在阻塞的某一個(gè) goroutine，去執(zhí)行任務(wù)。

通過任務(wù)池功能，我們發(fā)現(xiàn) sync.Cond 的運(yùn)用很簡單，但 Go 官方并不推薦我們使用 sync.Cond 來實(shí)現(xiàn)協(xié)程間的同步通信。

因?yàn)樗⒉环?Go 官方 “通過通信來共享內(nèi)存” 的設(shè)計(jì)思想，當(dāng)場景復(fù)雜時(shí)，則會耦合各個(gè)業(yè)務(wù)功能。

sync.Cond 源碼分析

我們來看下 sync.Cond 的結(jié)構(gòu)體，代碼在 /sr/sync/cond.go 下：

type Cond struct {
    noCopy noCopy       // 不可復(fù)制
    L Locker            // 鎖
    notify  notifyList  // 通知喚起列表
    checker copyChecker // 復(fù)制檢測
}

可以看到 Cond 上有 notify 列表，而這正是維護(hù)了需要喚起的 goroutine 列表。

當(dāng)我們調(diào)用 Wait() 方法的時(shí)候就會維護(hù)當(dāng)前 goroutine 到對應(yīng)的 notifyList 里：

func (c *Cond) Wait() {
    c.checker.check()
    t := runtime_notifyListAdd(&amp;c.notify) // 將當(dāng)前 goroutine 添加到 notifyList 里
    c.L.Unlock()
    runtime_notifyListWait(&amp;c.notify, t) // 阻塞等待
    c.L.Lock()
}

當(dāng)有其他協(xié)程調(diào)用了 Signal 或 Broadcast 方法時(shí)，則會通過runtime_notifyListNotifyOne或runtime_notifyListNotifyAll方法來喚起一個(gè)或多個(gè) goroutine。