Java并發(fā)之CAS原理詳解
開端
在學(xué)習(xí)源碼之前我們先從一個(gè)需求開始
需求
我們開發(fā)一個(gè)網(wǎng)站，需要對(duì)訪問(wèn)量進(jìn)行統(tǒng)計(jì)，用戶每發(fā)送一次請(qǐng)求，訪問(wèn)量+1.如何實(shí)現(xiàn)？我們模擬有100個(gè)人同時(shí)訪問(wèn)，并且每個(gè)人對(duì)咱們的網(wǎng)站發(fā)起10次請(qǐng)求，最后總訪問(wèn)次數(shù)應(yīng)該是1000次
1.代碼
package day03;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
* Description
* User:
* Date:
* Time:
*/
public class Demo {
//總訪問(wèn)量
static int count = 0;
//模擬訪問(wèn)的方法
public static void request() throws InterruptedException {
//模擬耗時(shí)5毫秒
TimeUnit.MILLISECONDS.sleep(5);
count++;
}
public static void main(String[] args) throws InterruptedException {
long startTime = System.currentTimeMillis();
int threadSize=100;
CountDownLatch countDownLatch = new CountDownLatch(threadSize);
for (int i=0;i<threadSize;i++){
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//每個(gè)用戶訪問(wèn)10次網(wǎng)站
try {
for (int j=0;j<10;j++) {
request();
}
}catch (InterruptedException e) {
e.printStackTrace();
}finally {
countDownLatch.countDown();
}
}
});
thread.start();
}
//怎么保證100個(gè)線程執(zhí)行之后，執(zhí)行后面的代碼
countDownLatch.await();
long endTime = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName()+"耗時(shí):"+(endTime-startTime)+",count:"+count);
}
}
我們多輸出幾次結(jié)果
main耗時(shí):66,count:950
main耗時(shí):67,count:928
發(fā)現(xiàn)每一次count都不相同，和我們期待的1000相差一點(diǎn)，這里就牽扯到了并發(fā)問(wèn)題，我們的count++在底層實(shí)際上由3步操作組成
- 獲取count，各個(gè)線程寫入自己的工作內(nèi)存
- count執(zhí)行+1操作
- 將+1后的值寫回主存中
這并不是一個(gè)線程安全的過(guò)程，如果有A、B兩個(gè)線程同時(shí)執(zhí)行count++，同時(shí)執(zhí)行到第一步，得到的count是一樣的，三步操作完成后，count只加1，導(dǎo)致count結(jié)果不正確
那么怎么解決這個(gè)問(wèn)題呢？
我們可以考慮使用synchronized關(guān)鍵字和ReentrantLock對(duì)資源加鎖，保證并發(fā)的正確性，多線程的情況下，可以保證被鎖住的資源被串行訪問(wèn)
1.1修改后的代碼
package day03;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
* Description
* User:
* Date:
* Time:
*/
public class Demo02 {
//總訪問(wèn)量
static int count = 0;
//模擬訪問(wèn)的方法
public static synchronized void request() throws InterruptedException {
//模擬耗時(shí)5毫秒
TimeUnit.MILLISECONDS.sleep(5);
count++;
}
public static void main(String[] args) throws InterruptedException {
long startTime = System.currentTimeMillis();
int threadSize=100;
CountDownLatch countDownLatch = new CountDownLatch(threadSize);
for (int i=0;i<threadSize;i++){
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//每個(gè)用戶訪問(wèn)10次網(wǎng)站
try {
for (int j=0;j<10;j++) {
request();
}
}catch (InterruptedException e) {
e.printStackTrace();
}finally {
countDownLatch.countDown();
}
}
});
thread.start();
}
//怎么保證100個(gè)線程執(zhí)行之后，執(zhí)行后面的代碼
countDownLatch.await();
long endTime = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName()+"耗時(shí):"+(endTime-startTime)+",count:"+count);
}
}
執(zhí)行結(jié)果
main耗時(shí):5630,count:1000
可以看到，由于sychronized鎖住了整個(gè)方法，雖然結(jié)果正確，但因?yàn)榫€程執(zhí)行方法均為串行執(zhí)行，導(dǎo)致運(yùn)行效率大大下降
那么我們?nèi)绾尾拍苁钩绦驁?zhí)行無(wú)誤時(shí)，效率還不會(huì)降低呢？
縮小鎖的范圍，升級(jí)上述3步中第三步的實(shí)現(xiàn)
- 獲取鎖
- 獲取count最新的值，記作LV
- 判斷LV是否等于A，如果相等，則將B的值賦值給count，并返回true，否則返回false
- 釋放鎖
1.2代碼改進(jìn)：CAS模仿
package day03;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
* Description
* User:
* Date:
* Time:
*/
public class Demo03 {
//總訪問(wèn)量
volatile static int count = 0;
//模擬訪問(wèn)的方法
public static void request() throws InterruptedException {
//模擬耗時(shí)5毫秒
TimeUnit.MILLISECONDS.sleep(5);
// count++;
int expectCount;
while (!compareAndSwap(expectCount=getCount(),expectCount+1)){}
}
/**
* @param expectCount 期待的值,比如最剛開始count=3
* @param newCount 新值 count+1之后的值，4
* @return
*/
public static synchronized boolean compareAndSwap(int expectCount,int newCount){
if (getCount()==expectCount){
count = newCount;
return true;
}
return false;
}
public static int getCount(){return count;}
public static void main(String[] args) throws InterruptedException {
long startTime = System.currentTimeMillis();
int threadSize=100;
CountDownLatch countDownLatch = new CountDownLatch(threadSize);
for (int i=0;i<threadSize;i++){
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//每個(gè)用戶訪問(wèn)10次網(wǎng)站
try {
for (int j=0;j<10;j++) {
request();
}
}catch (InterruptedException e) {
e.printStackTrace();
}finally {
countDownLatch.countDown();
}
}
});
thread.start();
}
//怎么保證100個(gè)線程執(zhí)行之后，執(zhí)行后面的代碼
countDownLatch.await();
long endTime = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName()+"耗時(shí):"+(endTime-startTime)+",count:"+count);
}
}
main耗時(shí):67,count:1000
2.CAS分析
CAS全稱“CompareAndSwap”，中文翻譯過(guò)來(lái)為“比較并替換”
定義：
- CAS操作包含三個(gè)操作數(shù)——
內(nèi)存位置（V）、期望值（A）和新值（B）。如果內(nèi)存位置的值和期望值匹配，那么處理器會(huì)自動(dòng)將該位置值更新為新值。否則處理器不作任何操作。無(wú)論哪種情況，它都會(huì)在CAS指令之前返回該位置的值。 - CAS在一些特殊情況下僅返回CAS是否成功，而不提取當(dāng)前值，CAS有效的說(shuō)明了我認(rèn)為位置V應(yīng)該包含值A(chǔ)，如果包含該值，將B放到這個(gè)位置，否則不要更改該位置的值，只告訴我這個(gè)位置現(xiàn)在的值即可
2.1Java對(duì)CAS的支持
java中提供了對(duì)CAS操作的支持，具體在sun.misc.unsafe類中，聲明如下
public final native boolean compareAndSwapObject(Object var1, long var2, Object var4, Object var5); public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5); public final native boolean compareAndSwapLong(Object var1, long var2, long var4, long var6);
- 參數(shù)var1：表示要操作的對(duì)象
- 參數(shù)var2：表示要操作屬性地址的偏移量
- 參數(shù)var4：表示需要修改數(shù)據(jù)的期望的值
- 參數(shù)var5：表示需要修改的新值
2.2CAS實(shí)現(xiàn)原理是什么？
CAS通過(guò)調(diào)用JNI的代碼實(shí)現(xiàn)，JNI：java native interface，允許java調(diào)用其他語(yǔ)言。而compareAndSwapxxx系列的方法就是借助C語(yǔ)言來(lái)調(diào)用cpu底層指令實(shí)現(xiàn)的
以常用的Intel x86平臺(tái)為例，最終映射到cpu的指令為"cmpxchg"，這是一個(gè)原子指令，cpu執(zhí)行此命令時(shí)，實(shí)現(xiàn)比較并替換的操作
現(xiàn)代計(jì)算機(jī)動(dòng)不動(dòng)就上百核心，cmpxchg怎么保證多核心下的線程安全？
系統(tǒng)底層在進(jìn)行CAS操作的時(shí)候，會(huì)判斷當(dāng)前系統(tǒng)是否為多核心系統(tǒng)，如果是就給“總線”加鎖，只有一個(gè)線程會(huì)對(duì)總線加鎖成功，加鎖之后執(zhí)行CAS操作，也就是說(shuō)CAS的原子性是平臺(tái)級(jí)別的
2.3CAS存在的問(wèn)題
2.3.1什么是ABA問(wèn)題？
CAS需要在操作值的時(shí)候檢查下值有沒(méi)有發(fā)生變化，如果沒(méi)有發(fā)生變化則更新，但是如果一個(gè)值原來(lái)是A，在CAS方法執(zhí)行之前，被其他線程修改為B，然后又修改回了A，那么CAS方法執(zhí)行檢查的時(shí)候會(huì)發(fā)現(xiàn)它的值沒(méi)有發(fā)生變化，但是實(shí)際卻不是原來(lái)的A了，這就是CAS的ABA問(wèn)題
可以看到上圖中線程A在真正更改A之前，A已經(jīng)被其他線程修改為B然后又修改為A了
程序模擬ABA問(wèn)題
package day04;
import java.util.concurrent.atomic.AtomicInteger;
/**
* Description
* User:
* Date:
* Time:
*/
public class Test01 {
public static AtomicInteger a = new AtomicInteger();
public static void main(String[] args) {
Thread main = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+"執(zhí)行，a的值為:"+a.get());
try {
int expect = a.get();
int update = expect+1;
//讓出cpu
Thread.sleep(1000);
boolean b = a.compareAndSet(expect, update);
System.out.println(Thread.currentThread().getName()+"CAS執(zhí)行:"+b+",a的值為:"+a.get());
}
catch (InterruptedException e) {
e.printStackTrace();
}
}
},"主線程");
// main.start();
Thread thread1 = new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(20);
a.incrementAndGet();
System.out.println(Thread.currentThread().getName()+"更改a的值為:"+a.get());
a.decrementAndGet();
System.out.println(Thread.currentThread().getName()+"更改a的值為:"+a.get());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},"其他線程");
main.start();
thread1.start();
}
}
主線程執(zhí)行，a的值為:0
其他線程更改a的值為:1
其他線程更改a的值為:0
主線程CAS執(zhí)行:true,a的值為:1
可以看到，在執(zhí)行CAS之前，a被其他線程修改為1又修改為0，但是對(duì)執(zhí)行CAS并沒(méi)有影響，因?yàn)樗緵](méi)有察覺(jué)到其他線程對(duì)a的修改
2.3.2如何解決ABA問(wèn)題
解決ABA問(wèn)題最簡(jiǎn)單的方案就是給值加一個(gè)修改版本號(hào)，每次值變化，都會(huì)修改它的版本號(hào)，CAS操作時(shí)都去對(duì)比此版本號(hào)
在java中的ABA解決方案（AtomicStampedReference）
AtomicStampedReference主要包含一個(gè)對(duì)象引用及一個(gè)可以自動(dòng)更新的整數(shù)stamp的pair對(duì)象來(lái)解決ABA問(wèn)題
AtomicStampedReference源碼
/**
* Atomically sets the value of both the reference and stamp
* to the given update values if the
* current reference is {@code ==} to the expected reference
* and the current stamp is equal to the expected stamp.
*
* @param expectedReference the expected value of the reference 期待引用
* @param newReference the new value for the reference 新值引用
* @param expectedStamp the expected value of the stamp 期望引用的版本號(hào)
* @param newStamp the new value for the stamp 新值的版本號(hào)
* @return {@code true} if successful
*/
public boolean compareAndSet(V expectedReference,
V newReference,
int expectedStamp,
int newStamp) {
Pair<V> current = pair;
return
expectedReference == current.reference &&//期望引用與當(dāng)前引用保持一致
expectedStamp == current.stamp &&//期望引用版本號(hào)與當(dāng)前版本號(hào)保持一致
((newReference == current.reference &&//新值引用與當(dāng)前引用一致并且新值版本號(hào)與當(dāng)前版本號(hào)保持一致
newStamp == current.stamp)
||//如果上述版本號(hào)不一致，則通過(guò)casPair方法新建一個(gè)Pair對(duì)象，更新值和版本號(hào)，進(jìn)行再次比較
casPair(current, Pair.of(newReference, newStamp)));
}
private boolean casPair(Pair<V> cmp, Pair<V> val) {
return UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);
}
使用AtomicStampedReference解決ABA問(wèn)題代碼
package day04;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.atomic.AtomicStampedReference;
/**
* Description
* User:
* Date:
* Time:
*/
public class Test02 {
public static AtomicStampedReference<Integer> a = new AtomicStampedReference(new Integer(1),1);
public static void main(String[] args) {
Thread main = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+"執(zhí)行，a的值為:"+a.getReference());
try {
Integer expectReference = a.getReference();
Integer newReference = expectReference+1;
Integer expectStamp = a.getStamp();
Integer newStamp = expectStamp+1;
//讓出cpu
Thread.sleep(1000);
boolean b = a.compareAndSet(expectReference, newReference,expectStamp,newStamp);
System.out.println(Thread.currentThread().getName()+"CAS執(zhí)行:"+b);
}
catch (InterruptedException e) {
e.printStackTrace();
}
}
},"主線程");
// main.start();
Thread thread1 = new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(20);
a.compareAndSet(a.getReference(),a.getReference()+1,a.getStamp(),a.getStamp()+1);
System.out.println(Thread.currentThread().getName()+"更改a的值為:"+a.getReference());
a.compareAndSet(a.getReference(),a.getReference()-1,a.getStamp(),a.getStamp()-1);
System.out.println(Thread.currentThread().getName()+"更改a的值為:"+a.getReference());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},"其他線程");
main.start();
thread1.start();
}
}
主線程執(zhí)行，a的值為:1
其他線程更改a的值為:2
其他線程更改a的值為:1
主線程CAS執(zhí)行:false
因?yàn)?code>AtomicStampedReference執(zhí)行CAS會(huì)去檢查版本號(hào)，版本號(hào)不一致則不會(huì)進(jìn)行CAS，所以ABA問(wèn)題成功解決
總結(jié)
本篇文章就到這里了，希望能夠給你帶來(lái)幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!
相關(guān)文章
將Java程序的輸出結(jié)果寫入文件方法實(shí)例
這篇文章主要給大家介紹了關(guān)于將Java程序的輸出結(jié)果寫入文件的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-02-02
SpringBoot如何實(shí)現(xiàn)starter原理詳解
這篇文章主要介紹了SpringBoot如何實(shí)現(xiàn)starter原理詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-06-06
這篇文章主要介紹了Java 自定義注解的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)使用Java，感興趣的朋友可以了解下2021-03-03
MyBatis批量插入(insert)數(shù)據(jù)操作
本文給大家分享MyBatis批量插入(insert)數(shù)據(jù)操作知識(shí)，非常不錯(cuò)，具有參考借鑒價(jià)值，感興趣的朋友一起學(xué)習(xí)吧2016-06-06
解決springboot application.properties server.port配置問(wèn)題
這篇文章主要介紹了解決springboot application.properties server.port配置問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-08-08
這篇文章主要為大家介紹了jvm垃圾回收之GC調(diào)優(yōu)工具的分析詳解，在進(jìn)行JVM?GC性能調(diào)優(yōu)之前，需要使用某些工具獲取到當(dāng)前應(yīng)用的狀態(tài)信息2022-01-01
java計(jì)算代碼段執(zhí)行時(shí)間的詳細(xì)代碼
java里計(jì)算代碼段執(zhí)行時(shí)間可以有兩種方法，一種是毫秒級(jí)別的計(jì)算，另一種是更精確的納秒級(jí)別的計(jì)算，這篇文章主要介紹了java計(jì)算代碼段執(zhí)行時(shí)間,需要的朋友可以參考下2022-08-08
使用Vert.x Maven插件快速創(chuàng)建項(xiàng)目的方法
這篇文章主要介紹了使用Vert.x Maven插件快速創(chuàng)建項(xiàng)目的方法，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-09-09
這篇文章主要給大家介紹了關(guān)于JDK更換IDEA如何修改的相關(guān)資料,Java的不同版本的JDK之間存在細(xì)微的差別,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
這篇文章主要介紹了Spring @Scheduled的坑及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-08-08