Redisson 分布式鎖源碼之公平鎖釋放
前言
看門狗機制是在 RedissonBaseLock#scheduleExpirationRenewal 方法中,這塊公平鎖和非公平鎖并無區(qū)別。
前文已經了解到,公平鎖加鎖失敗之后,會將當前放到等待隊列中,通過 Java 代碼中的循環(huán)不斷嘗試獲得鎖。
1.鎖釋放
主動釋放
源碼:RedissonFairLock#unlockInnerAsync
- KEYS[1]:加鎖的名字,anyLock;
- KEYS[2]:加鎖等待隊列,redisson_lock_queue:{anyLock};
- KEYS[3]:等待隊列中線程鎖時間的 set 集合,redisson_lock_timeout:{anyLock},是按照鎖的時間戳存放到集合中的;
- KEYS[4]:redisson_lock__channel:{anyLock};
- ARGV[1]:LockPubSub.UNLOCK_MESSAGE;
- ARGV[2]:鎖超時時間 30000;
- ARGV[3]:UUID:ThreadId 組合 58f6c4a2-9908-4957-b229-283a45359c4b:47;
- ARGV[4]:currentTime 當前時間戳。
這塊邏輯突出部分已經標出,重點就是釋放鎖。
- 鎖在隊列中,超時了則直接從隊列中移除;
- 鎖減少重入次數,減少后,如果重入次數大于 0,重置超時時間,如果不大于 0,則直接移除鎖。
這樣的話后續(xù)就其他線程從等待隊列中開始獲得鎖。
超時刪除
在加鎖和釋放鎖的 lua 腳本中,第一段永遠是一個 while true do xxx,作用就是用來移除隊列中超時的鎖。
而持鎖線程的釋放,則和非公平鎖沒有任何區(qū)別,當鎖超時或者服務宕機,鎖就會被自動釋放。(這個是指 anyLock)。
2.總結
公平鎖的釋放同樣分為主動釋放和超時釋放。
主動釋放,即自己調用釋放鎖。
超時刪除,則分為兩種,一種是持鎖線程超時刪除,這種和非公平鎖沒有任何區(qū)別,因為這個鎖也是含有超時時間+看門狗續(xù)租的。另一種則是等待隊列中的超時刪除,是在每次獲取鎖之前,判斷第一個等待線程的時間戳是否超時,從而移除鎖。
本文轉載自微信公眾號「程序員小航」,可以通過以下二維碼關注。轉載本文請聯系程序員小航公眾號。