--- jsr166/src/jsr166e/extra/AtomicDouble.java 2011/08/09 07:44:08 1.2 +++ jsr166/src/jsr166e/extra/AtomicDouble.java 2011/08/09 19:10:29 1.4 @@ -8,14 +8,13 @@ package jsr166e.extra; import static java.lang.Double.doubleToRawLongBits; import static java.lang.Double.longBitsToDouble; -import sun.misc.Unsafe; /** * A {@code double} value that may be updated atomically. See the * {@link java.util.concurrent.atomic} package specification for * description of the properties of atomic variables. An {@code - * AtomicDouble} is used in applications such as atomic summation, and - * cannot be used as a replacement for a {@link Double}. However, + * AtomicDouble} is used in applications such as atomic accumulation, + * and cannot be used as a replacement for a {@link Double}. However, * this class does extend {@code Number} to allow uniform access by * tools and utilities that deal with numerically-based classes. * @@ -29,40 +28,17 @@ import sun.misc.Unsafe; * long yBits = Double.doubleToRawLongBits(y); * return xBits == yBits; * }} - * - * @since 1.5 + * * @author Doug Lea * @author Martin Buchholz */ public class AtomicDouble extends Number implements java.io.Serializable { - private static final long serialVersionUID = 1927816293512124184L; + static final long serialVersionUID = -8405198993435143622L; // setup to use Unsafe.compareAndSwapLong for updates - private static final Unsafe unsafe = Unsafe.getUnsafe(); + private static final sun.misc.Unsafe unsafe = getUnsafe(); private static final long valueOffset; - /** - * Records whether the underlying JVM supports lockless - * compareAndSwap for longs. While the Unsafe.compareAndSwapLong - * method works in either case, some constructions should be - * handled at Java level to avoid locking user-visible locks. - */ - static final boolean VM_SUPPORTS_LONG_CAS = VMSupportsCS8(); - - /** - * Returns whether underlying JVM supports lockless CompareAndSet - * for longs. Called only once and cached in VM_SUPPORTS_LONG_CAS. - */ - private static boolean VMSupportsCS8() { - try { - Class klazz = java.util.concurrent.atomic.AtomicLong.class; - java.lang.reflect.Method m = - klazz.getDeclaredMethod("VMSupportsCS8", new Class[0]); - m.setAccessible(true); - return (Boolean) m.invoke(new Class[0]); - } catch (Throwable t) { throw new Error(t); } - } - static { try { valueOffset = unsafe.objectFieldOffset @@ -108,7 +84,6 @@ public class AtomicDouble extends Number * Eventually sets to the given value. * * @param newValue the new value - * @since 1.6 */ public final void lazySet(double newValue) { unsafe.putOrderedLong(this, valueOffset, doubleToRawLongBits(newValue)); @@ -232,4 +207,32 @@ public class AtomicDouble extends Number return get(); } + /** + * Returns a sun.misc.Unsafe. Suitable for use in a 3rd party package. + * Replace with a simple call to Unsafe.getUnsafe when integrating + * into a jdk. + * + * @return a sun.misc.Unsafe + */ + 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()); + } + } + } + }