removed synchronization block:

- AbstractFateStore still had a synchronization block for accessing `deferred` which was changed to a synchronized map in this PR; removed since there shouldn't be any more sync blocks in this class.
kevinrr888 · Aug 21, 2024 · 3557252 · 3557252
1 parent 55f02d1
commit 3557252
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java b/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java
@@ -193,12 +193,10 @@ public void runnable(AtomicBoolean keepWaiting, Consumer<FateId> idConsumer) {
       if (seen.get() == 0) {
         if (beforeCount == unreservedRunnableCount.getCount()) {
           long waitTime = 5000;
-          synchronized (AbstractFateStore.this) {
-            if (!deferred.isEmpty()) {
-              waitTime = deferred.values().stream()
-                  .mapToLong(countDownTimer -> countDownTimer.timeLeft(TimeUnit.MILLISECONDS)).min()
-                  .getAsLong();
-            }
+          if (!deferred.isEmpty()) {
+            waitTime = deferred.values().stream()
+                .mapToLong(countDownTimer -> countDownTimer.timeLeft(TimeUnit.MILLISECONDS)).min()
+                .getAsLong();
           }
 
           if (waitTime > 0) {