rt/emul/compact/src/main/java/java/util/concurrent/atomic/AtomicLong.java
author Jaroslav Tulach <jtulach@netbeans.org>
Thu, 03 Oct 2013 15:40:35 +0200
branchjdk7-b147
changeset 1334 588d5bf7a560
child 1338 aa70afac4eca
permissions -rw-r--r--
Set of JDK classes needed to run javac
jtulach@1334
     1
/*
jtulach@1334
     2
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
jtulach@1334
     3
 *
jtulach@1334
     4
 * This code is free software; you can redistribute it and/or modify it
jtulach@1334
     5
 * under the terms of the GNU General Public License version 2 only, as
jtulach@1334
     6
 * published by the Free Software Foundation.  Oracle designates this
jtulach@1334
     7
 * particular file as subject to the "Classpath" exception as provided
jtulach@1334
     8
 * by Oracle in the LICENSE file that accompanied this code.
jtulach@1334
     9
 *
jtulach@1334
    10
 * This code is distributed in the hope that it will be useful, but WITHOUT
jtulach@1334
    11
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
jtulach@1334
    12
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
jtulach@1334
    13
 * version 2 for more details (a copy is included in the LICENSE file that
jtulach@1334
    14
 * accompanied this code).
jtulach@1334
    15
 *
jtulach@1334
    16
 * You should have received a copy of the GNU General Public License version
jtulach@1334
    17
 * 2 along with this work; if not, write to the Free Software Foundation,
jtulach@1334
    18
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
jtulach@1334
    19
 *
jtulach@1334
    20
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
jtulach@1334
    21
 * or visit www.oracle.com if you need additional information or have any
jtulach@1334
    22
 * questions.
jtulach@1334
    23
 */
jtulach@1334
    24
jtulach@1334
    25
/*
jtulach@1334
    26
 * This file is available under and governed by the GNU General Public
jtulach@1334
    27
 * License version 2 only, as published by the Free Software Foundation.
jtulach@1334
    28
 * However, the following notice accompanied the original version of this
jtulach@1334
    29
 * file:
jtulach@1334
    30
 *
jtulach@1334
    31
 * Written by Doug Lea with assistance from members of JCP JSR-166
jtulach@1334
    32
 * Expert Group and released to the public domain, as explained at
jtulach@1334
    33
 * http://creativecommons.org/publicdomain/zero/1.0/
jtulach@1334
    34
 */
jtulach@1334
    35
jtulach@1334
    36
package java.util.concurrent.atomic;
jtulach@1334
    37
import sun.misc.Unsafe;
jtulach@1334
    38
jtulach@1334
    39
/**
jtulach@1334
    40
 * A {@code long} value that may be updated atomically.  See the
jtulach@1334
    41
 * {@link java.util.concurrent.atomic} package specification for
jtulach@1334
    42
 * description of the properties of atomic variables. An
jtulach@1334
    43
 * {@code AtomicLong} is used in applications such as atomically
jtulach@1334
    44
 * incremented sequence numbers, and cannot be used as a replacement
jtulach@1334
    45
 * for a {@link java.lang.Long}. However, this class does extend
jtulach@1334
    46
 * {@code Number} to allow uniform access by tools and utilities that
jtulach@1334
    47
 * deal with numerically-based classes.
jtulach@1334
    48
 *
jtulach@1334
    49
 * @since 1.5
jtulach@1334
    50
 * @author Doug Lea
jtulach@1334
    51
 */
jtulach@1334
    52
