//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 } }
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://www.ezyhdfw.cn/yun/72918.html
摘要:本篇我們將以的公平鎖為例來詳細(xì)看看使用獲取獨(dú)占鎖的流程。本文中的源碼基于。由于本篇我們分析的是獨(dú)占鎖,同一時(shí)刻,鎖只能被一個(gè)線程所持有。由于在整個(gè)搶鎖過程中,我們都是不響應(yīng)中斷的。 前言 AQS(AbstractQueuedSynchronizer)是JAVA中眾多鎖以及并發(fā)工具的基礎(chǔ),其底層采用樂觀鎖,大量使用了CAS操作, 并且在沖突時(shí),采用自旋方式重試,以實(shí)現(xiàn)輕量級和高效地獲取鎖...
摘要:我們可以將的作用理解為在多線程的環(huán)境下保證線程等待獲取鎖添加進(jìn)入隊(duì)列以及線程獲取鎖,并隊(duì)列中出去都是線程安全的。是如何做到線程安全的主要是通過死循環(huán)以及狀態(tài)值,來做到線程安全。 1、什么是aqs aqs是一個(gè)FIFO的雙向鏈表隊(duì)列。aqs將等待獲取鎖的線程封裝成結(jié)點(diǎn),放在隊(duì)列中。 我們可以將aqs的作用理解為在多線程的環(huán)境下保證線程等待獲取鎖(添加進(jìn)入隊(duì)列)以及線程獲取鎖,并隊(duì)列中出去...
ConcurrentHashMap源碼分析_JDK1.8版本 聲明 文章均為本人技術(shù)筆記,轉(zhuǎn)載請注明出處[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...
摘要:等到所有子線程都執(zhí)行完后即,會主調(diào)用線程,然后主調(diào)用線程就會從函數(shù)返回,繼續(xù)后余動作。 原理剖析(第 005 篇)AQS工作原理分析 - 一、大致介紹 1、前面章節(jié)講解了一下CAS,簡單講就是cmpxchg+lock的原子操作; 2、而在談到并發(fā)操作里面,我們不得不談到AQS,JDK的源碼里面好多并發(fā)的類都是通過Sync的內(nèi)部類繼承AQS而實(shí)現(xiàn)出五花八門的功能; 3、本章節(jié)就和大家分享...
閱讀 2279·2021-11-22 15:22
閱讀 1421·2021-11-11 16:54
閱讀 1970·2021-09-23 11:32
閱讀 3081·2021-09-22 10:02
閱讀 1853·2019-08-30 12:59
閱讀 1156·2019-08-29 16:27
閱讀 693·2019-08-29 13:21
閱讀 2519·2019-08-28 17:57