目录
一、CAS的简单介绍
CAS逻辑(用伪代码来描述)
二、CAS在多线程中简单的使用
三、原子类自增的代码分析
都看到这了,点个赞再走吧,谢谢谢谢谢
一、CAS的简单介绍
CAS的全称:“Compare And Swap”,字面意思是 “比较和交换”;一个CAS涉及到以下操作,有两个寄存器:A,SwapB,还有内存的值:AddressC。
先判断寄存器A是否和AddressC的值相同,相同,SwapB的值和AddressC的值进行交换,返回成功操作,否则返回失败操作。这里的交换值我们也可以理解成赋值操作,因为寄存器中的值我们不关心,用完就丢掉了,只关心内存中的值。
CAS逻辑(用伪代码来描述)
伪代码:
这里有两个寄存器:expectValue,swapValue,还有内存的值:address,初始化如图:
进入if语句,判断内存的值和寄存器e的值是否相等,如果相等,就交换寄存器swap和内存address的值,如图:
如图:
然后返回true,如果if条件不成立则返回false。
在计算机中,上述操作在计算机只是一条指令,因为单个指令的原因,所以CAS指令是原子的。
CAS指令不涉及到加锁,阻塞。基于CAS指令,合理使用的话,在多线程中,我们可以实现无锁编程;因为之前我们讨论并发编程的线程安全问题时,是通过加锁,阻塞这样方式解决线程安全问题,因为会有阻塞,所以性能也就会降低,用CAS指令实现无锁编程,也能保证线程安全,不涉及到阻塞,这样性能就能得到很大的提升,在多线程编程中打开了新世界的大门。
二、CAS在多线程中简单的使用
因为CAS是CPU的指令,有的cpu可能不支持CAS,但主流的CPU(x86,arm...)都是支持的。
CAS本身是CPU的指令,操作系统对其做了封装,jvm又对操作系统提供的api又做了一层封装。java中CAS的api是放在unsafe中的,这个包名的意思,顾名思义也是“不安全”的意思,一般在java中不建议使用,java的标准库中,对于CAS进行了进一步的封装,把CAS的一些操作封装成工具类,供程序猿使用。而主要的一个工具,叫做 “原子类”。
在 java.util.concurrent.atomic 包下,里面的类就是基于上述方式实现的,典型的类就是AtomicInteger类,里面有很多方法可以实现数值的自增、自减,以及基本的加减操作。下面的代码案例也是使用AtomicInteger展示。
我们以前写过一个代码,让两个线程实现一个变量自增10_0000次,如下代码是线程不安全。
public class AtomicIntegerTest1 {
public static int count = 0;
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count++;
}
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count++;
}
});
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(count);
}
}
执行结果:
输出结果也和我们预期结果不同,肯定是线程不安全的,而原因就是因为count++操作不是原子的,在计算机中有三个指令。
这里,我们使用CAS的方式,来实现让两个线程实现一个变量自增10_0000次,代码如下
public class AtomicIntegerTest1 {
public static AtomicInteger count = new AtomicInteger(0);
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count.getAndIncrement();//和count++意思一样
}
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count.getAndIncrement();//和count++意思一样
}
});
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(count);
}
}
执行结果:
因为这里用CAS的方式,原本count++操作在计算机中有3条指令,不是原子的,肯定线程不安全;但是用CAS的方式就可以把像count++这样的操作,用一条指令完成,是原子的,在这里就不涉及到线程安全问题了。
AtomicInteger中有很多方法:自增,自减,+=,-=等待,这里就不展开讨论了。
三、原子类自增的代码分析
代码还是上述的代码,如下:
public class AtomicIntegerTest1 {
public static AtomicInteger count = new AtomicInteger(0);
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count.getAndIncrement();//和count++意思一样
}
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 50000; i++) {
count.getAndIncrement();//和count++意思一样
}
});
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(count);
}
}
在标准库中,getAndIncrement方法是这样的:
这里比较难理解,我们用伪代码的形式介绍,伪代码如下:
当有两个线程对同一个变量进行自增操作时,执行流程是这样的:
这里的oldValue是寄存器中的值,它的值就是AtomicInteger括号里面初始化的值,value是内存中的值。从上到下,把内存value的值都赋值给oldValue,两个线程拿到的都是同一个内存value的值。
这时,右边的线程while循环里的判断,先执行CAS这里的操作,如图:
执行完CAS操作后返回true,然后while循环里true != ture,条件不成立,不执行while循环内的代码。
当左边线程进入while循环里面的判断语句时,如图:
也会进入CAS操作,这里因为内存value的值修改了,当前线程寄存器oldValue值还是0,给oldValue+1,会返回false,这时循环条件false != true成立,就会执行oldValue = value操作,如图:
再次进入循环条件里面执行CAS操作,这时候value == oldValue,所以会让oldvalue+1赋值给value,这时候value的值就是2了,如图:
所以,两个线程不管顺序是啥样的,使用getAndIncrement方法都不会出现线程安全问题,因为CAS操作本身就是原子的,原因的逻辑理解也大概是下面这样的:
如果cas不成功,会重复上面的操作,再次读取数据,这次读取到的数据就是正确的了,cas也就能成功。意思就是这个方法里面会判断拿到的值是不是最新值,如果不是就去拿最新的值,再去CAS,这时候因为拿到的是最新值,所以这时能CAS成功。