`
gelongmei
  • 浏览: 197526 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
文章分类
社区版块
存档分类
最新评论

sun.misc.Unsafe

 
阅读更多
http://www.cnblogs.com/tianchi/archive/2013/02/27/2935695.html
Java不能直接访问操作系统底层,而是通过本地方法来访问,Unsafe提供了硬件级别的原子操作,提供了以下功能:
分配、释放内存

操作内存主要依靠下面三个方法:
allocateMemory:分配内存;
reallocateMemory:扩充内存;
freeMemory:释放内存;
操作对象的字段

  Java对象中字段的定位可以通过staticFieldOffset实现,而读取具体便宜位置的字段的值可以使用getLong(根据不同类型选择不同的函数)来完成,可以使用putLong(根据不同的类型选择不同的函数)来设置值,可以使用arrayBaseOffset(获取数组第一个元素的偏移地址)和arrayIndexScale(获取数组中元素增量的地址)来访问数组中的元素。
CAS操作

CAS操作(会在java.util.concurrent中大量地使用)包括三个操作数:
内存位置;
预期原值;
新值;
如果内存位置的值与预期的值相等,那么处理器会将该位置的值设置为新值,否则,处理器不做任何处理。int类型的CAS实现如下:
复制代码
static inline bool compareAndSwap (volatile jint *addr, jint old, jint new_val)
{
    jboolean result = false;
    spinlock lock;
    if ((result = (*addr == old)))
        *addr = new_val;
    return result;
}
复制代码
这段代码看起来根本无法保证操作的原子性,而其中的关键就在于spinlock lock这段看似没有用的代码,这时会调用构造函数,其中不停检查lock的值是否为0,如果不是0则线程让步等到线程下次执行时再次检查;否则,将lock设置为1。在离开函数的时候会调用其析构函数,将lock的值再次设置为0。spinlock的代码如下:
复制代码
class spinlock
{
    static volatile obj_addr_t lock;
public:
    spinlock ()
    {
        while (!compare_and_swap(&lock, 0, 1))
            _Jv_ThreadYield();
    }
    ~spinlock ()
    {
        release_set(&lock, 0);
    }
};
复制代码
而且,不管是在多核还是在单核的情况下,总是需要一些特殊的手段才能保证CAS操作成功吧,比如锁总线,compare_and_swap的实现如下:
复制代码
inline static bool compare_and_swap(volatile obj_addr_t *addr, obj_addr_t old, obj_addr_t new_val)
{
    char result;
    #ifdef __x86_64__ __asm__ __volatile__("lock; cmpxchgq %2, %0; setz %1"
        : "=m"(*(addr)), "=q"(result)
        : "r" (new_val), "a"(old), "m"(*addr)
        : "memory");
    #else
        __asm__ __volatile__("lock; cmpxchgl %2, %0; setz %1"
        : "=m"(*addr), "=q"(result)
        : "r" (new_val), "a"(old), "m"(*addr)
        : "memory");
    #endif
    return (bool) result;
}
复制代码
挂起和恢复

使用park方法将一个线程挂起,知道超时或者中断等条件出现,实现如下:
复制代码
void sun::misc::Unsafe::park(jboolean isAbsolute, jlong time)
{
    using namespace ::java::lang;
    Thread *thread = Thread::currentThread();
    natThread *nt = (natThread *) thread->data;
    nt->park_helper.park(isAbsolute, time);
}
复制代码
使用unpark来终止一个挂起的线程,使其恢复正常,实现如下:
sun::misc::Unsafe::unpark (::java::lang::Thread *thread)
{
    natThread *nt = (natThread *) thread->data;
    nt->park_helper.unpark ();
}
----- -- -
END
分享到:
评论

相关推荐

    sun.misc.Unsafe源码

    sun.misc.Unsafe源码文件,需要学习的带走。希望能够帮助到大家。

    JDK8中sun.misc包下的UnSafe类

    JDK8中sun.misc包下的UnSafe类,想查看源码的就拿走,没积分的请与我联系!xtfggef@gmail.com

    unsafe:使用sun.misc.Unsafe的各种Java类

    unsafe-helper-包含一些简单的方法,这些方法使使用sun.misc.Unsafe更容易。 unsafe-collection-在ArrayList上建模的示例列表,该列表不存储对集合内对象的引用,而是直接将元素复制到列表中。 这有一些有趣的特性...

    JDK8中sun.misc下UnSafe类源代码 UnSafe.java

    JDK8中sun.misc下UnSafe类源代码 UnSafe.java JDK8中sun.misc下UnSafe类源代码 UnSafe.java

    Java中的魔法类:sun.misc.Unsafe示例详解

    Java是一个安全的开发工具,它阻止开发人员犯很多低级的错误,而大部份的错误都是基于内存管理方面的。...下面这篇文章主要给大家介绍了关于Java中魔法类:sun.misc.Unsafe的相关资料,需要的朋友可以参考下

    mapdb-unsafe:提供使用 sun.misc.Unsafe 提高 10% 的内存存储

    !!!过时的!! Unsafe 现在是 MapDB 2.0 的一部分。 使用 DBMaker.newMemoryUnsafeDB().make()

    gate-core-8.0.zip

    unsafe-tools.zip,使用sun.misc.unsafe tools处理堆外内存和字节数组的工具使用sun.misc.unsafe处理堆外内存的工具

    面试必问之AQS原理详解.pdf

    AQS 原理 lock 最 常 用 的 类 就 是 ReentrantLock , 其 底 层 实 现 使 用 的 ...sun.misc.Unsafe.park()本地方法,再进一步,HotSpot 在 Linux 中中通过调用 pthread_mutex_lock 函数把线程交给系统内核进行阻塞。

    Java中LockSupport的使用.docx

    LockSupport是JDK1.6中在java.util.concurrent中的子包locks中引入的一个比较底层的工具类,用来创建锁...根据LockSupport 源码发现LockSupport的核心方法都是基于大名鼎鼎的sun.misc.Unsafe类中的park和unpark实现的。

    Unsafe.java

    JDK8中sun.misc下UnSafe类源代码 UnSafe.java

    varhandle2:JVM 原子操作的安全而有效的实现

    这个 API 允许使用不安全的操作(a la sun.misc.Unsafe)是一种安全的方式,但与使用 sun.misc.Unsafe 一样有效。 主要思想是基本上让 JIT 生成完全(或大部分)相同的代码,因此它会同样高效。 例如,这里是使用...

    lein-jammin:进入卡住过程的窗口

    这是一个修改现有任务的插件,如果你的程序在一个地方停留太久,它会打印一个格式化的线程转储到*err* 。 这在无法直接在进程上运行... ==main sun.misc.Unsafe.park Unsafe.java java.util.concurrent.locks.LockSu

    xstream-1.3.1-sae-liufeng

    XStream源码中通过反射机制使用到了sun.misc.Unsafe类,而该类因为安全原因被SAE禁用掉了,这就是为什么用到XStream的项目部署到SAE会报NoClassDefFoundError的原因

    Java为什么会引入及如何使用Unsafe

     sun.misc.Unsafe至少从2004年Java1.4开始存在于Java中了。在Java9中,为了提高JVM的可维护性,Unsafe和许多其他的东西一起都被作为内部使用类隐藏起来了。但是究竟是什么取代Unsafe不得而知,个人推测会有不止...

    indian:通往原生世界的大门

    /警告:这仍然是一个 ...目标支持c#(使用不安全代码) C++ neko(使用辅助库 - 慢) java(可选择使用 sun.misc.Unsafe 进行内存操作) 本机函数调用将在可能的情况下通过平台的本机支持完成。 否则,将使用 libffi。

    aircompressor:Snappy,LZO,LZ4和Zstandard到Java的端口

    纯Java压缩 该库包含用纯Java编写的 , (Zstd), 和。...该库需要Java 1.8+虚拟机,该虚拟机包含在一点字节序平台上运行的sun.misc.Unsafe接口。 用户数 该库用于Trino( )等分布式SQL引擎项目中。

    手写一个线程安全的非阻塞队列,并且实现入队出队方法

    实现思路:利用单向链表来保存队列的数据,在往队列中...import sun.misc.Unsafe; import java.lang.reflect.Field; public class MyLinkQueue { //头节点 private volatile Node head; //尾节点 private volati

    汪文君高并发编程实战视频资源下载.txt

     高并发编程第三阶段14讲 Unsafe中的方法使用,一半是天使,一半是魔鬼的Unsafe.mp4  高并发编程第三阶段15讲 Unsafe背后的汇编指令,牛逼男人背后的女人_.mp4  高并发编程第三阶段16讲 CountDownLatch经典案例...

    CAS

    CAS并发原语体现在Java语言中就是sun.misc.Unsafe类中的各个方法。 调用Unsafe类中的CAS方法,JVM会帮我们实现出CAS汇编指令。这是一种完全依赖于硬件的功能。 由于CAS是一种系统原语,原语属于操作系统用语范畴,是...

    trove:Trove 3库的修补版本-更改Collections语义以匹配适当的java.util.Map语义

    宝库3.0.3 Trove库的修补版本-更改Collections语义以匹配适当的java.util.Map语义Palantir... 分支由Palantir Gotham 4.x使用: 此版本添加了数组,列表,集合和映射的实现,这些实现利用了sun.misc.Unsafe类分配的堆外

Global site tag (gtag.js) - Google Analytics