golang并發(fā)鎖使用詳解
如果程序用到的數(shù)據(jù)是多個(gè)groutine之間的交互過(guò)程中產(chǎn)生的，那么使用上文提到的channel就可以解決了。
如果我們的使用多個(gè)groutine訪問(wèn)和修改同一個(gè)數(shù)據(jù)，就需要考慮在并發(fā)環(huán)境下數(shù)據(jù)一致性的問(wèn)題，即線程安全問(wèn)題。
以存錢(qián)為例說(shuō)明一下問(wèn)題。假設(shè)我們發(fā)起一個(gè)眾籌項(xiàng)目，并發(fā)1000個(gè)用戶的向一個(gè)銀行銀行賬號(hào)存錢(qián)。
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
func Save(income int, balance *int) {
defer wg.Done()
*balance = *balance + income
}
func main() {
balance := 0
//wg.Add(1000)
for s := 0; s < 1000; s++ {
wg.Add(1)
go Save(1, &balance)
}
wg.Wait()
fmt.Println("當(dāng)前賬戶余額：", balance)
}運(yùn)行結(jié)果，正常應(yīng)該是收到1000元。代碼中使用了&符號(hào)傳遞余額變量地址，但是怎么運(yùn)行結(jié)果都不對(duì)。這個(gè)問(wèn)題的原因并不是值傳遞還是引用傳遞的問(wèn)題。而是多groutine并發(fā)訪問(wèn)變量的時(shí)候，變量值因?yàn)闆](méi)有鎖定被多個(gè)groutine反復(fù)修改所致。比如第一個(gè)groutine運(yùn)行的時(shí)候獲取的變量為0，運(yùn)算之后變量值被回寫(xiě)為1。但是由于的groutine啟動(dòng)順序是并不一致，即第200個(gè)groutine啟動(dòng)獲取變量值的時(shí)候，第20個(gè)groutine剛好運(yùn)算結(jié)束把結(jié)果20寫(xiě)回了變量。那么第200個(gè)groutine就拿到變量值20進(jìn)行了計(jì)算了。這就是導(dǎo)致數(shù)據(jù)丟失的原因。
% go run main.go 當(dāng)前賬戶余額： 947 % go run main.go 當(dāng)前賬戶余額： 938 % go run main.go 當(dāng)前賬戶余額： 948
解決的辦法，就是操作變量的時(shí)候加個(gè)鎖。每次只允許一個(gè)groutine讀寫(xiě)這個(gè)變量，讀寫(xiě)完成后釋放
互斥鎖 sync.Mutex
使用sync.Mutex對(duì)象，對(duì)數(shù)據(jù)進(jìn)行加解鎖操作
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
// 聲明一個(gè)sync.Mutex 類型
var lk sync.Mutex
func Save(income int, balance *int) {
defer wg.Done()
// 操作前給先加鎖
lk.Lock()
*balance = *balance + income
// 操作后解鎖
lk.Unlock()
}
func main() {
balance := 0
//wg.Add(1000)
for s := 0; s < 1000; s++ {
wg.Add(1)
go Save(1, &balance)
}
wg.Wait()
fmt.Println("當(dāng)前賬戶余額：", balance)
}運(yùn)行結(jié)果，始終與預(yù)期一致了
% go run main.go 當(dāng)前賬戶余額： 1000 % go run main.go 當(dāng)前賬戶余額： 1000 % go run main.go 當(dāng)前賬戶余額： 1000
讀寫(xiě)鎖 sync.RWMutex
互斥鎖雖然解決了數(shù)據(jù)一致性的問(wèn)題，但是在運(yùn)行過(guò)程中進(jìn)程無(wú)論是讀寫(xiě)要等待解鎖，如果是讀多寫(xiě)少的場(chǎng)景，那么讀groutine就進(jìn)行了很多無(wú)謂等待。讀寫(xiě)鎖的應(yīng)對(duì)此類需求就非常合適。讀寫(xiě)鎖的工作原理是當(dāng)變量要被變更時(shí)，無(wú)論讀寫(xiě)都會(huì)block。當(dāng)數(shù)據(jù)沒(méi)有變更時(shí)，只讀操作允許并發(fā)進(jìn)行。
package main
import (
"fmt"
"sync"
"time"
)
var wg sync.WaitGroup
// 聲明一個(gè)讀寫(xiě)鎖sync.RWMutex類型
var lk sync.RWMutex
func Save(thr int, income int, balance *int) {
defer wg.Done()
// 操作前給先加寫(xiě)鎖
lk.Lock()
fmt.Printf("write-groutine-< %d >添加寫(xiě)鎖\n", thr)
*balance = *balance + income
time.Sleep(time.Millisecond * 1)
fmt.Printf("write-groutine-< %d >解除寫(xiě)鎖\n", thr)
// 解除寫(xiě)鎖
lk.Unlock()
}
func Show(thr int, balance *int) {
defer wg.Done()
//如果使用互斥鎖，即使函數(shù)是只讀操作，也要等待解鎖才可讀取
// 讀取前加讀鎖
lk.RLock()
fmt.Printf("read-groutine-< %d >開(kāi)始讀取數(shù)據(jù)\n", thr)
time.Sleep(time.Millisecond * 1)
fmt.Printf("read-groutine-< %d >完成讀取數(shù)據(jù)\n", thr)
// 解除讀鎖
lk.RUnlock()
}
func main() {
balance := 0
StartTime := time.Now()
// 寫(xiě)操作3次
for s := 0; s < 3; s++ {
wg.Add(1)
go Save(s, 1, &balance)
}
// 讀操作10次
for sh := 0; sh < 10; sh++ {
wg.Add(1)
go Show(sh, &balance)
}
wg.Wait()
fmt.Println("最終賬戶余額：", balance)
TimeRange := time.Since(StartTime)
fmt.Println("程序運(yùn)行耗時(shí): ", TimeRange)
}運(yùn)行結(jié)果，加解鎖寫(xiě)操作成對(duì)出現(xiàn)。說(shuō)明在寫(xiě)操作時(shí)只有一個(gè)groutine在運(yùn)行，其他groutine被鎖住了。讀操作的加解鎖標(biāo)記有差距且啟動(dòng)順序混亂，說(shuō)明讀的時(shí)候是多個(gè)groutine并發(fā)運(yùn)行沒(méi)有鎖限制。
% go run main.go write-groutine-< 1 >添加寫(xiě)鎖 write-groutine-< 1 >解除寫(xiě)鎖 read-groutine-< 1 >開(kāi)始讀取數(shù)據(jù) # 1號(hào)讀groutine開(kāi)始讀數(shù)據(jù) read-groutine-< 7 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 6 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 4 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 0 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 2 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 9 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 8 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 3 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 5 >開(kāi)始讀取數(shù)據(jù) read-groutine-< 0 >完成讀取數(shù)據(jù) read-groutine-< 7 >完成讀取數(shù)據(jù) read-groutine-< 6 >完成讀取數(shù)據(jù) read-groutine-< 4 >完成讀取數(shù)據(jù) read-groutine-< 1 >完成讀取數(shù)據(jù) # # 1號(hào)讀groutine完成讀數(shù)據(jù)，耗時(shí)1ms read-groutine-< 5 >完成讀取數(shù)據(jù) read-groutine-< 9 >完成讀取數(shù)據(jù) read-groutine-< 8 >完成讀取數(shù)據(jù) read-groutine-< 3 >完成讀取數(shù)據(jù) read-groutine-< 2 >完成讀取數(shù)據(jù) write-groutine-< 0 >添加寫(xiě)鎖 # 0號(hào)寫(xiě)groutine要等到其他寫(xiě)鎖釋放，才能添加自己的寫(xiě)鎖 write-groutine-< 0 >解除寫(xiě)鎖 # 0號(hào)寫(xiě)groutine完成寫(xiě)操作耗時(shí)1ms，寫(xiě)期間其他groutine掛起 write-groutine-< 2 >添加寫(xiě)鎖 write-groutine-< 2 >解除寫(xiě)鎖 最終賬戶余額： 3 程序運(yùn)行耗時(shí): 45.2403ms
到此這篇關(guān)于golang并發(fā)鎖使用詳解的文章就介紹到這了,更多相關(guān)golang并發(fā)鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
golang中的string與其他格式數(shù)據(jù)的轉(zhuǎn)換方法詳解
這篇文章主要介紹了golang中的string與其他格式數(shù)據(jù)的轉(zhuǎn)換方法,文章通過(guò)代碼示例介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-10-10
Redis是我們開(kāi)發(fā)應(yīng)用程序中很常用的NoSQL數(shù)據(jù)庫(kù)，那么在Go語(yǔ)言中要如何連接和操作Redis呢，在這篇文章中，我們就來(lái)一起來(lái)探究一下吧2023-08-08
詳解Gotorch多機(jī)定時(shí)任務(wù)管理系統(tǒng)
遵循著“學(xué)一門(mén)語(yǔ)言最好的方式是使用它”的理念，想著用Go來(lái)實(shí)現(xiàn)些什么，剛好有一個(gè)比較讓我煩惱的問(wèn)題，于是用Go解決一下，即使不在生產(chǎn)環(huán)境使用，也可以作為Go語(yǔ)言學(xué)習(xí)的一種方式。2021-05-05
go語(yǔ)言執(zhí)行等待直到后臺(tái)goroutine執(zhí)行完成實(shí)例分析
這篇文章主要介紹了go語(yǔ)言執(zhí)行等待直到后臺(tái)goroutine執(zhí)行完成的方法,實(shí)例分析了Go語(yǔ)言中WaitGroup的使用技巧,需要的朋友可以參考下2015-03-03
這篇文章主要介紹了Go 結(jié)構(gòu)體格式化輸出的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)go語(yǔ)言，感興趣的朋友可以了解下2020-08-08
golang 網(wǎng)絡(luò)框架之gin的使用方法
這篇文章主要介紹了golang 網(wǎng)絡(luò)框架之gin的使用方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-11-11
Go對(duì)字符串格式化提供了良好的支持,這篇文章主要給大家介紹了關(guān)于在Go中格式化字符串的幾種常用方法,文中通過(guò)代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用Go具有一定的參考價(jià)值,需要的朋友可以參考下2023-10-10
關(guān)于golang中死鎖的思考與學(xué)習(xí)
本文主要介紹了關(guān)于golang中死鎖的思考與學(xué)習(xí)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-03-03
這篇文章主要介紹了Golang?中的?條件變量（sync.Cond）詳解的相關(guān)資料,需要的朋友可以參考下2022-12-12
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言中io/ioutil工具的使用，從而簡(jiǎn)化文件操作。文中是示例代碼講解詳細(xì)，感興趣的小伙伴可以了解一下2022-05-05