1. 介绍一下 Atomic 原子类
Atomic
翻译成中文是原子的意思。在化学上,我们知道原子是构成一般物质的最小单位,在化学反应中是不可分割的。在我们这里Atomic
是指一个不可中断的操作。即使是在多个线程一起执行的时候,一个操作一旦开始,也不会被其他线程干扰。
所以,所谓原子类说简单点就是具有原子/原子操作特征的类。
并发包java.util.concurrent
的原子类都存放在java.util.concurrent.atomic下
,如下图所示。
2. JUC 包中的原子类是哪 4 类?
基本类型
使⽤原⼦的⽅式更新基本类型
AtomicInteger
:整形原⼦类AtomicLong
:⻓整型原⼦类AtomicBoolean
:布尔型原⼦类
数组类型
使⽤原⼦的⽅式更新数组⾥的某个元素
AtomicIntegerArray
:整形数组原⼦类AtomicLongArray
:⻓整形数组原⼦类AtomicReferenceArray
:引⽤类型数组原⼦类
引⽤类型AtomicReference
:引⽤类型原⼦类AtomicStampedReference
:原⼦更新带有版本号的引⽤类型。该类将整数值与引⽤关联起来,可⽤于解决原⼦的更新数据和数据的版本号,可以解决使⽤ CAS 进⾏原⼦更新时可能出现的 ABA 问题。AtomicMarkableReference
:原⼦更新带有标记位的引⽤类型
对象的属性修改类型AtomicIntegerFieldUpdater
:原⼦更新整形字段的更新器AtomicLongFieldUpdater
:原⼦更新⻓整形字段的更新器AtomicReferenceFieldUpdater
:原⼦更新引⽤类型字段的更新器
3. 讲讲 AtomicInteger 的使用
AtomicInteger 类常用方法
public final int get() //获取当前的值
public final int getAndSet(int newValue)//获取当前的值,并设置新的值
public final int getAndIncrement()//获取当前的值,并自增
public final int getAndDecrement() //获取当前的值,并自减
public final int getAndAdd(int delta) //获取当前的值,并加上预期的值
boolean compareAndSet(int expect, int update) //如果输入的数值等于预期值,则以原子方式将该值设置为输入值(update)
public final void lazySet(int newValue)//最终设置为newValue,使用 lazySet 设置之后可能导致其他线程在之后的一小段时间内还是可以读到旧的值。
AtomicInteger 类的使用示例
使用 AtomicInteger 之后,不用对 increment() 方法加锁也可以保证线程安全。
class AtomicIntegerTest {
private AtomicInteger count = new AtomicInteger();
//使用AtomicInteger之后,不需要对该方法加锁,也可以实现线程安全。
public void increment() {
count.incrementAndGet();
}
public int getCount() {
return count.get();
}
}
4. 能不能给我简单介绍一下 AtomicInteger 类的原理
AtomicInteger 线程安全原理简单分析
AtomicInteger 类的部分源码:
// setup to use Unsafe.compareAndSwapInt for updates(更新操作时提供“比较并替换”的作用)
private static final Unsafe unsafe = Unsafe.getUnsafe();
private static final long valueOffset;
static {
try {
valueOffset = unsafe.objectFieldOffset
(AtomicInteger.class.getDeclaredField("value"));
} catch (Exception ex) { throw new Error(ex); }
}
private volatile int value;
AtomicInteger
类主要利用CAS (compare and swap)
+volatile
和native
方法来保证原子操作,从而避免synchronized
的高开销,执行效率大为提升。
CAS 的原理是拿期望的值和原本的一个值作比较,如果相同则更新成新的值。UnSafe
类的objectFieldOffset()
方法是一个本地方法,这个方法是用来拿到“原来的值”的内存地址,返回值是valueOffset
。另外value
是一个volatile
变量,在内存中可见,因此 JVM 可以保证任何时刻任何线程总能拿到该变量的最新值。
留言