關于golang中死鎖的思考與學習
1、Golang中死鎖的觸發(fā)條件
1.1 書上關于死鎖的四個必要條件的講解
發(fā)生死鎖時，線程永遠不能完成，系統(tǒng)資源被阻礙使用，以致于阻止了其他作業(yè)開始執(zhí)行。在討論處理死鎖問題的各種方法之前，我們首先深入討論一下死鎖特點。
必要條件：
如果在一個系統(tǒng)中以下四個條件同時成立，那么就能引起死鎖：
- 互斥：至少有一個資源必須處于非共享模式，即一次只有一個線程可使用。如果另一線程申請該資源，那么申請線程應等到該資源釋放為止。
- 占有并等待：—個線程應占有至少一個資源，并等待另一個資源，而該資源為其他線程所占有。
- 非搶占：資源不能被搶占，即資源只能被線程在完成任務后自愿釋放。
- 循環(huán)等待：有一組等待線程 {P0，P1，…，Pn}，P0 等待的資源為 P1 占有，P1 等待的資源為 P2 占有，……，Pn-1 等待的資源為 Pn 占有，Pn 等待的資源為 P0 占有。
我們強調(diào)所有四個條件必須同時成立才會出現(xiàn)死鎖。循環(huán)等待條件意味著占有并等待條件，這樣四個條件并不完全獨立。
圖示例：
線程1、線程2都嘗試獲取對方未釋放的資源，從而會一直阻塞，導致死鎖發(fā)生。
1.2 Golang 死鎖的觸發(fā)條件
看完了書上關于死鎖的介紹，感覺挺清晰的，但是實際上到了使用或者看代碼時，自己去判斷是否會發(fā)生死鎖卻是模模糊糊的，難以準確判斷出來。所以特意去網(wǎng)上找了些資料學習，特此記錄。
golang中死鎖的觸發(fā)條件：
死鎖是當 Goroutine 被阻塞而無法解除阻塞時產(chǎn)生的一種狀態(tài)。注意：for 死循環(huán)不能算在這里，雖然空for循環(huán)是實現(xiàn)了阻塞的效果，但是實際上goroutine是處于運行狀態(tài)的。
1.3 golang 中阻塞的場景
1.3.1 sync.Mutex、sync.RWMutex
golang中的鎖是不可重入鎖，對已經(jīng)上了鎖的寫鎖，再次申請鎖是會報死鎖。上了讀鎖的鎖，再次申請寫鎖會報死鎖，而申請讀鎖不會報錯。
寫寫沖突，讀寫沖突，讀讀不沖突。
func main() {
var lock sync.Mutex
lock.Lock()
lock.Lock()
}
//報死鎖錯誤
func main() {
var lock sync.RWMutex
lock.RLock()
lock.Lock()
}
//報死鎖錯誤
func main() {
var lock sync.RWMutex
lock.RLock()
lock.RLock()
}
//正常執(zhí)行
1.3.2 sync.WaitGroup
一個不會減少的 WaitGroup 會永久阻塞。
func main() {
var wg sync.WaitGroup
wg.Add(1)
wg.Wait()
//報死鎖錯誤
}
1.3.3 空 select
空 select 會一直阻塞。
package main
func main() {
select {
}
}
//報死鎖錯誤
1.3.4 channel
為 nil 的channel 發(fā)送、接受數(shù)據(jù)都會阻塞。
func main() {
var ch chan struct{}
ch <- struct{}{}
}
//報死鎖錯誤
無緩沖的channel 發(fā)送、接受數(shù)據(jù)都會阻塞。
func main() {
ch := make(chan struct{})
<- ch
}
//報死鎖錯誤
channel 緩沖區(qū)滿了的，繼續(xù)發(fā)送數(shù)據(jù)會阻塞。
2、死鎖案例講解
2.1 案例一：空 select{}
package main
func main() {
select {
}
}
以上面為例子，select 語句會 造成 當前 goroutine 阻塞，但是卻無法解除阻塞，所以會導致死鎖。
2.2 案例二：從無緩沖的channel接受、發(fā)送數(shù)據(jù)
func main() {
ch := make(chan struct{})
//ch <- struct{}{} //發(fā)送
<- ch //接受
fmt.Println("main over!")
}發(fā)生原因：
上面創(chuàng)建了一個 名為：ch 的channel，沒有緩沖空間。當向無緩存空間的channel 發(fā)送或者接受數(shù)據(jù)時，都會阻塞，但是卻無法解除阻塞，所以會導致死鎖。
解決方案：邊接受邊讀取
package main
// 方式1
func recv(c chan int) {
ret := <-c
fmt.Println("接收成功", ret)
}
func main() {
ch := make(chan int)
go recv(ch) // 啟用goroutine從通道接收值
ch <- 10
fmt.Println("發(fā)送成功")
}
// 方式2
func main() {
ch := make(chan int,1)
ch<-1
println(<-ch)
}
2.3 案例三：從空的channel中讀取數(shù)據(jù)
package main
import (
"fmt"
"time"
)
func request(index int,ch chan<- string) {
time.Sleep(time.Duration(index)*time.Second)
s := fmt.Sprintf("編號%d完成",index)
ch <- s
}
func main() {
ch := make(chan string, 10)
fmt.Println(ch,len(ch))
for i := 0; i < 4; i++ {
go request(i, ch)
}
for ret := range ch{ //當 ch 中沒有數(shù)據(jù)的時候，for range ch 會發(fā)生阻塞，但是無法解除阻塞，發(fā)生死鎖
fmt.Println(len(ch))
fmt.Println(ret)
}
}
發(fā)生原因：
當 ch 中沒有數(shù)據(jù)的時候，就是從空的channel中接受數(shù)據(jù)，for range ch 會發(fā)生阻塞，但是無法解除阻塞，發(fā)生死鎖。
解決辦法：當數(shù)據(jù)發(fā)送完了過后，close channel
package main
import (
"fmt"
"sync"
"time"
)
var wg sync.WaitGroup
func request(index int,ch chan<- string) {
time.Sleep(time.Duration(index)*time.Second)
s := fmt.Sprintf("編號%d完成",index)
ch <- s
wg.Done()
}
func main() {
ch := make(chan string, 10)
for i := 0; i < 4; i++ {
wg.Add(1)
go request(i, ch)
}
go func() {
wg.Wait()
close(ch)
}()
LOOP:
for {
select {
case i,ok := <-ch: // select會一直等待，直到某個case的通信操作完成時，就會執(zhí)行case分支對應的語句
if !ok {
break LOOP
}
println(i)
default:
time.Sleep(time.Second)
fmt.Println("無數(shù)據(jù)")
}
}
}
2.4 案例四：給滿了的channel發(fā)送數(shù)據(jù)
func main() {
ch := make(chan struct{}, 3)
for i := 0; i < 4; i++ {
ch <- struct{}{}
}
}
發(fā)生原因：
ch 是一個帶緩沖的channel，但是只能緩沖三個struct，當channel滿了過后，繼續(xù)往channel發(fā)送數(shù)據(jù)會阻塞，但是無法解除阻塞，發(fā)生死鎖。
解決辦法：讀取channel中的數(shù)據(jù)
package main
import (
"fmt"
"sync"
"time"
)
var wg sync.WaitGroup
func main() {
ch := make(chan struct{}, 3)
go func() {
for {
select {
case i, ok := <- ch:
wg.Done()
fmt.Println(i)
if !ok {
return
}
}
}
}()
for i := 0; i < 4; i++ {
wg.Add(1)
ch <- struct{}{}
}
wg.Wait()
}
3、總結(jié)
最重要的是記住golang中死鎖的觸發(fā)條件：當 goroutine 發(fā)生阻塞，但是無法解除阻塞狀態(tài)時，就會發(fā)生死鎖。然后在使用或者閱讀代碼時，再根據(jù)具體情況進行分析。
channel異常情況總結(jié)：
注意：對已經(jīng)關閉的channel再次關閉，也會發(fā)生panic。
到此這篇關于關于golang中死鎖的思考與學習的文章就介紹到這了,更多相關golang 死鎖內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
想知道如何在Go語言中輕松地格式化時間嗎？別再浪費時間了！本文將帶你快速入門,讓你的代碼更加優(yōu)雅高效,快來學習吧！2024-01-01
Go語法簡單易用,有其他編程經(jīng)驗的開發(fā)者,相信學習并快速上手Go語言的開發(fā),多數(shù)覺得不困難吧,下面這篇文章主要給大家介紹了關于GO中優(yōu)雅編碼與降低圈復雜度的相關資料,需要的朋友可以參考下2022-12-12
這篇文章主要為大家介紹了Go 庫性能分析工具pprof，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-12-12
錯誤處理在每個語言中都是一項重要內(nèi)容,眾所周知,通常寫程序時遇到的分為異常與錯誤兩種,Golang中也不例外,這篇文章主要給大家介紹了一些關于Go程序錯誤處理的相關建議,需要的朋友可以參考下2021-09-09
Go實現(xiàn)后臺任務調(diào)度系統(tǒng)的實例代碼
平常我們在開發(fā)API的時候，前端傳遞過來的大批數(shù)據(jù)需要經(jīng)過后端處理，如果后端處理的速度快，前端響應就快，反之則很慢，影響用戶體驗，為了解決這一問題，需要我們自己實現(xiàn)后臺任務調(diào)度系統(tǒng)，本文將介紹如何用Go語言實現(xiàn)后臺任務調(diào)度系統(tǒng),需要的朋友可以參考下2023-06-06
這篇文章會結(jié)合?errors?中的函數(shù)，來討論一下?Go?中常見的?error?使用方式，文中的示例代碼講解詳細，具有一定的學習價值，需要的可以了解一下2023-07-07
goconfig是一個易于使用,支持注釋的 Go 語言配置文件解析器,該文件的書寫格式和 Windows 下的 INI 文件一樣,本文主要為大家介紹了goconfig框架的具體使用,需要的可以參考下2023-11-11
這篇文章主要介紹了Go語言通過smtp發(fā)送郵件的方法,涉及Go語言發(fā)送郵件的技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
Golang創(chuàng)建構(gòu)造函數(shù)的方法超詳細講解
構(gòu)造器一般面向?qū)ο笳Z言的典型特性，用于初始化變量。Go語言沒有任何具體構(gòu)造器，但我們能使用該特性去初始化變量。本文介紹不同類型構(gòu)造器的差異及其應用場景2023-01-01
Golang監(jiān)聽日志文件并發(fā)送到kafka中
這篇文章主要介紹了Golang監(jiān)聽日志文件并發(fā)送到kafka中，日志收集項目的準備中，本文主要講的是利用golang的tail庫，監(jiān)聽日志文件的變動，將日志信息發(fā)送到kafka中?,需要的朋友可以參考一下2022-04-04