cas調(diào)用鏈

sorra 發(fā)布于2019-08-16 14:19 / 3094人閱讀

//java.util.concurrent.atomic.AtomicInteger.java
    public final boolean compareAndSet(int expect, int update) {
        return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
    }

//sun.misc.Unsafe.java
    public final native boolean compareAndSwapInt(Object o, long offset,
                                                  int expected,
                                                  int x);

// http://hg.openjdk.java.net/jdk8u/jdk8u/  hotspotsrcsharevmprimsunsafe.cpp

// These are the methods prior to the JSR 166 changes in 1.6.0
static JNINativeMethod methods_15[] = {
//...
    {CC "compareAndSwapInt",  CC "(" OBJ "J""I""I"")Z",      FN_PTR(Unsafe_CompareAndSwapInt)},
//...

};

UNSAFE_ENTRY(jboolean, Unsafe_CompareAndSwapInt(JNIEnv *env, jobject unsafe, jobject obj, jlong offset, jint e, jint x))
  UnsafeWrapper("Unsafe_CompareAndSwapInt");
  oop p = JNIHandles::resolve(obj);
  jint* addr = (jint *) index_oop_from_field_offset_long(p, offset);
  return (jint)(Atomic::cmpxchg(x, addr, e)) == e;
UNSAFE_END

// http://hg.openjdk.java.net/jdk8u/jdk8u/  hotspotsrcsharevm
untimeatomic.cpp

unsigned Atomic::cmpxchg(unsigned int exchange_value,
                         volatile unsigned int* dest, unsigned int compare_value) {
  assert(sizeof(unsigned int) == sizeof(jint), "more work to do");
  return (unsigned int)Atomic::cmpxchg((jint)exchange_value, (volatile jint*)dest,
                                       (jint)compare_value);
}

// http://hg.openjdk.java.net/jdk8u/jdk8u/ hotspotsrcos_cpuwindows_x86vmatomic_windows_x86.inline.hpp
inline jint     Atomic::cmpxchg    (jint     exchange_value, volatile jint*     dest, jint     compare_value) {
  // alternative for InterlockedCompareExchange
  int mp = os::is_MP();
  __asm {
    mov edx, dest
    mov ecx, exchange_value
    mov eax, compare_value
    LOCK_IF_MP(mp)
    cmpxchg dword ptr [edx], ecx
  }
}

云服務(wù)器 GPU云服務(wù)器調(diào)用鏈 CAS volatile cas linux cas

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/72918.html

相關(guān)文章

集合小記

摘要：解決沖突開(kāi)放定址法拉鏈法表解決沖突開(kāi)放定址法再哈希法鏈地址法建立公共溢出區(qū)并發(fā)包中的線(xiàn)程安全的集合容器線(xiàn)程安全的，不允許為，默認(rèn)個(gè)的數(shù)組，每個(gè)中實(shí)現(xiàn)就是了，通過(guò)定位?；跀?shù)組，線(xiàn)程安全的集合類(lèi)，容量可以限制。 List 　　List?元素是有序的、可重復(fù)，實(shí)現(xiàn)List接口的集合主要有：ArrayList、LinkedList、Vector、Stack。　　ArrayList：動(dòng)態(tài)數(shù)組...

alaege 2019-08-16 10:35 評(píng)論0 收藏0
逐行分析AQS源碼(1)——獨(dú)占鎖的獲取

摘要：本篇我們將以的公平鎖為例來(lái)詳細(xì)看看使用獲取獨(dú)占鎖的流程。本文中的源碼基于。由于本篇我們分析的是獨(dú)占鎖，同一時(shí)刻，鎖只能被一個(gè)線(xiàn)程所持有。由于在整個(gè)搶鎖過(guò)程中，我們都是不響應(yīng)中斷的。前言 AQS（AbstractQueuedSynchronizer）是JAVA中眾多鎖以及并發(fā)工具的基礎(chǔ)，其底層采用樂(lè)觀鎖，大量使用了CAS操作，并且在沖突時(shí)，采用自旋方式重試，以實(shí)現(xiàn)輕量級(jí)和高效地獲取鎖...

call_me_R 2019-08-19 10:47 評(píng)論0 收藏0
線(xiàn)程系列四AQS

摘要：我們可以將的作用理解為在多線(xiàn)程的環(huán)境下保證線(xiàn)程等待獲取鎖添加進(jìn)入隊(duì)列以及線(xiàn)程獲取鎖，并隊(duì)列中出去都是線(xiàn)程安全的。是如何做到線(xiàn)程安全的主要是通過(guò)死循環(huán)以及狀態(tài)值，來(lái)做到線(xiàn)程安全。 1、什么是aqs aqs是一個(gè)FIFO的雙向鏈表隊(duì)列。aqs將等待獲取鎖的線(xiàn)程封裝成結(jié)點(diǎn)，放在隊(duì)列中。我們可以將aqs的作用理解為在多線(xiàn)程的環(huán)境下保證線(xiàn)程等待獲取鎖(添加進(jìn)入隊(duì)列)以及線(xiàn)程獲取鎖，并隊(duì)列中出去...

sevi_stuo 2019-08-19 10:55 評(píng)論0 收藏0
ConcurrentHashMap源碼分析_JDK1.8版本

ConcurrentHashMap源碼分析_JDK1.8版本聲明文章均為本人技術(shù)筆記，轉(zhuǎn)載請(qǐng)注明出處[1] https://segmentfault.com/u/yzwall[2] blog.csdn.net/j_dark/ JDK1.6版本 ConcurrentHashMap結(jié)構(gòu) showImg(https://segmentfault.com/img/remote/146000000900...

animabear 2019-08-14 18:05 評(píng)論0 收藏0
原理剖析（第 005 篇）AQS工作原理分析

摘要：等到所有子線(xiàn)程都執(zhí)行完后即，會(huì)主調(diào)用線(xiàn)程，然后主調(diào)用線(xiàn)程就會(huì)從函數(shù)返回，繼續(xù)后余動(dòng)作。原理剖析（第 005 篇）AQS工作原理分析 - 一、大致介紹 1、前面章節(jié)講解了一下CAS，簡(jiǎn)單講就是cmpxchg+lock的原子操作； 2、而在談到并發(fā)操作里面，我們不得不談到AQS，JDK的源碼里面好多并發(fā)的類(lèi)都是通過(guò)Sync的內(nèi)部類(lèi)繼承AQS而實(shí)現(xiàn)出五花八門(mén)的功能； 3、本章節(jié)就和大家分享...

Aklman 2019-08-16 11:12 評(píng)論0 收藏0