一,什么是cas
cas的全称为compare-and-swap,它是一条cpu并发原语.
它的功能是判断内存某个位置是否为预期值,如果是则更改为新的值,这个过程是原子的(原子性).
cas并发原语体现在java语言中就是sun.misc.unsafe类中的各个方法,调用unsafe类中的cas方法,jvm会帮我们实现出cas汇编指令.这是一种完全依赖于硬件的功能,通过他实现原子操作.再次强调,由于cas是一种系统原语,原语属于操作系统用语范畴,是由若干条指令组成的,用于完成某个功能的一个过程,并且原语的执行是连续的,在执行过程中不允许被中断,也就是说cas是一条cpu的原子指令,不会造成所谓的数据不一致问题;
cas简单机制是:比较当前工作内存中的值和主内存中的值是否相同,如果相同就执行规定任务,否则继续比较直到主内存 和工作内存中的值一致为止,一致直自旋(自旋锁)
cas有 三个操作数 内存值v(工作内存中的值),旧的预期值a(主存中的值),要修改的新值b.当且内存值v与旧的预期值相等时,将内存值修改为b,否则一直循环去比较v和a的值,直到相等
//atomicinteger类的getandincrement方法
/**
* atomically increments by one the current value.
*
* @return the previous value
*/
public final int getandincrement() {
return unsafe.getandaddint(this, valueoffset, 1);
}
//unsafe类的getandaddint方法
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 atomicinteger对象本身
var2 该对象值的引用地址
var4 需要变动的数值
var5 是用var1 var2找出的内存中真实的值. 用该对象当前的值与var5比较:
如果相同,跟新var5 var4 并且返回true
如果不同,继续取值然后在比较,直到跟新完成.
二,什么是unsafe类
// atomicinteger 类的源码
public class atomicinteger extends number implements java.io.serializable {
private static final long serialversionuid = 6214790243416807050l;
// 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;
1:是cas的核心类,由于java方法无法直接访问底层系统,需要通过native方法来访问,unsafe相当于一个后门,基于该类可以直接操作特定内存数据,unsafe类存在于sun.mic包中,其内部方法可以直接操作内存,因为java中cas操作的执行都是依赖于unsafe类中的方法
注意:unsafe类中的所有方法都是native修饰的,也就是说unsafe类中的方法都可以直接调用操作系统底层资源执行相应的任务
2:变量valueoffset ,表示该变量值在内存中的偏移地址,因为unsafe就是根据内存偏移地址获取数据的
/**
* atomically increments by one the current value.
*
* @return the previous value
*/
public final int getandincrement() {
return unsafe.getandaddint(this, valueoffset, 1);
}
3:变量value用volatile修饰,保证多线程之间的可见性
private volatile int value;
三,cas缺点
1.循环时间长开销很大,有一个do{}while()循序,成功一直循环消耗时间
2.只能保证一个共享变量的原子操作
3.aba问题
四:原子类atomicinteger的aba问题？原子更新引用知道吗？
1.什么是aba问题?
cas算法实现一个重要前提需要提取出内存中某时刻的数据并在当下时刻比较替换,那么在这个时间差内会导致数据的变化.
比如有一个线程one从内存位置v中取出a,这时候另一个线程two也从内存中取出a,并且线程two进行了一些数据操作将值变成了b,然后线程two又将v位置的数据变成了a,在线程b操作过程中线程one可能被某种原因挂起了,这之后线程one操作发现内存中比较值仍然是a,然后线程one也操作成功了—>这就是aba问题(狸猫换太子)
尽管线程one的cas操作成功,但不代表这个过程是不安全的
2.原子引用
atomicreference是作用是对”对象”进行原子操作。
提供了一种读和写都是原子性的对象引用变量。原子意味着多个线程试图改变同一个atomicreference(例如比较和交换操作)将不会使得atomicreference处于不一致的状态。
atomicreference和atomicinteger非常类似，不同之处就在于atomicinteger是对整数的封装，底层采用的是compareandswapint实现cas，比较的是数值是否相等，而atomicreference则对应普通的对象引用，底层使用的是compareandswapobject实现cas，比较的是两个对象的地址是否相等。也就是它可以保证你在修改对象引用时的线程安全性。
class user{
string name;
int age;
public user(string name, int age) {
this.name = name;
this.age = age;
}
public string getname() {
return name;
}
public void setname(string name) {
this.name = name;
}
public int getage() {
return age;
}
public void setage(int age) {
this.age = age;
}
@override
public string tostring() {
return "user{"
"name='" name '\''
", age=" age
'}';
}
}
public class atomicreferencedemo {
public static void main(string[] args) {
user z3 = new user("z3", 22);
user l4 = new user("l4", 25);
//把自定义类封装成原子引用
atomicreference atomicreference = new atomicreference<>();
atomicreference.set(z3);
system.out.println(atomicreference.compareandset(z3, l4) "\t" atomicreference.tostring());
system.out.println(atomicreference.compareandset(z3, l4) "\t" atomicreference.tostring());
}
}
true user{
name='l4', age=25}
false user{
name='l4', age=25}
3.怎么解决aba问题
使用atomicstampreference,atomicstampreference在cas的基础上增加了一个标记stamp(版本号,类似于时间戳)，使用这个标记可以用来觉察数据是否发生变化，给数据带上了一种实效性的检验。它有以下几个参数
//参数代表的含义分别是 期望值，写入的新值，期望标记，新标记值
public boolean compareandset(v expected,v newreference,int expectedstamp,int newstamp);
public v getrerference();
public int getstamp();
public void set(v newreference,int newstamp);
/**
* aba问题的解决 atomicstampedreference
*/
public class abademo {
static atomicreference atomicreference = new atomicreference<>(100);
static atomicstampedreference atomicstampedreference = new atomicstampedreference<>(100, 1);
public static void main(string[] args) {
system.out.println("-----------------aba问题的产生--------------------");
new thread("t1"){
@override
public void run() {
atomicreference.compareandset(100, 101);
atomicreference.compareandset(101, 100);
}
}.start();
new thread("t2"){
@override
public void run() {
try {
//线程t2休眠1秒钟,确保t1完成一次aba操作
sleep(1000);
} catch (interruptedexception e) {
e.printstacktrace();
}
system.out.println(atomicreference.compareandset(100, 2020) "\t" atomicreference.get());
}
}.start();
try {
thread.sleep(2000);
} catch (interruptedexception e) {
e.printstacktrace();
}
system.out.println("-----------------aba问题的解决--------------------");
new thread("t3"){
@override
public void run() {
int stamp = atomicstampedreference.getstamp();
system.out.println(getname() "\t第一次版本号：" stamp);
try {
//t3线程休眠1秒中,确保t4也拿到初始的版本号
sleep(1000);
} catch (interruptedexception e) {
e.printstacktrace();
}
atomicstampedreference.compareandset(100, 101, atomicstampedreference.getstamp(), atomicstampedreference.getstamp() 1);
system.out.println(getname() "\t第二次版本号：" atomicstampedreference.getstamp());
atomicstampedreference.compareandset(101, 100, atomicstampedreference.getstamp(), atomicstampedreference.getstamp() 1);
system.out.println(getname() "\t第三次版本号：" atomicstampedreference.getstamp());
}
}.start();
new thread("t4"){
@override
public void run() {
int stamp = atomicstampedreference.getstamp();
system.out.println(getname() "\t第一次版本号：" stamp);
try {
//t4线程休眠3秒中,确保t3完成一次aba操作
sleep(3000);
} catch (interruptedexception e) {
e.printstacktrace();
}
boolean result = atomicstampedreference.compareandset(100, 2020, stamp, stamp 1);
system.out.println(getname() "\t是否修改成功," result "\t当前最新实际版本号：" atomicstampedreference.getstamp());
system.out.println(getname() "\t当前实际最新值：" atomicstampedreference.getreference());
}
}.start();
}
}
-----------------aba问题的产生--------------------
true 2020
-----------------aba问题的解决--------------------
t3 第一次版本号：1
t4 第一次版本号：1
t3 第二次版本号：2
t3 第三次版本号：3
t4 是否修改成功,false 当前最新实际版本号：3
t4 当前实际最新值：100