ZooKeeper 分布式鎖 Curator 源碼之二：可重入鎖重復加鎖和鎖釋放

作者： 程序員小航 2021-07-09 06:48:31

大數(shù)據(jù)

分布式 當鎖需要釋放的時候，只需要調(diào)用 lock.release() 進行釋放即可，具體是如何釋放的呢？

創(chuàng)新互聯(lián)公司專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務，包含不限于成都網(wǎng)站設計、做網(wǎng)站、魏縣網(wǎng)絡推廣、重慶小程序開發(fā)、魏縣網(wǎng)絡營銷、魏縣企業(yè)策劃、魏縣品牌公關、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務，您的肯定，是我們最大的嘉獎；創(chuàng)新互聯(lián)公司為所有大學生創(chuàng)業(yè)者提供魏縣建站搭建服務，24小時服務熱線：028-86922220，官方網(wǎng)址：www.cdcxhl.com

前言

加鎖邏輯已經(jīng)介紹完畢，那當一個線程重復加鎖是如何處理的呢?

1.鎖重入

在上一小節(jié)中，可以看到加鎖的過程，再回頭看 internalLock 這個方法。

加鎖成功之后，將當前線程放到 threadData 中，threadData 是 ConcurrentMap

假如鎖重入了，直接就會在上一部分 lockData != null 被攔下，然后執(zhí)行 lockData.lockCount.incrementAndGet();。

對 lockCount 自增，代表了鎖重入。

這里發(fā)現(xiàn)了吧!Curator 的鎖重入是在 Java 代碼中實現(xiàn)的。

2.鎖釋放

當鎖需要釋放的時候，只需要調(diào)用 lock.release() 進行釋放即可，具體是如何釋放的呢?

主要分為兩部分：

1. 遞減 threadData 中當前線程的加鎖次數(shù);
2. 加鎖次數(shù)大于 0，說明還剩余重入次數(shù)，直接返回;
3. 加鎖次數(shù)等于 0，則 releaseLock 釋放鎖，并刪除 threadData 中當前線程 key。

releaseLock 方法中就沒有多少復雜邏輯了，就是移除監(jiān)聽器，刪除臨時順序節(jié)點。也就是 /locks/lock_01/_c_e855d232-c636-4241-bf8e-f047939a5833-lock-0000000001。

3.總結

ZooKeeper 的 InterProcessMutex 鎖是通過 Java 代碼中維護了一個 lockCount 來判斷是否重入的。

本文轉(zhuǎn)載自微信公眾號「程序員小航」，可以通過以下二維碼關注。轉(zhuǎn)載本文請聯(lián)系程序員小航公眾號。

當前名稱：ZooKeeper 分布式鎖 Curator 源碼之二：可重入鎖重復加鎖和鎖釋放
標題網(wǎng)址：http://fisionsoft.com.cn/article/dhgihec.html