Java Concurrency 简明教程

Java Concurrency - AtomicInteger Class

java.util.concurrent.atomic.AtomicInteger 类提供对底层 int 值的操作，该值可以原子地读写，还包含高级原子操作。AtomicInteger 支持对底层 int 变量的原子操作。它有 get 和 set 方法，就像对 volatile 变量进行读写一样。也就是说，set 与同一变量上的任何后续 get 都有 happens-before 关系。atomic compareAndSet 方法也有这些内存一致性特性。

AtomicInteger Methods

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

Sr.No.	Method & Description
1	public int addAndGet(int delta) 以原子方式将给定值添加到当前值。
2	public boolean compareAndSet(int expect, int update) 如果当前值与预期值相同，则以原子方式将值设置为给定的更新值。
3	public int decrementAndGet() 以原子方式将当前值减一。
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() 将指定数字的值作为 int 返回。
13	public void lazySet(int newValue) 最终设置为给定值。
14	public long longValue() 将指定数字的值作为长整型返回。
15	public void set(int newValue) 设置为给定值。
16	public String toString() 返回当前值的 String 表示形式。
17	public boolean weakCompareAndSet(int expect, int update) 如果当前值与预期值相同，则以原子方式将该值设置为给定更新值。

Example

以下 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());
   }
}

这可能会根据计算机速度和线程交错产生以下结果。

Output

Final number (should be 1000): 1000

Example

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());
   }
}

这将产生以下结果。

Output

Final number (should be 1000): 1000