cas调用链

sorra 发布于2019-08-16 14:19 / 2988人阅读

//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
  }
}

海外云主机服务器托管调用链 CAS volatile cas linux cas

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/72918.html

集合小记

摘要：解決沖突开放定址法拉链法表解決沖突开放定址法再哈希法链地址法建立公共溢出区并发包中的线程安全的集合容器线程安全的，不允许为，默认个的数组，每个中实现就是了，通过定位。基于数组，线程安全的集合类，容量可以限制。 List 　　List 元素是有序的、可重复，实现List接口的集合主要有：ArrayList、LinkedList、Vector、Stack。　　ArrayList：动态数组...

alaege 2019-08-16 10:35 评论0 收藏0
逐行分析AQS源码(1)——独占锁的获取

摘要：本篇我们将以的公平锁为例来详细看看使用获取独占锁的流程。本文中的源码基于。由于本篇我们分析的是独占锁，同一时刻，锁只能被一个线程所持有。由于在整个抢锁过程中，我们都是不响应中断的。前言 AQS（AbstractQueuedSynchronizer）是JAVA中众多锁以及并发工具的基础，其底层采用乐观锁，大量使用了CAS操作，并且在冲突时，采用自旋方式重试，以实现轻量级和高效地获取锁...

call_me_R 2019-08-19 10:47 评论0 收藏0
线程系列四AQS

摘要：我们可以将的作用理解为在多线程的环境下保证线程等待获取锁添加进入队列以及线程获取锁，并队列中出去都是线程安全的。是如何做到线程安全的主要是通过死循环以及状态值，来做到线程安全。 1、什么是aqs aqs是一个FIFO的双向链表队列。aqs将等待获取锁的线程封装成结点，放在队列中。我们可以将aqs的作用理解为在多线程的环境下保证线程等待获取锁(添加进入队列)以及线程获取锁，并队列中出去...

sevi_stuo 2019-08-19 10:55 评论0 收藏0
ConcurrentHashMap源码分析_JDK1.8版本

ConcurrentHashMap源码分析_JDK1.8版本声明文章均为本人技术笔记，转载请注明出处[1] https://segmentfault.com/u/yzwall[2] blog.csdn.net/j_dark/ JDK1.6版本 ConcurrentHashMap结构 showImg(https://segmentfault.com/img/remote/146000000900...

animabear 2019-08-14 18:05 评论0 收藏0
原理剖析（第 005 篇）AQS工作原理分析

摘要：等到所有子线程都执行完后即，会主调用线程，然后主调用线程就会从函数返回，继续后余动作。原理剖析（第 005 篇）AQS工作原理分析 - 一、大致介绍 1、前面章节讲解了一下CAS，简单讲就是cmpxchg+lock的原子操作； 2、而在谈到并发操作里面，我们不得不谈到AQS，JDK的源码里面好多并发的类都是通过Sync的内部类继承AQS而实现出五花八门的功能； 3、本章节就和大家分享...

Aklman 2019-08-16 11:12 评论0 收藏0