日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

美團一面:什么是CAS?有什么優缺點?我說我知道AtomicInteger

來源: 責編: 時間:2024-04-22 09:16:12 199觀看
導讀引言傳統的并發控制手段,如使用synchronized關鍵字或者ReentrantLock等互斥鎖機制,雖然能夠有效防止資源的競爭沖突,但也可能帶來額外的性能開銷,如上下文切換、鎖競爭導致的線程阻塞等。而此時就出現了一種樂觀鎖的策略,

引言

傳統的并發控制手段,如使用synchronized關鍵字或者ReentrantLock等互斥鎖機制,雖然能夠有效防止資源的競爭沖突,但也可能帶來額外的性能開銷,如上下文切換、鎖競爭導致的線程阻塞等。而此時就出現了一種樂觀鎖的策略,以其非阻塞、輕量級的特點,在某些場合下能更好地提升并發性能,其中最為關鍵的技術便是Compare And Swap(簡稱CAS)。U5g28資訊網——每日最新資訊28at.com

CAS是一種無鎖算法,它在硬件級別提供了原子性的條件更新操作,允許線程在不加鎖的情況下實現對共享變量的修改。在Java中,CAS機制被廣泛應用于java.util.concurrent.atomic包下的原子類以及高級并發工具類如AbstractQueuedSynchronizer(AQS)的實現中。U5g28資訊網——每日最新資訊28at.com

CAS的基本概念與原理

CAS是一種原子指令,常用于多線程環境中的無鎖算法。CAS操作包含三個基本操作數:內存位置、期望值和新值。在執行CAS操作時,計算機會檢查內存位置當前是否存放著期望值,如果是,則將內存位置的值更新為新值;若不是,則不做任何修改,保持原有值不變,并返回當前內存位置的實際值。U5g28資訊網——每日最新資訊28at.com

在Java中,CAS機制被封裝在jdk.internal.misc.Unsafe類中,盡管這個類并不建議在普通應用程序中直接使用,但它是構建更高層次并發工具的基礎,例如java.util.concurrent.atomic包下的原子類如AtomicInteger、AtomicLong等。這些原子類通過JNI調用底層硬件提供的CAS指令,從而在Java層面上實現了無鎖并發操作。U5g28資訊網——每日最新資訊28at.com

這里指的注意的是,在JDK1.9之前CAS機制被封裝在sun.misc.Unsafe類中,在JDK1.9之后就使用了 jdk.internal.misc.Unsafe。這點由java.util.concurrent.atomic包下的原子類可以看出來。而sun.misc.Unsafe被許多第三方庫所使用。U5g28資訊網——每日最新資訊28at.com

CAS實現原理

在Java中,雖然Java語言本身并未直接提供CAS這樣的原子指令,但是Java可以通過JNI調用本地方法來利用硬件級別的原子指令實現CAS操作。在Java的標準庫中,特別是jdk.internal.misc.Unsafe類提供了一系列compareAndSwapXXX方法,這些方法底層確實是通過C++編寫的內聯匯編來調用對應CPU架構的cmpxchg指令,從而實現原子性的比較和交換操作。U5g28資訊網——每日最新資訊28at.com

cmpxchg指令是多數現代CPU支持的原子指令,它能在多線程環境下確保一次比較和交換操作的原子性,有效解決了多線程環境下數據競爭的問題,避免了數據不一致的情況。例如,在更新一個共享變量時,如果期望值與當前值相匹配,則原子性地更新為新值,否則不進行更新操作,這樣就能在無鎖的情況下實現對共享資源的安全訪問。 我們以java.util.concurrent.atomic包下的AtomicInteger為例,分析其compareAndSet方法。U5g28資訊網——每日最新資訊28at.com

