--- jsr166/src/jsr166e/CompletableFuture.java 2013/01/03 07:01:49 1.4 +++ jsr166/src/jsr166e/CompletableFuture.java 2013/02/06 07:51:57 1.11 @@ -83,9 +83,9 @@ public class CompletableFuture implem /* * Overview: * - * 1. Non-nullness of field result (set via CAS) indicates - * done. An AltResult is used to box null as a result, as well as - * to hold exceptions. Using a single field makes completion fast + * 1. Non-nullness of field result (set via CAS) indicates done. + * An AltResult is used to box null as a result, as well as to + * hold exceptions. Using a single field makes completion fast * and simple to detect and trigger, at the expense of a lot of * encoding and decoding that infiltrates many methods. One minor * simplification relies on the (static) NIL (to box null results) @@ -388,7 +388,7 @@ public class CompletableFuture implem } /** Base class can act as either FJ or plain Runnable */ - static abstract class Async extends ForkJoinTask + abstract static class Async extends ForkJoinTask implements Runnable, AsynchronousCompletionTask { public final Void getRawResult() { return null; } public final void setRawResult(Void v) { } @@ -557,7 +557,7 @@ public class CompletableFuture implem } // Opportunistically subclass AtomicInteger to use compareAndSet to claim. - static abstract class Completion extends AtomicInteger implements Runnable { + abstract static class Completion extends AtomicInteger implements Runnable { } static final class ApplyCompletion extends Completion { @@ -2449,10 +2449,10 @@ public class CompletableFuture implem * then the returned CompletableFuture also does so, with a * CompletionException holding this exception as its cause. * - * @param fn the function returning a new CompletableFuture. + * @param fn the function returning a new CompletableFuture * @return the CompletableFuture, that {@code isDone()} upon * return if completed by the given function, or an exception - * occurs. + * occurs */ public CompletableFuture thenCompose(Fun> fn) { @@ -2633,17 +2633,16 @@ public class CompletableFuture implem */ public boolean isCancelled() { Object r; - return ((r = result) != null && - (r instanceof AltResult) && - (((AltResult)r).ex instanceof CancellationException)); + return ((r = result) instanceof AltResult) && + (((AltResult)r).ex instanceof CancellationException); } /** * Forcibly sets or resets the value subsequently returned by - * method get() and related methods, whether or not already - * completed. This method is designed for use only in error - * recovery actions, and even in such situations may result in - * ongoing dependent completions using established versus + * method {@link #get()} and related methods, whether or not + * already completed. This method is designed for use only in + * error recovery actions, and even in such situations may result + * in ongoing dependent completions using established versus * overwritten outcomes. * * @param value the completion value @@ -2654,9 +2653,9 @@ public class CompletableFuture implem } /** - * Forcibly causes subsequent invocations of method get() and - * related methods to throw the given exception, whether or not - * already completed. This method is designed for use only in + * Forcibly causes subsequent invocations of method {@link #get()} + * and related methods to throw the given exception, whether or + * not already completed. This method is designed for use only in * recovery actions, and even in such situations may result in * ongoing dependent completions using established versus * overwritten outcomes. @@ -2700,22 +2699,23 @@ public class CompletableFuture implem private static sun.misc.Unsafe getUnsafe() { try { return sun.misc.Unsafe.getUnsafe(); - } catch (SecurityException se) { - try { - return java.security.AccessController.doPrivileged - (new java.security - .PrivilegedExceptionAction() { - public sun.misc.Unsafe run() throws Exception { - java.lang.reflect.Field f = sun.misc - .Unsafe.class.getDeclaredField("theUnsafe"); - f.setAccessible(true); - return (sun.misc.Unsafe) f.get(null); - }}); - } catch (java.security.PrivilegedActionException e) { - throw new RuntimeException("Could not initialize intrinsics", - e.getCause()); - } + } catch (SecurityException tryReflectionInstead) {} + try { + return java.security.AccessController.doPrivileged + (new java.security.PrivilegedExceptionAction() { + public sun.misc.Unsafe run() throws Exception { + Class k = sun.misc.Unsafe.class; + for (java.lang.reflect.Field f : k.getDeclaredFields()) { + f.setAccessible(true); + Object x = f.get(null); + if (k.isInstance(x)) + return k.cast(x); + } + throw new NoSuchFieldError("the Unsafe"); + }}); + } catch (java.security.PrivilegedActionException e) { + throw new RuntimeException("Could not initialize intrinsics", + e.getCause()); } } - }