Go中Sync.Cond的介紹和使用

本篇內容介紹了“Go中Sync.Cond的介紹和使用”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

創新互聯網站建設由有經驗的網站設計師、開發人員和項目經理組成的專業建站團隊，負責網站視覺設計、用戶體驗優化、交互設計和前端開發等方面的工作，以確保網站外觀精美、成都網站建設、網站建設易于使用并且具有良好的響應性。

1. 程序中的通信方式

GO語言中有句名言：“不要用共享內存來通信，而是使用通信來共享內存”。

編程語言中，通信方式分為進程間通信、線程間通信。

1.進程間通信，常用方式：

有名管道
無名管道
信號
共享內存
消息隊列
信號燈集
socket

2.線程間通信，常用方式：

信號量
互斥鎖
條件變量

對于Go語言來說，Go程序啟動之后對外是一個進程，內部包含若干協程，協程相當于用戶態輕量級線程，所以協程的通信方式大多可以使用線程間通信方式來完成。

協程間通信方式，官方推薦使用channel，channel在一對一的協程之間進行數據交換與通信十分便捷。但是，一對多的廣播場景中，則顯得有點無力，此時就需要sync.Cond來輔助。

2. 什么是廣播?

舉個例子，上高中時，宿管老師每天早晨需要叫醒學生們去上課。這個時候，有兩種解決方法：①一個寢室一個寢室的把學生叫醒。②在宿舍樓安裝個廣播，到起床時間時，在廣播上叫醒學生。顯然，使用廣播的方式效率更高。

編程中的廣播可以理解為：多個操作流程依賴于一個操作流程完成后才能進行某種動作，這個被依賴的操作流程在喚醒所有依賴者時使用的一種通知方式。

在Go語言中，則可以使用sync.Cond來實現多個協程之間的廣播通知功能。

3. sync.Cond

cond是sync包下面的一種數據類型，相當于線程間通信的條件變量方式。

// Cond implements a condition variable, a rendezvous point // for goroutines waiting for or announcing the occurrence // of an event. // // Each Cond has an associated Locker L (often a *Mutex or *RWMutex), // which must be held when changing the condition and // when calling the Wait method. // // A Cond must not be copied after first use. type Cond struct {     noCopy noCopy  // 在第一次使用后不可復制,使用go vet作為檢測使用      // L is held while observing or changing the condition   // 根據需求初始化不同的鎖，如*Mutex 和 *RWMutex。注意是 指針類型     L Locker    // 具有頭尾指針的鏈表。存儲被阻塞的協程，通知時操作該鏈表中的協程     notify  notifyList     checker copyChecker  // 復制檢查,檢查cond實例是否被復制 }

該數據類型提供的方法有：

type Cond  func NewCond(l Locker) *Cond func (c *Cond) Broadcast() // 通知所有協程，廣播 func (c *Cond) Signal()  // 通知一個協程 func (c *Cond) Wait()  // 阻塞等待，直到被喚醒

對應源碼追溯

// Wait atomically unlocks c.L and suspends execution // of the calling goroutine. After later resuming execution, // Wait locks c.L before returning. Unlike in other systems, // Wait cannot return unless awoken by Broadcast or Signal. // // Because c.L is not locked when Wait first resumes, the caller // typically cannot assume that the condition is true when // Wait returns. Instead, the caller should Wait in a loop: //       //      注意下面的寫法是官方推薦的 //    c.L.Lock() //    for !condition() { //        c.Wait() //    } //    ... make use of condition ... //    c.L.Unlock() // func (c *Cond) Wait() {     // 檢查c是否是被復制的，如果是就panic     c.checker.check()     // 獲取等待隊列的一個ticket數值，作為喚醒時的一個令牌憑證     t := runtime_notifyListAdd(&c.notify)     // 解鎖     c.L.Unlock()        // 注意，上面的ticket數值會作為阻塞攜程的一個標識     // 加入通知隊列里面     // 到這里執行gopark()，當前協程掛起，直到signal或broadcast發起通知     runtime_notifyListWait(&c.notify, t)        // 被喚醒之后，先獲取鎖     c.L.Lock() }  // Signal wakes one goroutine waiting on c, if there is any. // // It is allowed but not required for the caller to hold c.L // during the call. func (c *Cond) Signal() {     c.checker.check()     runtime_notifyListNotifyOne(&c.notify)  // 隨機挑選一個進行通知，wait阻塞解除 }  // Broadcast wakes all goroutines waiting on c. // // It is allowed but not required for the caller to hold c.L // during the call. func (c *Cond) Broadcast() {     c.checker.check()     // 通知所有阻塞等待的協程     // 主要是喚醒 cond.notify 鏈表上的各個協程     runtime_notifyListNotifyAll(&c.notify) }

使用方法，代碼示例：

var locker sync.Mutex var cond = sync.NewCond(&locker)  // NewCond(l Locker)里面定義的是一個接口,擁有lock和unlock方法。 // 看到sync.Mutex的方法,func (m *Mutex) Lock(),可以看到是指針有這兩個方法,所以應該傳遞的是指針 func main() {     // 啟動多個協程     for i := 0; i < 10; i++ {         gofunc(x int) {             cond.L.Lock()          // 獲取鎖             defer cond.L.Unlock()  // 釋放鎖                        cond.Wait()   // 等待通知，阻塞當前 goroutine                        // 通知到來的時候, cond.Wait()就會結束阻塞, do something. 這里僅打印             fmt.Println(x)         }(i)     }        time.Sleep(time.Second * 1) // 睡眠 1 秒，等待所有 goroutine 進入 Wait 阻塞狀態     fmt.Println("Signal...")     cond.Signal()               // 1 秒后下發一個通知給已經獲取鎖的 goroutine        time.Sleep(time.Second * 1)     fmt.Println("Signal...")     cond.Signal()               // 1 秒后下發下一個通知給已經獲取鎖的 goroutine        time.Sleep(time.Second * 1)     cond.Broadcast()            // 1 秒后下發廣播給所有等待的goroutine     fmt.Println("Broadcast...")     time.Sleep(time.Second * 1) // 等待所有 goroutine 執行完畢 }