Java多線程CAS操作原理代碼實例解析
CAS操作號稱無鎖優(yōu)化,也叫作自旋;對于一些常見的操作需要加鎖,然后jdk就提供了一些以Atomic開頭的類,這些類內(nèi)部自動帶了鎖,當然這里的鎖并非是用synchronized來實現(xiàn)的,而是通過CAS操作來實現(xiàn)的;
一、下面是 AtomicInteger 的使用:
package com.designmodal.design.juc01;import java.util.ArrayList;import java.util.List;import java.util.concurrent.atomic.AtomicInteger;/** * @author D-L * @Classname T03_AtomicInteger * @Version 1.0 * @Description 使用 AtomicInteger 類解決常見的 多線程count++ *其內(nèi)部使用了CAS操作來保證原子性 但是不能保證多個方法連續(xù)調(diào)用都是原子性 * @Date 2020/7/21 0:35 */public class T03_AtomicInteger { //使用AtomicInteger類 AtomicInteger count = new AtomicInteger(0); public void m(){ for (int i = 0; i < 10000; i++) { //等同于 在 count++ 上加鎖 count.incrementAndGet(); } } public static void main(String[] args) { T03_AtomicInteger t = new T03_AtomicInteger(); List<Thread> threads = new ArrayList<>(); for (int i = 0; i < 10; i++) { threads.add(new Thread(t::m , 'Thread' + i)); } threads.forEach((o) -> o.start()); threads.forEach(o ->{ try {o.join(); } catch (InterruptedException e) {e.printStackTrace(); } }); System.out.println(t.count); }}
二、當然達到使用的級別很簡單,看一下API就好了,通過上面的小程序,下面主要來聊一聊原理:
1、通過源碼分析AtomicInteger
首先小程序中定義了一個 AtomicInteger 類型的變量count;
AtomicInteger count = new AtomicInteger(0); public void add(){ count.incrementAndGet(); }
調(diào)用了AtomicInteger類中incrementAndGet();
/** * Atomically increments by one the current value. * * @return the updated value */ public final int incrementAndGet() { return unsafe.getAndAddInt(this, valueOffset, 1) + 1; }
調(diào)用unsafe類中的 getAndAddInt(Object var1, long var2, int var4)方法;
public native int getIntVolatile(Object var1, long var2);public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5); 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; }
這里通過以上三步的操作,最終會進入Unsafe類這里調(diào)用的 compareAndSwapInt 意思就是比較然后交換,通過一個while循環(huán),在這里轉(zhuǎn)呀轉(zhuǎn),直到修改成功;
CAS(compareAndSwap)(比較并交換):原來想改變的值為0 ,現(xiàn)在想修改成1 ,這里想做到線程安全就必須要加synchronized,現(xiàn)在想用另外一種方式來替換加鎖的方法,就是所謂的CAS操作;你可以把它想象成擁有三個參數(shù)的方法cas(V , Expected , NewValue); 第一個參數(shù)V是你要改的那個值,Expected第二個參數(shù)是你期望當前的值是多少(也就是如果沒有線程修改的時,這個值應(yīng)該是多少,如果不是期望值那就證明有別的線程修改過),NewValue是要設(shè)置的新值;
上圖簡單模擬了CAS操作的過程,當線程1和線程2同時讀取了共享變量count = 0;在線程1修改的過程中,線程2已經(jīng)將count值修改為1,那么在線程1修改的時候發(fā)現(xiàn)Expected值和V已經(jīng)匹配不上了,證明已經(jīng)有線程快我一步將count值改了(可能這里并發(fā)量大的時候已經(jīng)有n多個線程已經(jīng)修改過了),怎么辦呢?那我只能將我的期望值修改成V的值、newValue 在這基礎(chǔ)上加1,然后繼續(xù)在這自旋操作,直到修改成功,這就是自旋操作;
2、Unsafe類(java并發(fā)包底層實現(xiàn)的核心)
CAS操作不需要加鎖是如何做到的呢?原因就在于Unsafe這個類,這個類除了你使用反射之外,你是不能夠直接使用的,這里不能使用的原因和ClassLoader有關(guān)系,所有AtomicXXX 類內(nèi)部都是CompareAndSwap / CompareAndSet(新版jdk),這個類中存在好多native方法;
Unsafe類使Java擁有了像C語言的指針一樣操作內(nèi)存空間的能力,一旦能夠直接操作內(nèi)存,這也就意味著(1)不受JVM管理,也就意味著無法被GC,需要我們手動GC,稍有不慎就會出現(xiàn)內(nèi)存泄漏。(2)Unsafe的不少方法中必須提供原始地址(內(nèi)存地址)和被替換對象的地址,偏移量要自己計算,一旦出現(xiàn)問題就是JVM崩潰級別的異常,會導(dǎo)致整個JVM實例崩潰,表現(xiàn)為應(yīng)用程序直接crash掉。(3)直接操作內(nèi)存,也意味著其速度更快,在高并發(fā)的條件之下能夠很好地提高效率。
CAS:CompareAndSwap,內(nèi)存偏移地址(var2),預(yù)期值(var4),新值(var5)。如果變量在當前時刻的值和預(yù)期值expected相等,嘗試將變量的值更新為新值(var5)。如果更新成功,返回true;否則,返回false。
/** * CAS操作 :Unsafe類中的本地方法 由于Java語言無法訪問操作系統(tǒng)底層信息(比如:底層硬件設(shè)備等), * 這時候就需要借助C C++語言來完成了 * @param var1 對象 * @param var2 偏移量 * @param var4 期望值 * @param var5 新值 * @return 修改成功返回true 失敗返回false */ 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);
三、CAS操作帶來的ABA問題
ABA問題說白了就是在線程進行CAS操作過程中有多個線程對這個共享變量進行修改,有加有減,兜兜轉(zhuǎn)轉(zhuǎn)又回到起始值,這時該線程渾然不知;打個不恰當?shù)谋扔鳎哼@個過程就好像你前女友跟你分手以后,在時隔一年之后又找你復(fù)合來了,說兜兜轉(zhuǎn)轉(zhuǎn)還是覺得你好,在此期間你前女友已經(jīng)換了幾個男朋友你卻渾然不知,那個好看的她穿著你喜歡的小短裙,扎著清純的馬尾辮又回來,好了言歸正傳,意思就是結(jié)果是你期望的,可是這個值是經(jīng)過很多版本的。
下面簡單模擬ABA操作圖:
如何解決ABA問題呢?
如果是int類型,最終的值也是你期望的,真的是沒有所謂,你也不用去糾結(jié)這問題;如果你確實就想管一管,那就加一個版本號,做一次修改操作加一,比較檢查時連帶版本號一起檢查。
基礎(chǔ)類型:沒有必要管,對你真的沒有所謂;
引用類型:就像是你女朋友和你分手之后又復(fù)合,中間經(jīng)歷了多少個男朋友,這個是有所謂的,這時可以通過加版本號來解決;
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. 基于PHP做個圖片防盜鏈2. ASP.NET MVC使用Boostrap實現(xiàn)產(chǎn)品展示、查詢、排序、分頁3. .NET中實現(xiàn)對象數(shù)據(jù)映射示例詳解4. jscript與vbscript 操作XML元素屬性的代碼5. asp.net core 認證和授權(quán)實例詳解6. php使用正則驗證密碼字段的復(fù)雜強度原理詳細講解 原創(chuàng)7. XML在語音合成中的應(yīng)用8. 如何使用ASP.NET Core 配置文件9. 基于javaweb+jsp實現(xiàn)企業(yè)車輛管理系統(tǒng)10. ASP.NET MVC把數(shù)據(jù)庫中枚舉項的數(shù)字轉(zhuǎn)換成文字
