Java 并发 - AtomicLong 类

java.util.concurrent.atomic.AtomicLong 类提供对底层 long 值的操作,这些操作可以原子方式读写,并且还包含高级原子操作。 AtomicLong 支持对底层 long 变量进行原子操作。 它具有 get 和 set 方法,其工作方式类似于对易失性变量进行读取和写入。 也就是说,集合与同一变量上的任何后续获取具有先发生关系。 原子compareAndSet方法也具有这些内存一致性特性。

AtomicLong 方法

以下是 AtomicLong 类中可用的重要方法的列表。

Sr.No. 方法及描述
1

public long addAndGet(long delta)

以原子方式将给定值添加到当前值。

2

public boolean compareAndSet(long expect, long update)

如果当前值与预期值相同,则自动将该值设置为给定的更新值。

3

public long decrementAndGet()

以原子方式将当前值减一。

4

public double doubleValue()

以双精度形式返回指定数字的值。

5

public float floatValue()

以浮点数形式返回指定数字的值。

6

public long get()

获取当前值。

7

public long getAndAdd(long delta)

原子地将给定值添加到当前值。

8

public long getAndDecrement()

以原子方式将当前值减一。

9

public long getAndIncrement()

以原子方式将当前值加一。

10

public long getAndSet(long newValue)

自动设置为给定值并返回旧值。

11

public long incrementAndGet()

以原子方式将当前值加一。

12

public int intValue()

以 int 形式返回指定数字的值。

13

public void lazySet(long newValue)

最终设置为给定值。

14

public long longValue()

以长整型形式返回指定数字的值。

15

public void set(long newValue)

设置为给定值。

16

public String toString()

返回当前值的字符串表示形式。

17

public boolean weakCompareAndSet(long expect, long update)

如果当前值与预期值相同,则自动将该值设置为给定的更新值。

示例

以下 TestThread 程序显示了在基于线程的环境中使用 AtomicLong 的计数器的安全实现。

import java.util.concurrent.atomic.AtomicLong;

public class TestThread {

   static class Counter {
      private AtomicLong c = new AtomicLong(0);

      public void increment() {
         c.getAndIncrement();
      }

      public long value() {
         return c.get();
      }
   }

   public static void main(final String[] arguments) throws InterruptedException {
      final Counter counter = new Counter();
      
      //1000 threads
      for(int i = 0; i < 1000 ; i++) {
         
         new Thread(new Runnable() {
            
            public void run() {
               counter.increment();
            }
         }).start();	
      }
      Thread.sleep(6000);			   		  
      System.out.println("Final number (should be 1000): " + counter.value());
   }
}

这将产生以下结果。

输出

Final number (should be 1000): 1000