Go語言中sync.Mutex的使用方法
背景
多個(gè)協(xié)程操作中經(jīng)常出現(xiàn)臟讀寫的情況,這種情況下需要使用互斥鎖,保證在對協(xié)程共享區(qū)域操作的原子性。
如下示例:
啟動(dòng)了 100個(gè)協(xié)程,每個(gè)協(xié)程累加 100 次,在沒有臟讀寫的情況下,最后結(jié)果應(yīng)該是 100 * 100 = 10000
package main
import (
"fmt"
"sync"
)
func main() {
var count = 0
var wg sync.WaitGroup
wg.Add(100)
for i :=0; i< 100; i++ {
go func(){
defer wg.Done()
for j := 0; j< 100; j ++ {
count ++
}
}()
}
wg.Wait()
fmt.Println(count)
}
但是實(shí)際結(jié)果一直小于 10000

互斥鎖
count ++ 操作, 分為三個(gè)步驟
在協(xié)程的共享區(qū)域取出 count 當(dāng)前值
當(dāng)前值加一
加一后的值寫回協(xié)程共享區(qū)域
這時(shí)需要使用互斥鎖, 來保證對 count++ 的三個(gè)操作過程中沒有其他協(xié)程進(jìn)行讀寫。
Go的Sync 包提供了Mutex, 讀寫互斥的鎖, 來保證只有一個(gè)協(xié)程對數(shù)據(jù)進(jìn)行讀寫操作。 以保證 count++操作的原子性
如下示例:
package main
import (
"fmt"
"sync"
)
func main() {
var count = 0
// 聲明Mutex變量
var mu sync.Mutex
var wg sync.WaitGroup
wg.Add(100)
for i :=0; i< 100; i++ {
go func(){
defer wg.Done()
for j := 0; j< 100; j ++ {
// 添加鎖
mu.Lock()
count ++
// 解鎖
mu.Unlock()
}
}()
}
wg.Wait()
fmt.Println(count)
}
在mu.Lock() 和mu.Unlock() 之間的代碼可以保證在操作只會(huì)被一個(gè)協(xié)程執(zhí)行。這樣執(zhí)行結(jié)果就是 10000 了

注意
mu.Lock() 和mu.Unlock() 必須成對出現(xiàn),在忘掉 Unlock 的情況下,鎖獲取后永遠(yuǎn)不會(huì)得到釋放,其他 的線程/協(xié)程會(huì)永遠(yuǎn)處于阻塞狀態(tài),永遠(yuǎn)獲取不到鎖,在忘掉 Lock 的情況下,直接 Unlock 一個(gè)未加鎖的 Mutex,會(huì)導(dǎo)致程序 panic。
到此這篇關(guān)于Go語言中sync.Mutex的使用方法的文章就介紹到這了,更多相關(guān)Go sync.Mutex內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Go語言中的空值(nil)與零值(zerovalue)區(qū)別詳解
在Go語言中,空值(nil)和零值(zero value)是兩個(gè)不同的概念,它們在語義、使用場景以及實(shí)際的編程實(shí)踐中有著明顯的區(qū)別,理解這兩者的差異對于編寫清晰、健壯的Go代碼至關(guān)重要,需要的朋友可以參考下2024-06-06
Go語言使用slices包輕松實(shí)現(xiàn)排序功能
在 Go 語言開發(fā)中,對數(shù)據(jù)進(jìn)行排序是常見的需求,Go 1.18 版本引入的 slices包提供了簡潔高效的排序解決方案,支持內(nèi)置類型和用戶自定義類型的排序操作,本文將通過具體示例,詳細(xì)介紹如何使用 slices包實(shí)現(xiàn)排序及相關(guān)功能,需要的朋友可以參考下2025-05-05

