Java并发——AtomicInteger类

java.util.concurrent.atomic.AtomicInteger 类提供对底层 int 值的原子操作，这些操作可以原子地读取和写入，并且还包含高级原子操作。AtomicInteger 支持对底层 int 变量的原子操作。它具有 get 和 set 方法，其作用类似于对 volatile 变量的读取和写入。也就是说，set 操作与随后对同一变量的任何 get 操作之间存在 happens-before 关系。atomic compareAndSet 方法也具有这些内存一致性特性。

AtomicInteger 方法

以下是 AtomicInteger 类中一些重要方法的列表。

序号	方法及描述
1	public int addAndGet(int delta) 原子地将给定值添加到当前值。
2	public boolean compareAndSet(int expect, int update) 如果当前值与预期值相同，则原子地将值设置为给定的更新值。
3	public int decrementAndGet() 原子地将当前值减 1。
4	public double doubleValue() 将指定数字的值作为双精度浮点数返回。
5	public float floatValue() 将指定数字的值作为单精度浮点数返回。
6	public int get() 获取当前值。
7	public int getAndAdd(int delta) 原子地将给定值添加到当前值。
8	public int getAndDecrement() 原子地将当前值减 1。
9	public int getAndIncrement() 原子地将当前值加 1。
10	public int getAndSet(int newValue) 原子地设置为给定值并返回旧值。
11	public int incrementAndGet() 原子地将当前值加 1。
12	public int intValue() 将指定数字的值作为整数返回。
13	public void lazySet(int newValue) 最终设置为给定值。
14	public long longValue() 将指定数字的值作为长整数返回。
15	public void set(int newValue) 设置为给定值。
16	public String toString() 返回当前值的字符串表示形式。
17	public boolean weakCompareAndSet(int expect, int update) 如果当前值与预期值相同，则原子地将值设置为给定的更新值。

示例

下面的 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

打印页面