--- jsr166/src/jsr166e/CompletableFuture.java 2013/01/02 18:20:16 1.3 +++ jsr166/src/jsr166e/CompletableFuture.java 2013/01/03 07:01:49 1.4 @@ -287,7 +287,7 @@ public class CompletableFuture implem else if (q.thread != null && result == null) { try { ForkJoinPool.managedBlock(q); - } catch(InterruptedException ex){ + } catch (InterruptedException ex) { q.interruptControl = -1; } } @@ -320,7 +320,7 @@ public class CompletableFuture implem if (nanos <= 0L) throw new TimeoutException(); long d = System.nanoTime() + nanos; - q = new WaitNode(true, nanos, d == 0L? 1L : d); // avoid 0 + q = new WaitNode(true, nanos, d == 0L ? 1L : d); // avoid 0 } else if (!queued) queued = UNSAFE.compareAndSwapObject(this, WAITERS, @@ -338,7 +338,7 @@ public class CompletableFuture implem else if (q.thread != null && result == null) { try { ForkJoinPool.managedBlock(q); - } catch(InterruptedException ex){ + } catch (InterruptedException ex) { q.interruptControl = -1; } }