public class AtomicInteger extends Number implements java.io.Serializable {    private static final long serialVersionUID = 6214790243416807050L;    //由這里可以看出來,依賴jdk.internal.misc.Unsafe實現的    private static final jdk.internal.misc.Unsafe U = jdk.internal.misc.Unsafe.getUnsafe();    private static final long VALUE = U.objectFieldOffset(AtomicInteger.class, "value");    private volatile int value;    public final boolean compareAndSet(int expectedValue, int newValue) {         // 調用 jdk.internal.misc.Unsafe的compareAndSetInt方法        return U.compareAndSetInt(this, VALUE, expectedValue, newValue);      }}

Unsafe中的compareAndSetInt使用了@HotSpotIntrinsicCandidate注解修飾,@HotSpotIntrinsicCandidate注解是Java HotSpot虛擬機(JVM)的一個特性注解,它表明標注的方法有可能會被HotSpot JVM識別為“內聯候選”,當JVM發現有方法被標記為內聯候選時,會嘗試利用底層硬件提供的原子指令(比如cmpxchg指令)直接替換掉原本的Java方法調用,從而在運行時獲得更好的性能。U5g28資訊網——每日最新資訊28at.com

public final class Unsafe {    @HotSpotIntrinsicCandidate      public final native boolean compareAndSetInt(Object o, long offset,                                                   int expected,                                                   int x);}

compareAndSetInt這個方法我們可以從openjdk的hotspot源碼(位置:hotspot/src/share/vm/prims/unsafe.cpp)中可以找到:U5g28資訊網——每日最新資訊28at.com

{CC "compareAndSetObject",CC "(" OBJ "J" OBJ "" OBJ ")Z", FN_PTR(Unsafe_CompareAndSetObject)},{CC "compareAndSetInt", CC "(" OBJ "J""I""I"")Z", FN_PTR(Unsafe_CompareAndSetInt)},{CC "compareAndSetLong", CC "(" OBJ "J""J""J"")Z", FN_PTR(Unsafe_CompareAndSetLong)},{CC "compareAndExchangeObject", CC "(" OBJ "J" OBJ "" OBJ ")" OBJ, FN_PTR(Unsafe_CompareAndExchangeObject)},{CC "compareAndExchangeInt", CC "(" OBJ "J""I""I"")I", FN_PTR(Unsafe_CompareAndExchangeInt)},{CC "compareAndExchangeLong", CC "(" OBJ "J""J""J"")J", FN_PTR(Unsafe_CompareAndExchangeLong)},

關于openjdk的源碼,本文源碼版本為1.9,如需要該版本源碼或者其他版本下載方法,請關注本公眾號【碼農Academy】后,后臺回復【openjdk】獲取U5g28資訊網——每日最新資訊28at.com

而hostspot中的Unsafe_CompareAndSetInt函數會統一調用Atomic的cmpxchg函數:U5g28資訊網——每日最新資訊28at.com

UNSAFE_ENTRY(jboolean, Unsafe_CompareAndSetInt(JNIEnv *env, jobject unsafe, jobject obj, jlong offset, jint e, jint x)) {oop p = JNIHandles::resolve(obj);jint* addr = (jint *)index_oop_from_field_offset_long(p, offset);// 統一調用Atomic的cmpxchg函數return (jint)(Atomic::cmpxchg(x, addr, e)) == e;} UNSAFE_END

而Atomic的cmpxchg函數源碼(位置:hotspot/src/share/vm/runtime/atomic.hpp)如下:U5g28資訊網——每日最新資訊28at.com

/***這是按字節大小進行的`cmpxchg`操作的默認實現。它使用按整數大小進行的`cmpxchg`來模擬按字節大小進行的`cmpxchg`。不同的平臺可以通過定義自己的內聯定義以及定義`VM_HAS_SPECIALIZED_CMPXCHG_BYTE`來覆蓋這個默認實現。這將導致使用特定于平臺的實現而不是默認實現。*  exchange_value:要交換的新值。*  dest:指向目標字節的指針。*  compare_value:要比較的值。*  order:內存順序。*/inline jbyte Atomic::cmpxchg(jbyte exchange_value, volatile jbyte* dest,                             jbyte compare_value, cmpxchg_memory_order order) {  STATIC_ASSERT(sizeof(jbyte) == 1);  volatile jint* dest_int =      static_cast<volatile jint*>(align_ptr_down(dest, sizeof(jint)));  size_t offset = pointer_delta(dest, dest_int, 1);  // 獲取當前整數大小的值,并將其轉換為字節數組。  jint cur = *dest_int;  jbyte* cur_as_bytes = reinterpret_cast<jbyte*>(&cur);  // 設置當前整數中對應字節的值為compare_value。這確保了如果初始的整數值不是我們要找的值,那么第一次的cmpxchg操作會失敗。  cur_as_bytes[offset] = compare_value;  // 在循環中,不斷嘗試更新目標字節的值。  do {    // new_val    jint new_value = cur;    // 復制當前整數值,并設置其中對應字節的值為exchange_value。    reinterpret_cast<jbyte*>(&new_value)[offset] = exchange_value;    // 嘗試使用新的整數值替換目標整數。    jint res = cmpxchg(new_value, dest_int, cur, order);    if (res == cur) break; // 如果返回值與原始整數值相同,說明操作成功。    // 更新當前整數值為cmpxchg操作的結果。    cur = res;    // 如果目標字節的值仍然是我們之前設置的值,那么繼續循環并再次嘗試。  } while (cur_as_bytes[offset] == compare_value);  // 返回更新后的字節值  return cur_as_bytes[offset];}

而由cmpxchg函數中的do...while我們也可以看出,當多個線程同時嘗試更新同一內存位置,且它們的期望值相同但只有一個線程能夠成功更新時,其他線程的CAS操作會失敗。對于失敗的線程,常見的做法是采用自旋鎖的形式,即循環重試直到成功為止。這種方式在低競爭或短時間窗口內的并發更新時,相比于傳統的鎖機制,它避免了線程的阻塞和喚醒帶來的開銷,所以它的性能會更優。U5g28資訊網——每日最新資訊28at.com

Java中的CAS實現與API

在Java中,CAS操作的實現主要依賴于兩個關鍵組件:sun.misc.Unsafe類、jdk.internal.misc.Unsafe類以及java.util.concurrent.atomic包下的原子類。盡管Unsafe類提供了對底層硬件原子操作的直接訪問,但由于其API是非公開且不穩定的,所以在常規開發中并不推薦直接使用。Java標準庫提供了豐富的原子類,它們是基于Unsafe封裝的安全、便捷的CAS操作實現。U5g28資訊網——每日最新資訊28at.com

java.util.concurrent.atomic包

Java標準庫中的atomic包為開發者提供了許多原子類,如AtomicInteger、AtomicLong、AtomicReference等,它們均內置了CAS操作邏輯,使得我們可以在更高的抽象層級上進行無鎖并發編程。U5g28資訊網——每日最新資訊28at.com

U5g28資訊網——每日最新資訊28at.com

圖片圖片U5g28資訊網——每日最新資訊28at.com

而對于這個問題,其實也很好解決,我們給這個數據加上一個時間戳或者版本號(樂觀鎖概念)。即每次不僅比較值,還會比較版本。比如上述示例,初始時str的值的版本是1,然后線程2操作后值變成B,而對應版本變成了2,然后線程3操作后值變成了A,版本變成了3,而對于線程2來說,雖然值還是A,但是版本號變了,所以線程2依然會執行替換的操作。U5g28資訊網——每日最新資訊28at.com

Java的原子類就提供了類似的實現,如AtomicStampedReference和AtomicMarkableReference引入了附加的標記位或版本號,以便區分不同的修改序列。U5g28資訊網——每日最新資訊28at.com

圖片圖片U5g28資訊網——每日最新資訊28at.com

圖片圖片U5g28資訊網——每日最新資訊28at.com

總結

Java中的CAS原理及其在并發編程中的應用是一項非常重要的技術。CAS利用CPU硬件提供的原子指令,實現了在無鎖環境下的高效并發控制,避免了傳統鎖機制帶來的上下文切換和線程阻塞開銷。Java通過JNI接口調用底層的CAS指令,封裝在jdk.internal.misc類和java.util.concurrent.atomic包下的原子類中,為我們提供了簡潔易用的API來實現無鎖編程。U5g28資訊網——每日最新資訊28at.com

CAS在帶來并發性能提升的同時,也可能引發循環開銷過大、ABA問題等問題。針對這些問題,Java提供了如LongAdder、AtomicStampedReference和AtomicMarkableReference等工具類來解決ABA問題,同時也通過自適應自旋、適時放棄自旋轉而進入阻塞等待等方式降低循環開銷。U5g28資訊網——每日最新資訊28at.com

理解和熟練掌握CAS原理及其在Java中的應用,有助于我們在開發高性能并發程序時作出更明智的選擇,既能提高系統并發性能,又能保證數據的正確性和一致性。U5g28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-84469-0.html美團一面:什么是CAS?有什么優缺點?我說我知道AtomicInteger

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 在前端中,什么是幽靈依賴?

下一篇: 如何做配置鏈接的質量保障?看這篇就對了

標簽:
  • 熱門焦點
  • 6月安卓手機好評榜:魅族20 Pro蟬聯冠軍

    性能榜和性價比榜之后,我們來看最后的安卓手機好評榜,數據來源安兔兔評測,收集時間2023年6月1日至6月30日,僅限國內市場。第一名:魅族20 Pro好評率:95%5月份的時候魅族20 Pro就是
  • 0糖0卡0脂 旭日森林仙草烏龍茶優惠:15瓶到手29元

    旭日森林無糖仙草烏龍茶510ml*15瓶平時要賣為79.9元,今日下單領取50元優惠券,到手價為29.9元。產品規格:0糖0卡0脂,添加草本仙草汁,清涼爽口,富含茶多酚,保留
  • 如何正確使用:Has和:Nth-Last-Child

    我們可以用CSS檢查,以了解一組元素的數量是否小于或等于一個數字。例如,一個擁有三個或更多子項的grid。你可能會想,為什么需要這樣做呢?在某些情況下,一個組件或一個布局可能會
  • 一篇聊聊Go錯誤封裝機制

    %w 是用于錯誤包裝(Error Wrapping)的格式化動詞。它是用于 fmt.Errorf 和 fmt.Sprintf 函數中的一個特殊格式化動詞,用于將一個錯誤(或其他可打印的值)包裝在一個新的錯誤中。使
  • .NET 程序的 GDI 句柄泄露的再反思

    一、背景1. 講故事上個月我寫過一篇 如何洞察 C# 程序的 GDI 句柄泄露 文章,當時用的是 GDIView + WinDbg 把問題搞定,前者用來定位泄露資源,后者用來定位泄露代碼,后面有朋友反
  • 三分鐘白話RocketMQ系列—— 如何發送消息

    我們知道RocketMQ主要分為消息 生產、存儲(消息堆積)、消費 三大塊領域。那接下來,我們白話一下,RocketMQ是如何發送消息的,揭秘消息生產全過程。注意,如果白話中不小心提到相關代
  • 阿里瓴羊One推出背后,零售企業迎數字化新解

    作者:劉曠近年來隨著數字經濟的高速發展,各式各樣的SaaS應用服務更是層出不窮,但本質上SaaS大多局限于單一業務流層面,對用戶核心關切的增長問題等則沒有提供更好的解法。在Saa
  • 機構稱Q2全球智能手機出貨量同比下滑11% 蘋果份額依舊第2

    7月20日消息,據外媒報道,研究機構的報告顯示,由于需求下滑,今年二季度全球智能手機的出貨量,同比下滑了11%,三星、蘋果等主要廠商的銷量,較去年同期均有下
  • 榮耀Magicbook V 14 2021曙光藍版本正式開售,擁有觸摸屏

    榮耀 Magicbook V 14 2021 曙光藍版本正式開售,搭載 i7-11390H 處理器與 MX450 顯卡,配備 16GB 內存與 512GB SSD,重 1.48kg,厚 14.5mm,具有 1.5mm 鍵盤鍵程、
Top 主站蜘蛛池模板: 虹口区| 临颍县| 兴隆县| 龙山县| 息烽县| 金秀| 永定县| 亳州市| 景泰县| 益阳市| 福鼎市| 泾阳县| 商都县| 蕲春县| 塔城市| 耿马| 天峨县| 博湖县| 玉屏| 乌拉特中旗| 商南县| 宣化县| 肥西县| 温州市| 临邑县| 建湖县| 宣恩县| 安义县| 舒兰市| 图木舒克市| 南召县| 讷河市| 淳化县| 洞口县| 循化| 甘泉县| 嵊州市| 子洲县| 朝阳县| 遂川县| 房产|