go語言支援鎖嗎

2022-12-06 22:05:59

go語言支援鎖。go語言標準庫中提供了兩種鎖:1、互斥鎖(sync.Mutex),能保護一個資源不會因為並行操作而引起衝突導致資料不準確;2、讀寫鎖(sync.RWMutex),在讀鎖佔用的情況下,會阻止寫,但不阻止讀。在讀多寫少的環境中,可以優先使用讀寫互斥鎖。

php入門到就業線上直播課:進入學習
Apipost = Postman + Swagger + Mock + Jmeter 超好用的API偵錯工具:

本教學操作環境:windows7系統、GO 1.18版本、Dell G3電腦。

go語言標準庫中提供了兩種鎖,一種是互斥鎖,另外一種是讀寫鎖。Go語言套件中的 sync 包提供了兩種鎖型別:互斥鎖(sync.Mutex) 和 讀寫鎖(sync.RWMutex)。

Mutex 是最簡單的一種鎖型別,同時也比較暴力,當一個 goroutine 獲得了 Mutex 後,其他 goroutine 就只能乖乖等到這個 goroutine 釋放該 Mutex。

RWMutex 相對友好些,是經典的單寫多讀模型。在讀鎖佔用的情況下,會阻止寫,但不阻止讀,也就是多個 goroutine 可同時獲取讀鎖(呼叫 RLock() 方法);而寫鎖(呼叫 Lock() 方法)會阻止任何其他 goroutine(無論讀和寫)進來,整個鎖相當於由該 goroutine 獨佔。從 RWMutex 的實現看,RWMutex 型別其實組合了 Mutex:

type RWMutex struct {
    w Mutex
    writerSem uint32
    readerSem uint32
    readerCount int32
    readerWait int32
}
登入後複製

對於這兩種鎖型別,任何一個 Lock() 或 RLock() 均需要保證對應有 Unlock() 或 RUnlock() 呼叫與之對應,否則可能導致等待該鎖的所有 goroutine 處於飢餓狀態,甚至可能導致死鎖。【相關推薦:Go視訊教學、】

鎖的典型使用模式如下:

package main
import (
    "fmt"
    "sync"
)
var (
    // 邏輯中使用的某個變數
    count int
    // 與變數對應的使用互斥鎖
    countGuard sync.Mutex
)
func GetCount() int {
    // 鎖定
    countGuard.Lock()
    // 在函數退出時解除鎖定
    defer countGuard.Unlock()
    return count
}
func SetCount(c int) {
    countGuard.Lock()
    count = c
    countGuard.Unlock()
}
func main() {
    // 可以進行並行安全的設定
    SetCount(1)
    // 可以進行並行安全的獲取
    fmt.Println(GetCount())
}
登入後複製

程式碼說明如下:

  • 第 10 行是某個邏輯步驟中使用到的變數,無論是包級的變數還是結構體成員欄位,都可以。

  • 第 13 行,一般情況下,建議將互斥鎖的粒度設定得越小越好,降低因為共用存取時等待的時間。這裡筆者習慣性地將互斥鎖的變數命名為以下格式:

變數名+Guard
登入後複製

以表示這個互斥鎖用於保護這個變數。

  • 第 16 行是一個獲取 count 值的函數封裝,通過這個函數可以並行安全的存取變數 count。

  • 第 19 行,嘗試對 countGuard 互斥量進行加鎖。一旦 countGuard 發生加鎖,如果另外一個 goroutine 嘗試繼續加鎖時將會發生阻塞,直到這個 countGuard 被解鎖。

  • 第 22 行使用 defer 將 countGuard 的解鎖進行延遲呼叫,解鎖操作將會發生在 GetCount() 函數返回時。

  • 第 27 行在設定 count 值時,同樣使用 countGuard 進行加鎖、解鎖操作,保證修改 count 值的過程是一個原子過程,不會發生並行存取衝突。

在讀多寫少的環境中,可以優先使用讀寫互斥鎖(sync.RWMutex),它比互斥鎖更加高效。sync 包中的 RWMutex 提供了讀寫互斥鎖的封裝。

我們將互斥鎖例子中的一部分程式碼修改為讀寫互斥鎖,參見下面程式碼:

var (
    // 邏輯中使用的某個變數
    count int
    // 與變數對應的使用互斥鎖
    countGuard sync.RWMutex
)
func GetCount() int {
    // 鎖定
    countGuard.RLock()
    // 在函數退出時解除鎖定
    defer countGuard.RUnlock()
    return count
}
登入後複製

程式碼說明如下:

  • 第 6 行,在宣告 countGuard 時,從 sync.Mutex 互斥鎖改為 sync.RWMutex 讀寫互斥鎖。

  • 第 12 行,獲取 count 的過程是一個讀取 count 資料的過程,適用於讀寫互斥鎖。在這一行,把 countGuard.Lock() 換做 countGuard.RLock(),將讀寫互斥鎖標記為讀狀態。如果此時另外一個 goroutine 並行存取了 countGuard,同時也呼叫了 countGuard.RLock() 時,並不會發生阻塞。

  • 第 15 行,與讀模式加鎖對應的,使用讀模式解鎖。

特別說明:

  • sync.Mutex 的鎖是不可以巢狀使用的

  • sync.RWMutex 的 RLock()是可以巢狀使用的

  • sync.RWMutex 的 mu.Lock() 是不可以巢狀的

  • sync.RWMutex 的 mu.Lock() 中不可以巢狀 mu.RLock()

更多程式設計相關知識,請存取:!!

以上就是go語言支援鎖嗎的詳細內容,更多請關注TW511.COM其它相關文章!