update

hellooo-stack · Sep 28, 2023 · 7557ad3 · 7557ad3
1 parent 64b3aa3
commit 7557ad3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/site/hellooo/distributedlock/impl/redis/RedisLockCallback.java b/src/main/java/site/hellooo/distributedlock/impl/redis/RedisLockCallback.java
@@ -33,7 +33,7 @@ private void startRetryLockThread() {
         while (retryLockThread == null || retryLockThread.getState() == Thread.State.TERMINATED) {
             if (retryLockThreadReference.compareAndSet(retryLockThread, new RemotingRetryLockThread(lockContext))) {
                 retryLockThread = retryLockThreadReference.get();
-//                one process have only one running retryLockThread
+                // one process have only one running retryLockThread
                 retryLockThread.start();
             }
         }
@@ -72,7 +72,7 @@ public void afterLocked(LockContext lockContext) {
 
     @Override
     public void beforeParking(LockContext lockContext) {
-//        if current process not holding the lock, then we should start the retry lock thread
+        // if current process not holding the lock, then we should start the retry lock thread
         if (lockContext.holdingThread().get() == null) {
             startRetryLockThread();
         }

diff --git a/src/main/java/site/hellooo/distributedlock/impl/redis/RedisLockHandler.java b/src/main/java/site/hellooo/distributedlock/impl/redis/RedisLockHandler.java
@@ -96,7 +96,7 @@ public boolean doLease(LockContext lockContext) {
         Object leaseResult = null;
         try {
             LockState<?> lockState = lockContext.holdingLockState().get();
-//            if success, value will be "1"
+            //  if success, value will be "1"
             leaseResult = jedis.eval(leaseScript, Collections.singletonList(lockState.getIdentifier()), Arrays.asList((String) lockState.getValue(), lockContext.options().getLeaseMilliseconds() + ""));
         } catch (Exception ignored) {
 

diff --git a/src/main/java/site/hellooo/distributedlock/impl/redis/RemotingRetryLockThread.java b/src/main/java/site/hellooo/distributedlock/impl/redis/RemotingRetryLockThread.java
@@ -33,8 +33,8 @@ private void doRetry() throws InterruptedException {
         RedisLockHandler lockHandler = (RedisLockHandler) lockContext.lockHandler();
         boolean isStateExists = lockHandler.checkStateExists(lockContext.target());
         if (!isStateExists) {
-//            lock hold by other process has been released,
-//            then we unpark queued head thread in current process
+//             lock hold by other process has been released,
+//             then we unpark queued head thread in current process
             ReentrantDistributedLock lock = (ReentrantDistributedLock) lockContext.currentLock();
             lock.unparkQueueHead();
         }