Go并發(fā)編程之死鎖與活鎖的案例分析
什么是死鎖、活鎖
什么是死鎖:就是在并發(fā)程序中,兩個(gè)或多個(gè)線程彼此等待對(duì)方完成操作,從而導(dǎo)致它們都被阻塞,并無限期地等待對(duì)方完成。這種情況下,程序會(huì)卡死,無法繼續(xù)執(zhí)行。
什么是活鎖:就是程序一直在運(yùn)行,但是無法取得進(jìn)展。例如,在某些情況下,多個(gè)線程會(huì)爭奪同一個(gè)資源,然后每個(gè)線程都會(huì)釋放資源,以便其他線程可以使用它。但是,如果沒有正確的同步,這些線程可能會(huì)同時(shí)嘗試獲取該資源,然后再次釋放它。這可能導(dǎo)致線程在無限循環(huán)中運(yùn)行,卻無法取得進(jìn)展。
發(fā)生死鎖的案例分析
1.編寫會(huì)發(fā)生死鎖的代碼:
package?main
import?(
?"fmt"
?"sync"
)
func?main()?{
?var?mu?sync.Mutex
?mu.Lock()
?defer?mu.Unlock()
?wg?:=?sync.WaitGroup{}
?wg.Add(1)
?go?func()?{
??fmt.Println("goroutine?started")
??mu.Lock()?//?在這里獲取了鎖
??fmt.Println("goroutine?finished")
??mu.Unlock()
??wg.Done()
?}()
?wg.Wait()
}
運(yùn)行和輸出:
[root@workhost temp02]# go run main.go
goroutine started
fatal error: all goroutines are asleep - deadlock! # 錯(cuò)誤很明顯了,告訴你死鎖啦!
goroutine 1 [semacquire]:
sync.runtime_Semacquire(0xc000010030?)
/usr/local/go/src/runtime/sema.go:62 +0x27
...
...
上面的代碼,使用 sync.Mutex 實(shí)現(xiàn)了一個(gè)互斥鎖。主 goroutine 獲取了鎖,并啟動(dòng)了一個(gè)新的 goroutine。新 goroutine 也嘗試獲取鎖來執(zhí)行其任務(wù)。但是,由于主 goroutine 沒有釋放鎖,新 goroutine 將一直等待鎖,導(dǎo)致死鎖。
2.代碼改造
在上面的代碼中,可以通過將主 goroutine 中的 defer mu.Unlock() 移到 goroutine 函數(shù)中的 mu.Unlock() 后面來解決問題。這樣,當(dāng) goroutine 獲取到鎖后,它可以在完成任務(wù)后釋放鎖,以便主 goroutine 可以繼續(xù)執(zhí)行。
改造后的代碼:
package?main
import?(
?"fmt"
?"sync"
)
func?main()?{
?var?mu?sync.Mutex
?mu.Lock()
?wg?:=?sync.WaitGroup{}
?wg.Add(1)
?go?func()?{
??fmt.Println("goroutine?started")
??mu.Lock()?//?在這里獲取了鎖
??fmt.Println("goroutine?finished")
??mu.Unlock()
??wg.Done()
?}()
?mu.Unlock()?//?釋放鎖
?wg.Wait()
}
運(yùn)行和輸出:
[root@workhost temp02]# go run main.go
goroutine started
goroutine finished
3.如何避免死鎖
在 Go 語言中,要避免死鎖,一定要清楚以下幾個(gè)規(guī)則:
- 避免嵌套鎖:在使用多個(gè)鎖時(shí),確保它們的嵌套順序相同。否則,可能會(huì)出現(xiàn)循環(huán)等待的情況,導(dǎo)致死鎖。
- 避免無限等待:如果在獲取鎖時(shí)指定了超時(shí)時(shí)間,確保在超時(shí)后能夠處理錯(cuò)誤或執(zhí)行其他操作。
- 避免過度競爭:如果多個(gè)協(xié)程需要訪問相同的資源,請(qǐng)確保它們不會(huì)互相干擾??梢允褂没コ怄i或讀寫鎖等機(jī)制來解決競爭問題。
- 使用通道:Go 語言中的通道可以用于協(xié)調(diào)并發(fā)操作。使用通道來傳遞消息和同步操作,可以避免死鎖和競爭問題。
- 確保資源釋放:在使用鎖或其他資源時(shí),一定要確保它們?cè)谑褂煤蟮玫结尫牛駝t可能會(huì)導(dǎo)致死鎖。
- 使用 select 語句:在使用通道進(jìn)行并發(fā)操作時(shí),可以使用 select 語句來避免死鎖。通過 select 語句選擇多個(gè)通道中的一個(gè)進(jìn)行操作,可以避免在某個(gè)通道被阻塞時(shí)出現(xiàn)死鎖。
發(fā)生活鎖的案例分析
1.編寫會(huì)發(fā)生活鎖的代碼:
package?main
import?(
?"fmt"
?"sync"
)
func?main()?{
?var?wg?sync.WaitGroup
?var?mu?sync.Mutex
?var?flag?bool
?wg.Add(2)
?//?goroutine?1
?go?func()?{
??//?先獲取鎖資源
??fmt.Println("goroutine?1?獲取?mu")
??mu.Lock()
??defer?mu.Unlock()
??//?然后等待?flag?變量的值變?yōu)?true
??fmt.Println("goroutine?1?等待標(biāo)志")
??for?!flag?{
???//?不斷循環(huán)等待
??}
??//?最終輸出并釋放鎖資源
??fmt.Println("goroutine?1?從等待中釋放")
??wg.Done()
?}()
?//?goroutine?2
?go?func()?{
??//?先獲取鎖資源
??fmt.Println("goroutine?2?獲取?mu")
??mu.Lock()
??defer?mu.Unlock()
??//?然后等待?flag?變量的值變?yōu)?true
??fmt.Println("GoRoutine2?等待標(biāo)志")
??for?!flag?{
???//?不斷循環(huán)等待
??}
??//?最終輸出并釋放鎖資源
??fmt.Println("GoRoutine?2?從等待中釋放")
??wg.Done()
?}()
?//?在主線程中等待?1?秒鐘,以便兩個(gè)?goroutine?開始等待?flag?變量的值
?//?然后將?flag?變量設(shè)置為?true
?//?由于兩個(gè)?goroutine?會(huì)同時(shí)喚醒并嘗試獲取鎖資源,它們會(huì)相互等待
?//?最終導(dǎo)致了活鎖問題,它們都無法向前推進(jìn)
?fmt.Println("主線程休眠?1?秒")
?fmt.Println("兩個(gè)goroutine都應(yīng)該等待標(biāo)志")
?flag?=?true
?wg.Wait()
?fmt.Println("所有?GoRoutines?已完成")
}
運(yùn)行和輸出:
[root@workhost temp02]# go run main.go
主線程休眠 1 秒
兩個(gè)goroutine都應(yīng)該等待標(biāo)志
goroutine 2 獲取 mu
GoRoutine2 等待標(biāo)志
GoRoutine 2 從等待中釋放
goroutine 1 獲取 mu
goroutine 1 等待標(biāo)志
goroutine 1 從等待中釋放
所有 GoRoutines 已完成
上面的代碼存在活鎖問題。如果兩個(gè)goroutine同時(shí)等待flag變?yōu)閠rue并且都已經(jīng)獲取了鎖資源,那么它們就會(huì)進(jìn)入一個(gè)死循環(huán)并相互等待,無法繼續(xù)向前推進(jìn)。
2.代碼改造
改造后的代碼:
package?main
import?(
?"fmt"
?"runtime"
?"sync"
)
func?main()?{
?var?wg?sync.WaitGroup
?var?mu?sync.Mutex
?var?flag?bool
?wg.Add(2)
?//?goroutine?1
?go?func()?{
??//?先獲取鎖資源
??fmt.Println("goroutine?1?獲取?mu")
??mu.Lock()
??defer?mu.Unlock()
??//?然后等待?flag?變量的值變?yōu)?true
??fmt.Println("goroutine?1?等待標(biāo)志")
??for?!flag?{
???runtime.Gosched()?//?讓出時(shí)間片
??}
??//?最終輸出并釋放鎖資源
??fmt.Println("goroutine?1?從等待中釋放")
??wg.Done()
?}()
?//?goroutine?2
?go?func()?{
??//?先獲取鎖資源
??fmt.Println("goroutine?2?獲取?mu")
??mu.Lock()
??defer?mu.Unlock()
??//?然后等待?flag?變量的值變?yōu)?true
??fmt.Println("GoRoutine2?等待標(biāo)志")
??for?!flag?{
???runtime.Gosched()?//?讓出時(shí)間片
??}
??//?最終輸出并釋放鎖資源
??fmt.Println("GoRoutine?2?從等待中釋放")
??wg.Done()
?}()
?//?在主線程中等待?1?秒鐘,以便兩個(gè)?goroutine?開始等待?flag?變量的值
?//?然后將?flag?變量設(shè)置為?true
?//?由于兩個(gè)?goroutine?會(huì)同時(shí)喚醒并嘗試獲取鎖資源,它們會(huì)相互等待
?//?最終導(dǎo)致了活鎖問題,它們都無法向前推進(jìn)
?fmt.Println("主線程休眠?1?秒")
?fmt.Println("兩個(gè)goroutine都應(yīng)該等待標(biāo)志")
?flag?=?true
?wg.Wait()
?fmt.Println("所有?GoRoutines?已完成")
}
改造后的代碼在等待flag變量的循環(huán)中加入了讓出時(shí)間片的函數(shù) runtime.Gosched(),這樣兩個(gè)goroutine在等待期間可以放棄時(shí)間片,以便其他goroutine可以執(zhí)行并獲得鎖資源。這種方式可以有效地減少競爭程度,從而避免了活鎖問題。
3.如何避免發(fā)生活鎖的可能性
在 Go 語言的并發(fā)編程中,避免活鎖的關(guān)鍵是正確地實(shí)現(xiàn)同步機(jī)制。以下是一些避免活鎖的方法:
- 避免忙等待:使用 sync.Cond 或者 channel 等同步機(jī)制來實(shí)現(xiàn)等待。這樣避免了線程一直占用 CPU 資源而無法取得進(jìn)展的問題。
- 避免死鎖:死鎖往往是活鎖的前提,因此正確地使用鎖和同步機(jī)制可以避免死鎖,從而避免活鎖。
- 減少鎖的粒度:盡可能將鎖的粒度縮小到最小范圍,避免鎖住不必要的代碼塊。
- 采用超時(shí)機(jī)制:使用 sync.Mutex 的 TryLock() 方法或者使用 select 語句實(shí)現(xiàn)等待超時(shí)機(jī)制,這樣可以防止線程無限期等待。
- 合理設(shè)計(jì)并發(fā)模型:合理設(shè)計(jì)并發(fā)模型可以避免競爭和饑餓等問題,進(jìn)而避免活鎖的發(fā)生。
以上就是Go并發(fā)編程之死鎖與活鎖的案例分析的詳細(xì)內(nèi)容,更多關(guān)于Go死鎖 活鎖的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
go語言數(shù)據(jù)結(jié)構(gòu)之前綴樹Trie
這篇文章主要介紹了go語言數(shù)據(jù)結(jié)構(gòu)之前綴樹Trie,文章圍繞主題展開詳細(xì)內(nèi)容介紹,具有一定得參考價(jià)值,需要的小伙伴可以參考一下2022-05-05
golang實(shí)現(xiàn)對(duì)JavaScript代碼混淆
在Go語言中,你可以使用一些工具來混淆JavaScript代碼,一個(gè)常用的工具是Terser,它可以用于壓縮和混淆JavaScript代碼,你可以通過Go語言的`os/exec`包來調(diào)用Terser工具,本文給通過一個(gè)簡單的示例給大家介紹一下,感興趣的朋友可以參考下2024-01-01
golang jsoniter extension 處理動(dòng)態(tài)字段的實(shí)現(xiàn)方法
這篇文章主要介紹了golang jsoniter extension 處理動(dòng)態(tài)字段的實(shí)現(xiàn)方法,我們使用實(shí)例級(jí)別的 extension, 而非全局,可以針對(duì)不同業(yè)務(wù)邏輯有所區(qū)分,jsoniter 包提供了比較完善的定制能力,通過例子可以感受一下擴(kuò)展性,需要的朋友可以參考下2023-04-04
Go/C語言LeetCode題解997找到小鎮(zhèn)法官
這篇文章主要為大家介紹了Go語言LeetCode題解997找到小鎮(zhèn)的法官示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-12-12

