Merge 6f2856e into bcca6e2

CorfuDB · Dec 11, 2017 · 20c34f1 · 20c34f1
2 parents bcca6e2 + 6f2856e
commit 20c34f1
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/runtime/src/main/java/org/corfudb/util/CFUtils.java b/runtime/src/main/java/org/corfudb/util/CFUtils.java
@@ -92,6 +92,9 @@ public static <T> T getUninterruptibly(Future<T> future) {
                 RuntimeException.class, RuntimeException.class);
     }
 
+    /** A static timeout exception that we complete futures exceptionally with. */
+    static final TimeoutException TIMEOUT_EXCEPTION = new TimeoutException();
+
     /**
      * Generates a completable future which times out.
      * inspired by NoBlogDefFound: http://www.nurkiewicz.com/2014/12/asynchronous-timeouts-with.html
@@ -102,11 +105,8 @@ public static <T> T getUninterruptibly(Future<T> future) {
      */
     public static <T> CompletableFuture<T> failAfter(Duration duration) {
         final CompletableFuture<T> promise = new CompletableFuture<>();
-        scheduler.schedule(() -> {
-            final TimeoutException ex = new TimeoutException("Timeout after "
-                    + duration.toMillis() + " ms");
-            return promise.completeExceptionally(ex);
-        }, duration.toMillis(), TimeUnit.MILLISECONDS);
+        scheduler.schedule(() -> promise.completeExceptionally(TIMEOUT_EXCEPTION),
+                                        duration.toMillis(), TimeUnit.MILLISECONDS);
         return promise;
     }