死鎖

死鎖的4個(gè)條件

• 不可剝奪

線程已經(jīng)獲得的資源，在未使用完之前，不能被其他線程剝奪，只能在使用完后自己釋放。

• 請(qǐng)求保持

線程 T1 保持了一個(gè)資源 R1 占用，但是又提出另外一個(gè)資源 R2 請(qǐng)求，此時(shí)，資源 R2 被線程 T2 占用，于是 T1 線程必須等待，但又對(duì)自己保持的 R1 資源不釋放。

• 循環(huán)等待

死鎖發(fā)生時(shí)，必然存在一個(gè) “進(jìn)程-資源環(huán)形鏈”，例如 進(jìn)程p0 等待 p1 占用資源，p1 等待 p2 占用的資源， p2 等待 p0 占用的資源，形成了一個(gè)環(huán)形鏈。

• 互斥

線程對(duì)資源訪問(wèn)是排斥的，如果一個(gè)線程占用了資源，那么其他線程必須處于等待狀態(tài)，直到資源釋放。

如何避免死鎖

如果并發(fā)的查詢多個(gè)表，要約定好訪問(wèn)順序

不能線程 T1 先訪問(wèn)表 A 后訪問(wèn)表 B，線程T2 先訪問(wèn) 表B 后訪問(wèn) 表A, 這個(gè)情況極容易死鎖。

• 在同一個(gè)事務(wù)中，盡可能一次鎖定獲取所需要的資源
• 對(duì)于容易產(chǎn)生死鎖的業(yè)務(wù)場(chǎng)景， 嘗試升級(jí)鎖的力度
• 采用分布式鎖或者使用樂(lè)觀鎖

死鎖代碼

package sync

import (
   "fmt"
   "runtime"
   "sync"
   "testing"
   "time"
)
type value struct {
   memAccess sync.Mutex
   value     int
}
func TestDeadLock(t *testing.T) {
   runtime.GOMAXPROCS(3)
   var wg sync.WaitGroup
   sum := func(v1, v2 *value) {
      defer wg.Done()
      v1.memAccess.Lock()  // 鎖 v1
      time.Sleep(2 * time.Second)
      v2.memAccess.Lock() //鎖 v2
      fmt.Printf("sum = %d\n", v1.value+v2.value)
      v2.memAccess.Unlock()
      v1.memAccess.Unlock()
   }
   product := func(v1, v2 *value) {
      defer wg.Done()
      v2.memAccess.Lock() // 鎖 v2
      time.Sleep(2 * time.Second)
      v1.memAccess.Lock() // 鎖 v1
      fmt.Printf("product = %d\n", v1.value*v2.value)
      v1.memAccess.Unlock()
      v2.memAccess.Unlock()
   }
   var v1, v2 value
   v1.value = 1
   v2.value = 1
   wg.Add(2)
   go sum(&v1, &v2)
   go product(&v1, &v2)
   wg.Wait()
}

運(yùn)行結(jié)果

=== RUN   TestDeadLock
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
testing.(*T).Run(0xc000122480, 0x116dd2c, 0xc, 0x1176e68, 0x1084de6)
 /usr/local/go/src/testing/testing.go:1240 +0x2da
testing.runTests.func1(0xc000122300)
 /usr/local/go/src/testing/testing.go:1512 +0x78
testing.tRunner(0xc000122300, 0xc00012dde0)
 /usr/local/go/src/testing/testing.go:1194 +0xef
testing.runTests(0xc0001320d8, 0x12540e0, 0x1, 0x1, 0x0, 0x0, 0x0, 0x116e218)
 /usr/local/go/src/testing/testing.go:1510 +0x2fe
testing.(*M).Run(0xc00014c080, 0x0)
 /usr/local/go/src/testing/testing.go:1418 +0x1eb
main.main()
 _testmain.go:51 +0x138

可以看到上述運(yùn)行結(jié)果中出現(xiàn) fatal error: all goroutines are asleep - deadlock!  線程T1 先獲得v1 ,然后獲得v2, 線程T2 先獲得v2，然后獲得v1。這樣滿足了死鎖循環(huán)等待等條件，會(huì)造成死鎖。

到此這篇關(guān)于Go 語(yǔ)言中的死鎖問(wèn)題解決的文章就介紹到這了,更多相關(guān)Go 死鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論