rename lock name

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>
neowu · Mar 22, 2024 · fc9e605 · fc9e605
1 parent aa8d2d0
commit fc9e605
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/core-ng/src/main/java/core/framework/internal/kafka/MessageListenerThread.java b/core-ng/src/main/java/core/framework/internal/kafka/MessageListenerThread.java
@@ -50,7 +50,7 @@ class MessageListenerThread extends Thread {
     private final int concurrency;
 
     private final ReentrantLock lock = new ReentrantLock();
-    private final Condition processingCondition = lock.newCondition();
+    private final Condition notProcessing = lock.newCondition();
     private boolean processing;
 
     private volatile boolean shutdown;
@@ -72,14 +72,14 @@ public void run() {
             process();
         } finally {
             processing = false;
-            notifyProcessingCondition();
+            signal();
         }
     }
 
-    private void notifyProcessingCondition() {
+    private void signal() {
         lock.lock();
         try {
-            processingCondition.signalAll();
+            notProcessing.signalAll();
         } finally {
             lock.unlock();
         }
@@ -139,7 +139,7 @@ boolean awaitTermination(long timeoutInMs) throws InterruptedException {
                 if (left <= 0) {
                     return false;
                 }
-                processingCondition.await(left, TimeUnit.MILLISECONDS);
+                notProcessing.await(left, TimeUnit.MILLISECONDS);
             }
             return true;
         } finally {

diff --git a/core-ng/src/main/java/core/framework/internal/web/ShutdownHandler.java b/core-ng/src/main/java/core/framework/internal/web/ShutdownHandler.java
@@ -20,7 +20,7 @@ public class ShutdownHandler implements ExchangeCompletionListener {
     private final Logger logger = LoggerFactory.getLogger(ShutdownHandler.class);
 
     private final ReentrantLock lock = new ReentrantLock();
-    private final Condition activeRequestCondition = lock.newCondition();
+    private final Condition noMoreActiveRequest = lock.newCondition();
 
     private volatile boolean shutdown;
 
@@ -55,7 +55,7 @@ boolean awaitTermination(long timeoutInMs) throws InterruptedException {
                 if (left <= 0) {
                     return false;
                 }
-                activeRequestCondition.await(left, TimeUnit.MILLISECONDS);
+                noMoreActiveRequest.await(left, TimeUnit.MILLISECONDS);
             }
             return true;
         } finally {
@@ -68,17 +68,17 @@ public void exchangeEvent(HttpServerExchange exchange, NextListener next) {
         try {
             int count = activeRequests.decrease();
             if (count <= 0 && shutdown) {
-                notifyActiveRequestCondition();
+                signal();
             }
         } finally {
             next.proceed();
         }
     }
 
-    private void notifyActiveRequestCondition() {
+    private void signal() {
         lock.lock();
         try {
-            activeRequestCondition.signalAll();
+            noMoreActiveRequest.signalAll();
         } finally {
             lock.unlock();
         }