Java 并发 - AtomicInteger 类

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

Atomics整数方法

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

先生。	方法及说明
1	公共 int addAndGet(int delta) 以Atomics方式将给定值添加到当前值。
2	公共布尔比较AndSet（int期望，int更新）如果当前值与预期值相同，则自动将该值设置为给定的更新值。
3	公共 int decrementAndGet() 以Atomics方式将当前值减一。
4	公共双倍双值（）以双精度形式返回指定数字的值。
5	公共浮点数 floatValue() 以浮点数形式返回指定数字的值。
6	公共 int get() 获取当前值。
7	公共 int getAndAdd(int delta) 以Atomics方式将给定值添加到当前值。
8	公共 int getAndDecrement() 以Atomics方式将当前值减一。
9	公共 int getAndIncrement() 以Atomics方式将当前值加一。
10	公共 int getAndSet(int newValue) Atomics地设置为给定值并返回旧值。
11	公共 int 增量AndGet() 以Atomics方式将当前值加一。
12	公共 int intValue() 以 int 形式返回指定数字的值。
13	公共无效lazySet（int newValue）最终设置为给定值。
14	公共长长值（）以 long 形式返回指定数字的值。
15	公共无效集（int newValue）设置为给定值。
16	公共字符串 toString() 返回当前值的字符串表示形式。
17 号	公共布尔weakCompareAndSet（int期望，int更新）如果当前值与预期值相同，则自动将该值设置为给定的更新值。

例子

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

现场演示

public class TestThread {

   static class Counter {
      private int c = 0;

      public void increment() {
         c++;
      }

      public int value() {
         return c;
      }
   }
   
   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

例子

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

现场演示

import java.util.concurrent.atomic.AtomicInteger;

public class TestThread {

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

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

      public int 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