[Java] Change Tests.sleep so that it uses LockSupport.parkNanos to pr…

…event catching of InterruptedException and clearing the interrupt flag.
aeron-io · Jan 2, 2025 · 598740f · 598740f
1 parent 3b92bca
commit 598740f
Showing 1 changed file with 8 additions and 24 deletions.
diff --git a/aeron-test-support/src/main/java/io/aeron/test/Tests.java b/aeron-test-support/src/main/java/io/aeron/test/Tests.java
@@ -53,7 +53,9 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.nio.file.attribute.BasicFileAttributes;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.locks.LockSupport;
 import java.util.function.*;
 
 import static io.aeron.Aeron.NULL_VALUE;
@@ -224,14 +226,8 @@ public static StringBuilder appendStackTrace(final StringBuilder sb, final Stack
      */
     public static void sleep(final long durationMs)
     {
-        try
-        {
-            Thread.sleep(durationMs);
-        }
-        catch (final InterruptedException ex)
-        {
-            throw new TimeoutException(ex, AeronException.Category.ERROR);
-        }
+        LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(durationMs));
+        checkInterruptStatus();
     }
 
     /**
@@ -242,14 +238,8 @@ public static void sleep(final long durationMs)
      */
     public static void sleep(final long durationMs, final Supplier<String> messageSupplier)
     {
-        try
-        {
-            Thread.sleep(durationMs);
-        }
-        catch (final InterruptedException ex)
-        {
-            throw new TimeoutException(messageSupplier.get());
-        }
+        LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(durationMs));
+        checkInterruptStatus(messageSupplier);
     }
 
     /**
@@ -261,14 +251,8 @@ public static void sleep(final long durationMs, final Supplier<String> messageSu
      */
     public static void sleep(final long durationMs, final String format, final Object... params)
     {
-        try
-        {
-            Thread.sleep(durationMs);
-        }
-        catch (final InterruptedException ex)
-        {
-            throw new TimeoutException(String.format(format, params));
-        }
+        LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(durationMs));
+        checkInterruptStatus(format, params);
     }
 
     /**