May be a (delayed) lock on mid, might fix the issue. Presuming that i…

…t is some race condition.
vpro · Nov 29, 2024 · 44c957d · 44c957d
1 parent f39b69e
commit 44c957d
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/vpro-shared-util/src/main/java/nl/vpro/util/locker/ObjectLocker.java b/vpro-shared-util/src/main/java/nl/vpro/util/locker/ObjectLocker.java
@@ -227,7 +227,7 @@ public static  <K extends Serializable> LockHolderCloser<K> acquireLock(
                         locks.remove(key);
                         continue;
                     }
-                    closer = new LockHolderCloser<>(nanoStart, locks, holder);
+                    closer = new LockHolderCloser<>(nanoStart, locks, holder, true);
                     if (holder.lock.isLocked() && !holder.lock.isHeldByCurrentThread()) {
                         log.debug("There are already threads ({}) for {}, waiting", holder.lock.getQueueLength(), key);
                         alreadyWaiting = true;
@@ -327,7 +327,8 @@ private static  <K extends Serializable> void releaseLock(
         final @NonNull K key,
         final @NonNull  String reason,
         final @NonNull Map<K, LockHolder<K>> locks,
-        final @NonNull LockHolder<K> lock) {
+        final @NonNull LockHolder<K> lock,
+        final boolean checkIfCurrentThread) {
         synchronized (locks) {
             if (lock.lock.getHoldCount() == 1) {
                 if (!lock.lock.hasQueuedThreads()) {
@@ -342,7 +343,7 @@ private static  <K extends Serializable> void releaseLock(
                 Slf4jHelper.log(log, duration.compareTo(lock.warnTime)> 0 ? Level.WARN :  Level.DEBUG,
                     "Released lock for {} ({}) in {}", key, reason, Duration.ofNanos(System.nanoTime() - nanoStart));
             }
-            if (lock.lock.isHeldByCurrentThread()) { // MSE-4946
+            if (! checkIfCurrentThread || lock.lock.isHeldByCurrentThread()) { // MSE-4946
                 HOLDS.get().remove(lock);
                 lock.lock.unlock();
             } else {
@@ -456,19 +457,25 @@ public static class LockHolderCloser<K extends Serializable> implements AutoClos
 
         final long nanoStart;
 
+        @With
+        final boolean checkIfCurrentThread;
+
         final @NonNull Map<K, LockHolder<K>> locks;
+
         private LockHolderCloser(
             final long nanoStart,
             @NonNull Map<K, LockHolder<K>> locks,
-            @NonNull LockHolder<K> lockHolder) {
+            @NonNull LockHolder<K> lockHolder,
+            final boolean checkIfCurrentThread) {
             this.nanoStart = nanoStart;
             this.locks = locks;
             this.lockHolder = lockHolder;
+            this.checkIfCurrentThread = checkIfCurrentThread;
         }
 
         @Override
         public void close() {
-            releaseLock(nanoStart, lockHolder.key, lockHolder.reason, locks, lockHolder);
+            releaseLock(nanoStart, lockHolder.key, lockHolder.reason, locks, lockHolder, checkIfCurrentThread);
         }
     }