fix: correct inverted park condition in PooledTaskExecutorTest.LongTask (#971)

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: vharseko <6818498+vharseko@users.noreply.github.com>
Co-authored-by: Valery Kharseko <vharseko@3a-systems.ru>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: 3 people

openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/PooledTaskExecutorTest.java

@@ -12,7 +12,7 @@
  * information: "Portions copyright [year] [name of copyright owner]".
  *
  * Copyright 2015-2016 ForgeRock AS.
- * Portions copyright 2025 3A Systems LLC.
+ * Portions copyright 2023-2026 3A Systems LLC.
  */
 
 package org.forgerock.openam.sm.datalayer.impl;
@@ -22,10 +22,9 @@
 import static org.mockito.Mockito.*;
 
 import java.text.MessageFormat;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Semaphore;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.locks.LockSupport;
 
 import jakarta.inject.Provider;
 
@@ -148,18 +147,18 @@ public void run() {
 
     private static class LongTask implements Task {
 
-        private AtomicBoolean locked = new AtomicBoolean(false);
-        private Thread executingThread;
+        private final CountDownLatch latch = new CountDownLatch(1);
 
         @Override
         public void execute(TokenStorageAdapter adapter) throws DataLayerException {
-            this.executingThread = Thread.currentThread();
             debug("Locking");
-            locked.set(true);
-            while (!locked.compareAndSet(false, true)) {
-                debug("Task still locked - parking thread");
-                LockSupport.park(this);
-                debug("Thread unparked");
+            try {
+                if (!latch.await(30, TimeUnit.SECONDS)) {
+                    fail("LongTask was not unblocked within 30 seconds; test is likely hung.");
+                }
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+                throw new DataLayerException("Task was interrupted while waiting on latch", e);
             }
             debug("Thread unlocked - continuing");
         }
@@ -169,10 +168,7 @@ public void processError(DataLayerException error) {}
 
         public void unblock() {
             debug("Setting task unlocked");
-            locked.set(false);
-            debug("Unparking thread {0}", executingThread);
-            LockSupport.unpark(executingThread);
-            debug("Unparked thread {0}", executingThread);
+            latch.countDown();
         }
 
     }