深入了解Java atomic原子类的使用方法和原理
在讲atomic原子类之前先看一个小例子:
publicclassUseAtomic{
publicstaticvoidmain(String[]args){
AtomicIntegeratomicInteger=newAtomicInteger();
for(inti=0;i<10;i++){
Threadt=newThread(newAtomicTest(atomicInteger));
t.start();
try{
t.join(0);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
System.out.println(atomicInteger.get());
}
}
classAtomicTestimplementsRunnable{
AtomicIntegeratomicInteger;
publicAtomicTest(AtomicIntegeratomicInteger){
this.atomicInteger=atomicInteger;
}
@Override
publicvoidrun(){
atomicInteger.addAndGet(1);
atomicInteger.addAndGet(2);
atomicInteger.addAndGet(3);
atomicInteger.addAndGet(4);
}
}
最终的输出结果为100，可见这个程序是线程安全的。如果把AtomicInteger换成变量i的话，那最终结果就不确定了。
打开AtomicInteger的源码可以看到:
//setuptouseUnsafe.compareAndSwapIntforupdates privatestaticfinalUnsafeunsafe=Unsafe.getUnsafe(); privatevolatileintvalue;
volatile关键字用来保证内存的可见性（但不能保证线程安全性），线程读的时候直接去主内存读，写操作完成的时候立即把数据刷新到主内存当中。
CAS简要
/**
*Atomicallysetsthevaluetothegivenupdatedvalue
*ifthecurrentvalue{@code==}theexpectedvalue.
*
*@paramexpecttheexpectedvalue
*@paramupdatethenewvalue
*@return{@codetrue}ifsuccessful.Falsereturnindicatesthat
*theactualvaluewasnotequaltotheexpectedvalue.
*/
publicfinalbooleancompareAndSet(intexpect,intupdate){
returnunsafe.compareAndSwapInt(this,valueOffset,expect,update);
}
从注释就可以看出:当线程写数据的时候，先对内存中要操作的数据保留一份旧值，真正写的时候，比较当前的值是否和旧值相同，如果相同，则进行写操作。如果不同，说明在此期间值已经被修改过，则重新尝试。
compareAndSet使用Unsafe调用native本地方法CAS（CompareAndSet）递增数值。
CAS利用CPU调用底层指令实现。
两种方式:总线加锁或者缓存加锁保证原子性。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。