public class AtomicLong extends Number implements java.io.Serializable {
jtulach@1334
    53
    private static final long serialVersionUID = 1927816293512124184L;
jtulach@1334
    54
jtulach@1334
    55
    // setup to use Unsafe.compareAndSwapLong for updates
jtulach@1334
    56
    private static final Unsafe unsafe = Unsafe.getUnsafe();
jtulach@1334
    57
    private static final long valueOffset;
jtulach@1334
    58
jtulach@1334
    59
    /**
jtulach@1334
    60
     * Records whether the underlying JVM supports lockless
jtulach@1334
    61
     * compareAndSwap for longs. While the Unsafe.compareAndSwapLong
jtulach@1334
    62
     * method works in either case, some constructions should be
jtulach@1334
    63
     * handled at Java level to avoid locking user-visible locks.
jtulach@1334
    64
     */
jtulach@1334
    65
    static final boolean VM_SUPPORTS_LONG_CAS = VMSupportsCS8();
jtulach@1334
    66
jtulach@1334
    67
    /**
jtulach@1334
    68
     * Returns whether underlying JVM supports lockless CompareAndSet
jtulach@1334
    69
     * for longs. Called only once and cached in VM_SUPPORTS_LONG_CAS.
jtulach@1334
    70
     */
jtulach@1334
    71
    private static native boolean VMSupportsCS8();
jtulach@1334
    72
jtulach@1334
    73
    static {
jtulach@1334
    74
      try {
jtulach@1334
    75
        valueOffset = unsafe.objectFieldOffset
jtulach@1334
    76
            (AtomicLong.class.getDeclaredField("value"));
jtulach@1334
    77
      } catch (Exception ex) { throw new Error(ex); }
jtulach@1334
    78
    }
jtulach@1334
    79
jtulach@1334
    80
    private volatile long value;
jtulach@1334
    81
jtulach@1334
    82
    /**
jtulach@1334
    83
     * Creates a new AtomicLong with the given initial value.
jtulach@1334
    84
     *
jtulach@1334
    85
     * @param initialValue the initial value
jtulach@1334
    86
     */
jtulach@1334
    87
    public AtomicLong(long initialValue) {
jtulach@1334
    88
        value = initialValue;
jtulach@1334
    89
    }
jtulach@1334
    90
jtulach@1334
    91
    /**
jtulach@1334
    92
     * Creates a new AtomicLong with initial value {@code 0}.
jtulach@1334
    93
     */
jtulach@1334
    94
    public AtomicLong() {
jtulach@1334
    95
    }
jtulach@1334
    96
jtulach@1334
    97
    /**
jtulach@1334
    98
     * Gets the current value.
jtulach@1334
    99
     *
jtulach@1334
   100
     * @return the current value
jtulach@1334
   101
     */
jtulach@1334
   102
    public final long get() {
jtulach@1334
   103
        return value;
jtulach@1334
   104
    }
jtulach@1334
   105
jtulach@1334
   106
    /**
jtulach@1334
   107
     * Sets to the given value.
jtulach@1334
   108
     *
jtulach@1334
   109
     * @param newValue the new value
jtulach@1334
   110
     */
jtulach@1334
   111
    public final void set(long newValue) {
jtulach@1334
   112
        value = newValue;
jtulach@1334
   113
    }
jtulach@1334
   114
jtulach@1334
   115
    /**
jtulach@1334
   116
     * Eventually sets to the given value.
jtulach@1334
   117
     *
jtulach@1334
   118
     * @param newValue the new value
jtulach@1334
   119
     * @since 1.6
jtulach@1334
   120
     */
jtulach@1334
   121
    public final void lazySet(long newValue) {
jtulach@1334
   122
        unsafe.putOrderedLong(this, valueOffset, newValue);
jtulach@1334
   123
    }
jtulach@1334
   124
jtulach@1334
   125
    /**
jtulach@1334
   126
     * Atomically sets to the given value and returns the old value.
jtulach@1334
   127
     *
jtulach@1334
   128
     * @param newValue the new value
jtulach@1334
   129
     * @return the previous value
jtulach@1334
   130
     */
jtulach@1334
   131
    public final long getAndSet(long newValue) {
jtulach@1334
   132
        while (true) {
jtulach@1334
   133
            long current = get();
jtulach@1334
   134
            if (compareAndSet(current, newValue))
jtulach@1334
   135
                return current;
jtulach@1334
   136
        }
jtulach@1334
   137
    }
jtulach@1334
   138
jtulach@1334
   139
    /**
jtulach@1334
   140
     * Atomically sets the value to the given updated value
jtulach@1334
   141
     * if the current value {@code ==} the expected value.
jtulach@1334
   142
     *
jtulach@1334
   143
     * @param expect the expected value
jtulach@1334
   144
     * @param update the new value
jtulach@1334
   145
     * @return true if successful. False return indicates that
jtulach@1334
   146
     * the actual value was not equal to the expected value.
jtulach@1334
   147
     */
jtulach@1334
   148
    public final boolean compareAndSet(long expect, long update) {
jtulach@1334
   149
        return unsafe.compareAndSwapLong(this, valueOffset, expect, update);
jtulach@1334
   150
    }
jtulach@1334
   151
jtulach@1334
   152
    /**
jtulach@1334
   153
     * Atomically sets the value to the given updated value
jtulach@1334
   154
     * if the current value {@code ==} the expected value.
jtulach@1334
   155
     *
jtulach@1334
   156
     * <p>May <a href="package-summary.html#Spurious">fail spuriously</a>
jtulach@1334
   157
     * and does not provide ordering guarantees, so is only rarely an
jtulach@1334
   158
     * appropriate alternative to {@code compareAndSet}.
jtulach@1334
   159
     *
jtulach@1334
   160
     * @param expect the expected value
jtulach@1334
   161
     * @param update the new value
jtulach@1334
   162
     * @return true if successful.
jtulach@1334
   163
     */
jtulach@1334
   164
    public final boolean weakCompareAndSet(long expect, long update) {
jtulach@1334
   165
        return unsafe.compareAndSwapLong(this, valueOffset, expect, update);
jtulach@1334
   166
    }
jtulach@1334
   167
jtulach@1334
   168
    /**
jtulach@1334
   169
     * Atomically increments by one the current value.
jtulach@1334
   170
     *
jtulach@1334
   171
     * @return the previous value
jtulach@1334
   172
     */
jtulach@1334
   173
    public final long getAndIncrement() {
jtulach@1334
   174
        while (true) {
jtulach@1334
   175
            long current = get();
jtulach@1334
   176
            long next = current + 1;
jtulach@1334
   177
            if (compareAndSet(current, next))
jtulach@1334
   178
                return current;
jtulach@1334
   179
        }
jtulach@1334
   180
    }
jtulach@1334
   181
jtulach@1334
   182
    /**
jtulach@1334
   183
     * Atomically decrements by one the current value.
jtulach@1334
   184
     *
jtulach@1334
   185
     * @return the previous value
jtulach@1334
   186
     */
jtulach@1334
   187
    public final long getAndDecrement() {
jtulach@1334
   188
        while (true) {
jtulach@1334
   189
            long current = get();
jtulach@1334
   190
            long next = current - 1;
jtulach@1334
   191
            if (compareAndSet(current, next))
jtulach@1334
   192
                return current;
jtulach@1334
   193
        }
jtulach@1334
   194
    }
jtulach@1334
   195
jtulach@1334
   196
    /**
jtulach@1334
   197
     * Atomically adds the given value to the current value.
jtulach@1334
   198
     *
jtulach@1334
   199
     * @param delta the value to add
jtulach@1334
   200
     * @return the previous value
jtulach@1334
   201
     */
jtulach@1334
   202
    public final long getAndAdd(long delta) {
jtulach@1334
   203
        while (true) {
jtulach@1334
   204
            long current = get();
jtulach@1334
   205
            long next = current + delta;
jtulach@1334
   206
            if (compareAndSet(current, next))
jtulach@1334
   207
                return current;
jtulach@1334
   208
        }
jtulach@1334
   209
    }
jtulach@1334
   210
jtulach@1334
   211
    /**
jtulach@1334
   212
     * Atomically increments by one the current value.
jtulach@1334
   213
     *
jtulach@1334
   214
     * @return the updated value
jtulach@1334
   215
     */
jtulach@1334
   216
    public final long incrementAndGet() {
jtulach@1334
   217
        for (;;) {
jtulach@1334
   218
            long current = get();
jtulach@1334
   219
            long next = current + 1;
jtulach@1334
   220
            if (compareAndSet(current, next))
jtulach@1334
   221
                return next;
jtulach@1334
   222
        }
jtulach@1334
   223
    }
jtulach@1334
   224
jtulach@1334
   225
    /**
jtulach@1334
   226
     * Atomically decrements by one the current value.
jtulach@1334
   227
     *
jtulach@1334
   228
     * @return the updated value
jtulach@1334
   229
     */
jtulach@1334
   230
    public final long decrementAndGet() {
jtulach@1334
   231
        for (;;) {
jtulach@1334
   232
            long current = get();
jtulach@1334
   233
            long next = current - 1;
jtulach@1334
   234
            if (compareAndSet(current, next))
jtulach@1334
   235
                return next;
jtulach@1334
   236
        }
jtulach@1334
   237
    }
jtulach@1334
   238
jtulach@1334
   239
    /**
jtulach@1334
   240
     * Atomically adds the given value to the current value.
jtulach@1334
   241
     *
jtulach@1334
   242
     * @param delta the value to add
jtulach@1334
   243
     * @return the updated value
jtulach@1334
   244
     */
jtulach@1334
   245
    public final long addAndGet(long delta) {
jtulach@1334
   246
        for (;;) {
jtulach@1334
   247
            long current = get();
jtulach@1334
   248
            long next = current + delta;
jtulach@1334
   249
            if (compareAndSet(current, next))
jtulach@1334
   250
                return next;
jtulach@1334
   251
        }
jtulach@1334
   252
    }
jtulach@1334
   253
jtulach@1334
   254
    /**
jtulach@1334
   255
     * Returns the String representation of the current value.
jtulach@1334
   256
     * @return the String representation of the current value.
jtulach@1334
   257
     */
jtulach@1334
   258
    public String toString() {
jtulach@1334
   259
        return Long.toString(get());
jtulach@1334
   260
    }
jtulach@1334
   261
jtulach@1334
   262
jtulach@1334
   263
    public int intValue() {
jtulach@1334
   264
        return (int)get();
jtulach@1334
   265
    }
jtulach@1334
   266
jtulach@1334
   267
    public long longValue() {
jtulach@1334
   268
        return get();
jtulach@1334
   269
    }
jtulach@1334
   270
jtulach@1334
   271
    public float floatValue() {
jtulach@1334
   272
        return (float)get();
jtulach@1334
   273
    }
jtulach@1334
   274
jtulach@1334
   275
    public double doubleValue() {
jtulach@1334
   276
        return (double)get();
jtulach@1334
   277
    }
jtulach@1334
   278
jtulach@1334
   279
}