CAS指令和具体源代码
原子类例如AtomicInteger里的方法都很简单,大家看一看都能懂,我们具体看下getAndIncrement方法。下面贴出代码:
//该方法功能是Interger类型加1
public final int getAndIncrement() {
//主要看这个getAndAddInt方法
return unsafe.getAndAddInt(this, valueOffset, 1);
}
//var1 是this指针
//var2 是地址偏移量
//var4 是自增的数值,是自增1还是自增N
public final int getAndAddInt(Object var1, long var2, int var4) {
int var5;
do {
//获取内存值,这是内存值已经是旧的,假设我们称作期望值E
var5 = this.getIntVolatile(var1, var2);
//compareAndSwapInt方法是重点,
//var5是期望值,var5 + var4是要更新的值
//这个操作就是调用CAS的JNI,每个线程将自己内存里的内存值M
//与var5期望值E作比较,如果相同将内存值M更新为var5 + var4,否则做自旋操作
} while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
return var5;
}
解释一下getAndAddInt方法的流程
假设有以下情景:
1.A、B两个线程
2.jvm主内存的值1,A、B工作内存的值为1(工作内存会拷贝一份主内存的值)
3.当前期望值为1,做加1操作
4.此时var5 = 1, var4 = 1,
(1)A线程将var5与工作内存值M比较,比较var5是否等于1
(2)如果相同则将工作内存值修改为var5+var4 既修改为2并同步到主内存,此时this指针里,示例变量value的值就是2,结束循环
(3)如果不相同
则其B线程修改了主内存的值
,说明B线程已经先于A线程做了加1操作,A线程没有更新成功需要继续循环,注意此时var5更新为新的内存值
,假设当前的内存值是2,那么此时var5 = 2, var5 + var4 = 3,重复上述步骤直到成功
网友评论