如何定位死鎖

cokeboL

發(fā)個(gè)自己常用的庫(kù)： https://github.com/naivefox/foxmutex

sample:

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         fox "github.com/naivefox/foxmutex"
   
6.         "time"
   
7. )
   
8. 
   
9. func main() {
   
10.         fox.SetDebug(true, time.Second)
    
11. 
    
12.         mtx := fox.Mutex{}
    
13. 
    
14.         fmt.Println(111)
    
15.         mtx.Lock()
    
16.         fmt.Println(222)
    
17. 
    
18.         go func() {
    
19.                 fmt.Println(333)
    
20.                 mtx.Lock()
    
21.                 fmt.Println(444)
    
22.         }()
    
23. 
    
24.         time.Sleep(time.Hour)
    
25. }

復(fù)制代碼

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         fox "github.com/naivefox/foxmutex"
   
6.         "time"
   
7. )
   
8. 
   
9. func main() {
   
10.         fox.SetDebug(true, time.Second)
    
11. 
    
12.         mtx := fox.RWMutex{}
    
13. 
    
14.         fmt.Println(111)
    
15.         mtx.Lock()
    
16.         fmt.Println(222)
    
17. 
    
18.         go func() {
    
19.                 fmt.Println(333)
    
20.                 mtx.RLock()
    
21.                 fmt.Println(444)
    
22.         }()
    
23. 
    
24.         time.Sleep(time.Hour)
    
25. }

復(fù)制代碼

lxyscls

-race?????

cokeboL

回復(fù) 2# lxyscls

-race 有用嗎？你試下這段代碼能用-race解決嗎：

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         "sync"
   
6.         "time"
   
7. )
   
8. 
   
9. func main() {
   
10.         mtx := sync.Mutex{}
    
11. 
    
12.         fmt.Println(111)
    
13.         mtx.Lock()
    
14.         fmt.Println(222)
    
15. 
    
16.         go func() {
    
17.                 fmt.Println(333)
    
18.                 mtx.Lock()
    
19.                 fmt.Println(444)
    
20.         }()
    
21. 
    
22.         time.Sleep(time.Hour)
    
23. }
    

復(fù)制代碼

lxyscls

cokeboL 發(fā)表于 2017-08-30 21:59
回復(fù) 2# lxyscls

-race 有用嗎？你試下這段代碼能用-race解決嗎：

倫家剛把K大爺?shù)臅?shū)看完，一行代碼都沒(méi)寫(xiě)過(guò)呢

But，你這個(gè)代碼其實(shí)不是死鎖呢，1個(gè)小時(shí)后會(huì)解開(kāi)的

cokeboL

回復(fù) 4# lxyscls

我功力不夠所以只能鎖住它一小時(shí)，等我功力提升了把它鎖time.Hour * 2你先 go get "github.com/naivefox/foxmutex"
然后直接go run 我那個(gè)代碼就知道效果了

lxyscls

回復(fù) 5# cokeboL

這個(gè)求解釋

• 為什么在Mutex.Lock和RWMutex.Lock之后還要起timer？
• Lock之前的timer key沒(méi)有記下來(lái)，Unlock只有讓它自己超時(shí)
  

另外就是，timer中記錄log用到了另外一把鎖，應(yīng)該是防止log混亂的？但是這樣我覺(jué)得肯定會(huì)影響真正被使用的鎖的，興許原來(lái)要死鎖的，加了debug就不出了，還不如把log都buffer起來(lái)，一次性輸出，由fmt.println自己去保證。

cokeboL

回復(fù) 6# lxyscls

1.因?yàn)槟鉒ock()成功獲取了鎖，但是你很久不釋放，可能也是bug，所以也做了超時(shí)的log，就比如

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         fox "github.com/naivefox/foxmutex"
   
6.         "time"
   
7. )
   
8. 
   
9. func main() {
   
10.         fox.SetDebug(true, time.Second)
    
11. 
    
12.         mtx := fox.Mutex{}
    
13. 
    
14.         fmt.Println(111)
    
15.         mtx.Lock()
    
16.         fmt.Println(222)
    
17. 
    
18.         time.Sleep(time.Hour)
    
19. }

復(fù)制代碼

只調(diào)用一次Lock()，通常情況下不會(huì)鎖住太久
這個(gè)庫(kù)的日志是相當(dāng)于Warning，具體是不是死鎖由寫(xiě)代碼的人來(lái)根據(jù)實(shí)際情況判定

cokeboL

回復(fù) 6# lxyscls

2. Lock之前的timer key沒(méi)有記下來(lái)，Unlock只有讓它自己超時(shí)
這句沒(méi)太看懂。。
我弄兩個(gè)timer是因?yàn)?Lock() 之前的是獲取鎖失敗的超時(shí)告警
                            Lock() 之后的是獲取鎖成功但是超時(shí)沒(méi)釋放的告警

cokeboL

回復(fù) 6# lxyscls

“另外就是，timer中記錄log用到了另外一把鎖，應(yīng)該是防止log混亂的？但是這樣我覺(jué)得肯定會(huì)影響真正被使用的鎖的，興許原來(lái)要死鎖的，加了debug就不出了，還不如把log都buffer起來(lái)，一次性輸出，由fmt.println自己去保證�！�
用到另一把鎖是為了在不同的并行流中Lock()和Unlock()的時(shí)候根據(jù)自己的id來(lái)獲取、存儲(chǔ)、釋放之前的timer，因?yàn)閠imer是放
到 mtxmutexes（這個(gè)命名應(yīng)該改成mtxtimers...，懶得查找替換不打算改了） 這個(gè)全局map里，多個(gè)并行流，肯定要加鎖，
go 1.9的sync包里新增了個(gè)Map類(lèi)型是并發(fā)安全的，換成那個(gè)就不需要在foxmutex這里用另外一把鎖了，但是看了下源碼里面
還是map+mutex，感覺(jué)雞肋sync.Map也是個(gè)雞肋

還有就是，這個(gè)額外的鎖只是在getLockTimer、saveLockTimer、unsaveLockTimer里使用，這幾個(gè)func里可以保證這個(gè)額外
的鎖對(duì)原本要來(lái)debug的鎖沒(méi)有影響

另外就是性能問(wèn)題，這個(gè)包的鎖肯定性能不好，但是只作為調(diào)試期使用幫助發(fā)現(xiàn)問(wèn)題，我一般這樣寫(xiě)：

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         fox "github.com/naivefox/foxmutex"
   
6.         "time"
   
7. )
   
8. 
   
9. type MyMutex struct {
   
10.         fox.Mutex //debug
    
11.         //sync.Mutex //release
    
12. }
    
13. 
    
14. /* type MyMutex fox.Mutex 這樣不行，好像跟time包里的有關(guān) */
    
15. 
    
16. func init() {
    
17.         fox.SetDebug(true, time.Second)
    
18. }
    
19. 
    
20. func main() {
    
21.         mtx := MyMutex{}
    
22. 
    
23.         fmt.Println(111)
    
24.         mtx.Lock()
    
25.         fmt.Println(222)
    
26. 
    
27.         time.Sleep(time.Hour)
    
28. }

復(fù)制代碼

dorodaloo

我對(duì)于cokeboL老師，都是抱著敬仰的態(tài)度。