Java 并发 - AtomicInteger 类
java.util.concurrent.atomic.AtomicInteger 类提供了对底层 int 值的操作，这些操作可以原子地读写，并且还包含高级原子操作。 AtomicInteger 支持对底层 int 变量进行原子操作。 它具有 get 和 set 方法，其工作方式类似于对易失性变量进行读取和写入。 也就是说，集合与同一变量上的任何后续获取具有先发生关系。 原子compareAndSet方法也具有这些内存一致性特性。
原子整数方法
以下是 AtomicInteger 类中可用的重要方法的列表。
| Sr.No. | 方法及描述 |
|---|---|
| 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() 以原子方式将当前值减一。 |
| 9 | public int getAndIncrement() 以原子方式将当前值加一。 |
| 10 | public int getAndSet(int newValue) 自动设置为给定值并返回旧值。 |
| 11 | public int incrementAndGet() 以原子方式将当前值加一。 |
| 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() 返回当前值的字符串表示形式。 |
| 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
