private boolean internalLock(long time, TimeUnit unit) throws Exception{ Thread currentThread = Thread.currentThread(); LockData lockData = threadData.get(currentThread); if ( lockData != null ){ // 實(shí)現(xiàn)可重入 // 同一線(xiàn)程再次acquire，首先判斷當(dāng)前的映射表內(nèi)（threadData）是否有該線(xiàn)程的鎖信息，如果有則原子+1，然后返回 lockData.lockCount.incrementAndGet(); return true; } // 映射表內(nèi)沒(méi)有對(duì)應(yīng)的鎖信息，嘗試通過(guò)LockInternals獲取鎖 String lockPath = internals.attemptLock(time, unit, getLockNodeBytes()); if ( lockPath != null ){ // 成功獲取鎖，記錄信息到映射表 LockData newLockData = new LockData(currentThread, lockPath); threadData.put(currentThread, newLockData); return true; } return false; } // 映射表 // 記錄線(xiàn)程與鎖信息的映射關(guān)系 private final ConcurrentMap<Thread, LockData> threadData = Maps.newConcurrentMap(); // 鎖信息 // Zookeeper中一個(gè)臨時(shí)順序節(jié)點(diǎn)對(duì)應(yīng)一個(gè)“鎖”，但讓鎖生效激活需要排隊(duì)（公平鎖），下面會(huì)繼續(xù)分析 private static class LockData{ final Thread owningThread; final String lockPath; final AtomicInteger lockCount = new AtomicInteger(1); // 分布式鎖重入次數(shù) private LockData(Thread owningThread, String lockPath){ this.owningThread = owningThread; this.lockPath = lockPath; } }

?

總結(jié)

以上是生活随笔為你收集整理的Curator实现分布式锁的基本原理-InterProcessMutex.internalLock的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。