一个可以原子更新的int值。有关原子变量属性的描述,请参阅java.util.concurrent.atomic包规范。AtomicInteger用于原子递增计数器等应用程序,不能用作Integer的替代品。但是,这个类确实扩展了Number,以允许处理基于数字的类的工具和实用程序进行统一访问。
2. 设置使用CAS进行更新setUp to use Unsafe.compareAndAwapInt for update
3. 计算偏移量检查用户权限获取声明为公有的字段,然后根据有权限的字段,获取系统的偏移量value得到一个long类型的偏移量的值
static {
try {
valueOffset = unsafe.objectFieldOffset
(AtomicInteger.class.getDeclaredField("value"));
} catch (Exception ex) { throw new Error(ex); }
}
4. 懒赋值
public final void lazySet(int newValue) {
unsafe.putOrderedInt(this, valueOffset, newValue);
}
5. getAndSet 先获取然后再进行赋值操作(涉及CAS)
public final int getAndSetInt(Object var1, long var2, int var4) {
int var5;
do {
var5 = this.getIntVolatile(var1, var2);
} while(!this.compareAndSwapInt(var1, var2, var5, var4));
return var5;
}
第一步:传入一个要替换的值var5;然后计算根据var1和war2通过getIntVolatile计算得到var5
第二步:如果compareAndSwapInt比较结果和var5相等,返回var5
public final boolean compareAndSet(int expect, int update) {
return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}
如果实际要更新的值和预期要更新的值不想等则返回false,如果实际要更新的值和期待值相等返回true
7. 获取并更新值第一步:
public final int addAndGet(int delta) {
return unsafe.getAndAddInt(this, valueOffset, delta) + delta;
}
第二步:
public final int getAndAddInt(Object var1, long var2, int var4) {
int var5;
do {
var5 = this.getIntVolatile(var1, var2);
} while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
return var5;
}
如果原来值var1和偏移量var2得到的计算和结果var5相等,给var5加上相应的增量delta即var4
8.getAndUpdatepublic final int getAndUpdate(IntUnaryOperator updateFunction) {
int prev, next;
do {
prev = get();
next = updateFunction.applyAsInt(prev);
} while (!compareAndSet(prev, next));
return prev;
}
用应用给定函数的结果原子地更新当前值,返回跟新前的值。该函数应该没有副作用,因为当线程争用导致尝试更新失败时,会重新尝试更新。
9.updateAndGet public final int updateAndGet(IntUnaryOperator updateFunction) {
int prev, next;
do {
prev = get();
next = updateFunction.applyAsInt(prev);
} while (!compareAndSet(prev, next));
return next;
}
用应用给定函数的结果原子地更新当前值,返回跟新后的值。该函数应该没有副作用,因为当线程争用导致尝试更新失败时,会重新尝试更新。
10.getAndAccumulatepublic final int getAndAccumulate(int x, IntBinaryOperator accumulatorFunction) {
int prev, next;
do {
prev = get();
next = accumulatorFunction.applyAsInt(prev, x);
} while (!compareAndSet(prev, next));
return prev;
}
用将给定函数应用于当前值和给定值的结果原子地更新当前值,返回更新前的值。该函数应该没有副作用,因为当线程争用导致尝试更新失败时,可能会重新应用该函数。函数的第一个参数是当前值,第二个参数是给定的更新。
11. accumulateAndGetpublic final int accumulateAndGet(int x, IntBinaryOperator accumulatorFunction) {
int prev, next;
do {
prev = get();
next = accumulatorFunction.applyAsInt(prev, x);
} while (!compareAndSet(prev, next));
return next;
}
用将给定函数应用于当前值和给定值的结果原子地更新当前值,返回跟新后的值。该函数应该没有副作用,因为当线程争用导致尝试更新失败时,可能会重新应用该函数。函数的第一个参数是当前值,第二个参数是给定的更新。



