Use a monotonic clock for checking timeout on shutdown

LMAX-Exchange · Sep 29, 2023 · 95c705f · 95c705f
1 parent 8192ba7
commit 95c705f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/lmax/disruptor/dsl/Disruptor.java b/src/main/java/com/lmax/disruptor/dsl/Disruptor.java
@@ -404,10 +404,10 @@ public void shutdown()
      */
     public void shutdown(final long timeout, final TimeUnit timeUnit) throws TimeoutException
     {
-        final long timeOutAt = System.currentTimeMillis() + timeUnit.toMillis(timeout);
+        final long timeOutAt = System.nanoTime() + timeUnit.toNanos(timeout);
         while (hasBacklog())
         {
-            if (timeout >= 0 && System.currentTimeMillis() > timeOutAt)
+            if (timeout >= 0 && System.nanoTime() > timeOutAt)
             {
                 throw TimeoutException.INSTANCE;
             }