快捷導(dǎo)航

Go語言sync.Cond使用方法詳解

更新時間：2023年07月18日 11:15:48 作者：碼一行

Go語言標(biāo)準(zhǔn)庫中還包含條件變量 sync.Cond，它可以讓一組 Goroutine 都在滿足特定條件時被喚醒，每一個sync.Cond結(jié)構(gòu)體在初始化時都需要傳入一個互斥鎖，接下來我們將通過文中例子了解它的使用方法，感興趣的同學(xué)跟著小編一起來看看吧

概述

每一個sync.Cond結(jié)構(gòu)體在初始化時都需要傳入一個互斥鎖，我們可以通過下面的例子了解它的使用方法：

var status int64
func main(){
    c := sync.NewCond(&sync.mutex{})
    for i := 0; i < 10; i++ {
        go listen(c)
    }
    time.Sleep(1 * time.Second)
    go broadcast(c)
    ch := make(chan os.Signal, 1)
    signal.Notify(ch, os.Interrupt)
    <-ch
}
func broadcast(c *sync.Cond) {
    c.L.Lock()
    atomic.StoreInt64(&status, 1)
    c.Broadcast()
    c.L.Unlock()
}
func listen(c *sync.Cond) {
    c.L.Lock()
    for atomic.LoadInt64(&status) != 1 {
        c.Wait()
    }
    fmt.Println("listen")
    c.L.Unlock()
}

運行結(jié)果：

listen
...
listen

上述代碼同時運行了 11 個Goroutine，它們分別做了不同事情：

10個Goroutine通過sync.Cond.Wait等待特定條件滿足
1個Goroutine會調(diào)用sync.Cond.Broadcast喚醒所有陷入等待的Goroutine

調(diào)用sync.Cond.Broadcast方法后，上述代碼會打印出10次 "listen" 并結(jié)束調(diào)用。

結(jié)構(gòu)體

sync.Cond的結(jié)構(gòu)體中包含以下 4 個字段：

type Cond struct {
    noCopy   noCopy
    L        Locker
    notify   notifyList
    checker  copyChecker
}

noCopy —— 用于保證結(jié)構(gòu)體不會在編譯期間復(fù)制
L —— 用于保護內(nèi)部的 notify 字段，Locker 接口類型的變量
notify —— 一個 Goroutine 的鏈表，它是實現(xiàn)同步機制的核心結(jié)構(gòu)
copyChecker —— 用于禁止運行期間發(fā)生的復(fù)制

type notifyList struct {
    wait   uint32
    notify uint32
    lock   mutex
    head   *sudog
    tail   *sudog
}

在sync.notifyList結(jié)構(gòu)體中，head和tail分別指向鏈表的頭和尾，wait和notify分別表示當(dāng)前正在等待的和已經(jīng)通知的Goroutine的索引。

接口

sync.Cond對外暴露的sync.Cond.Wait方法會令當(dāng)前Goroutine陷入休眠狀態(tài)，它的執(zhí)行過程分成以下兩個步驟：

調(diào)用runtime.notifyListAdd將等待計時器加一并解鎖
調(diào)用runtime.notifyListWait等待其他Goroutine被喚醒并對其加鎖

func (c *Cond) Wait () {
    c.checker.check()
    t := runtime_notifyListAdd(&c.notify)  // runtime.notifyListAdd 的鏈接名
    c.L.Unlock()
    runtime_notifyListWait(&c.notify, t)   //runtime.notifyListWait 的鏈接名
    c.L.Lock()
}
func notifyListAdd(l *notifyList) uint32 {
    return atomic.Xadd(&l.wait, 1) - 1
}

runtime.notifyListWait 會獲取當(dāng)前Goroutine并將它追加到Goroutine通知鏈表的末端：

func notifyListWait(l *notifyList, t uint32) {
    s := acquireSudog()
    s.g = getg()
    s.ticket = t
    if l.tail == nil {
        l.head = s
    } else {
        l.tail.next = s
    }
    l.tail = s
    goparkunlock(&l.lock, waitReasonSyncCondWait, traceEvGoBlockCond, 3)
    releaseSudog(s)
}

除了將當(dāng)前Goroutine追加到鏈表末端外，我們還會調(diào)用runtime.goparkunlock令當(dāng)前Goroutine陷入休眠。該函數(shù)也是在Go語言切換Goroutine時常用的方法，它會直接讓出當(dāng)前處理器的使用權(quán)并等待調(diào)度器喚醒。

sync.Cond.Signal和sync.Cond.Broadcast方法就是用來喚醒陷入休眠的Goroutine的，它們的實現(xiàn)有一些細微差別：

sync.Cond.Signal方法會喚醒隊列最前面的Goroutine
sync.Cond.Broadcast方法會喚醒隊列中全部Goroutine

func (c *Cond) Signal() {
    c.checker.check()
    runtime_notifyListNotifyOne(&c.notify)
}
func (c *Cond) Broadcast() {
    c.checker.check()
    runtime_notifyListNotifyAll(&c.notify)
}

runtime.notifyListNotifyOne只會從sync.notifyList鏈表中找到滿足sudog.ticket == l.notify條件的Goroutine，并通過runtime.readyWithTime將其喚醒：

func notifyListNotifyOne(l *notifyList) {
    t := l.notify
    atomic.Store(&l.notify, t + 1)
    for p, s := (*sudog)(nil), l.head; s != nil; p, s = s, s.next {
        if s.tiket == t {
            n := s.next
            if p != nil {
                p.next = n
            } else {
                l.head = n
            }
            if n == nil {
                l.tail = p
            }
            s.next = nil
            readyWithTime(s, 4)
            return
        }
    }
}

runtime.notifyListNotifyAll會依次通過runtime.readyWithTime喚醒鏈表中的Goroutine：

func notifyListNotifyAll(l *notifyList) {
    s := l.head
    l.head = nil
    l.tail = nil
    atomic.Store(&l.notify, atomic.Load(&l.wait))
    for s != nil {
        next := s.next
        s.next = nil
        readyWithTime(s, 4)
        s = next
    }
}

Goroutine的喚醒順序也是按照加入隊列的先后順序，先加入的會先被喚醒，而后加入的Goroutine可能需要等待調(diào)度器的調(diào)度。

一般情況下，我們會先調(diào)用sync.Cond.Wait陷入休眠等待滿足期望條件，當(dāng)滿足期望條件時，就可以選用sync.Cond.Signal或者sync.Cond.Broadcast喚醒一個或者全部Goroutine。