Unsafe类详解

Unsafe类是进行底层操作的方法集合,可以直接操作内存,进行一些非常规操作,所以说是"不安全"的操作,但是因为直接操作内存,它的效率很高,通常在在对性能有要求或者有底层操作需求的时候使用

Unsafe的包名为sun.misc,Java9开始,位于jdk.unsupported模块内,并且添加大量注释方便使用,同时在jdk.internal模块内有一个更底层的Unsafe类实现

Unsafe 实例化

因为Unsafe的构造函数是private,所以不能使用new创建,Unsafe使用单例模式构建,内部实例字段名称为theUnsafe

    private Unsafe() {}
    private static final Unsafe theUnsafe = new Unsafe();
    private static final jdk.internal.misc.Unsafe theInternalUnsafe = jdk.internal.misc.Unsafe.getUnsafe();

Unsafe.getUnsafe静态方法可以返回该字段,但是Java9之前,只有调用该方法的类是通过引导类加载器(bootstrap class loader)加载的才可以获取该字段(此时caller.getClassLoader()返回值为null),即JDK源码可以正常调用,个人写的代码都会抛出异常SecurityException

    // Java8
    @CallerSensitive
    public static Unsafe getUnsafe() {
        Class<?> caller = Reflection.getCallerClass();
        if (!VM.isSystemDomainLoader(caller.getClassLoader()))
            throw new SecurityException("Unsafe");
        return theUnsafe;
    }

    // Java9
    public static Unsafe getUnsafe() {
        return theUnsafe;
    }

为此可以将引导类加载器路径设置为系统默认值加上自身代码的当前路径

java -Xbootclasspath:/usr/lib/jvm/jdk1.8.0/jre/lib/rt.jar:. MainClassName

但是这样太过麻烦,所以在Java8及以前,直接使用反射获取该theUnsafe字段,抑制Java语言的访问检查(private属性),获取字段的值

    Field f = Unsafe.class.getDeclaredField("theUnsafe");
    f.setAccessible(true);
    Unsafe unsafe = (Unsafe) f.get(null);

Unsafe API

大多数API都是通过native函数实现的,具体可以查看源码中的文件path/to/openjdk/source/hotspot/src/share/vm/prims/unsafe.cpp

Classes/Objects

创建类对象,不进行初始化:

//实例化对象,但是不进行初始化,类初始化和实例初始化都不调用
Object allocateInstance(Class<?> cls)

对象和字段的地址获取:

//字段在内存中的地址相对于实例对象内存地址的偏移量
public long objectFieldOffset(Field f)
public long objectFieldOffset(Class<?> c, String name)
//静态字段在类对象中的偏移
public long staticFieldOffset(Field f)
//获得静态字段所对应类对象,等同于f.getDeclaringClass()
public Object staticFieldBase(Field f)

读取/修改对象上指定偏移位置的值,其他基本数据类型(boolean,char,byte,short,float,double,long)类似:

public native int getInt(Object o, long offset);
public native void putInt(Object o, long offset, int x);

此外还可以读取/设定引用值reference value,指针native pointer

//获得给定对象偏移量上的引用类型的值
public native Object getObject(Object o, long offset);
//设置给定对象偏移量上的引用类型的值
public native void putObject(Object o, long offset, Object x);
//获取、设定本地指针的值,等同于获取、设定int或者是long类型的数据
public long getAddress(Object o, long offset)
public void putAddress(Object o, long offset, long x)

以上方法都是通过两个参数引用到一个变量,叫做double-register地址模式,
当Object引用为null时,把offset作为绝对地址,使用绝对地址的API,叫做single-register地址模式,例如:

    public void putInt(long address, int x) {
        putInt(null, address, x);
    }

此时address可以指向通过Unsafe.allocateMemory获取的内存块中的地址,类似于C语言中的指针,直接指明实际要读写的地址

Arrays

数组头部还存储有数组的长度信息,索引访问数组元素时需要知道第一个元素与起始位置的偏移地址,Unsafe类包含所有的基本数据类型和Object类型的偏移的常量值,名称为ARRAY_***_BASE_OFFSET

同时访问数组第i个元素,对应偏移的确定需要乘以一个比例值,即数组中单个元素的长度,Unsafe中对应的常量为ARRAY_***_INDEX_SCALE

// 初始偏移
public int arrayBaseOffset(Class<?> arrayClass)

public static final int ARRAY_BOOLEAN_BASE_OFFSET
        = theUnsafe.arrayBaseOffset(boolean[].class);

public static final int ARRAY_OBJECT_BASE_OFFSET
        = theUnsafe.arrayBaseOffset(Object[].class);
// 比例值
public int arrayIndexScale(Class<?> arrayClass)

public static final int ARRAY_BOOLEAN_INDEX_SCALE
        = theUnsafe.arrayIndexScale(boolean[].class);

public static final int ARRAY_OBJECT_INDEX_SCALE
        = theUnsafe.arrayIndexScale(Object[].class);

两个信息配合使用,就可以得到数组中每个元素相对内存起点的偏移,然后进行读写

    // java8中的ConcurrentHashMap
    Class<?> ak = Node[].class;
    ABASE = U.arrayBaseOffset(ak);
    int scale = U.arrayIndexScale(ak);
    ASHIFT = 31 - Integer.numberOfLeadingZeros(scale);

    //具体使用,i代表索引
    static final <K,V> boolean casTabAt(Node<K,V>[] tab, int i,
                                        Node<K,V> c, Node<K,V> v) {
        return U.compareAndSwapObject(tab, ((long)i << ASHIFT) + ABASE, c, v);
    }

Synchronization

CAS操作

只有Object,int和long类型,对于其他基本数据类型,可以对数据进行转换为以上三种数据类型,再进行CAS

public final native boolean compareAndSwapObject(Object o, long offset, Object expected, Object x);
public final native boolean compareAndSwapInt(Object o, long offset, int expected, int x);
public final native boolean compareAndSwapLong(Object o, long offset, long expected, long x);

JDK8中添加了一些对基本数据类型进行循环CAS操作,确保成功的功能函数

    @HotSpotIntrinsicCandidate
    public final int getAndAddInt(Object o, long offset, int delta) {
        int v;
        do {
            v = getIntVolatile(o, offset);
        } while (!weakCompareAndSetInt(o, offset, v, v + delta));
        return v;
    }

    @HotSpotIntrinsicCandidate
    public final int getAndSetInt(Object o, long offset, int newValue) {
        int v;
        do {
            v = getIntVolatile(o, offset);
        } while (!weakCompareAndSetInt(o, offset, v, newValue));
        return v;
    }

volatile

使用volatile机制加载读取数据,保证可见性,API包含所有的基本数据类型和Object类型

//设置给定对象的int值,使用volatile语义,即设置后立马更新到内存对其他线程可见
public native void  putIntVolatile(Object o, long offset, int x);
//获得给定对象的指定偏移量offset的int值,使用volatile语义,总能获取到最新的int值。
public native int getIntVolatile(Object o, long offset);

此外还有一种惰性设定值的方式,通常出现在AtomicXXX.lazySet,它允许volatile变量和后续的内存操作重排序,就像普通非volatile变量的写操作,所以其他线程可能不能立即获取到新的值

putOrderedObject(Object o, long offset, Object x)
putOrderedInt(Object o, long offset, int x)
putOrderedLong(Object o, long offset, long x)

挂起

调用park后,线程将被阻塞,直到unpark调用或者超时,如果之前调用过unpark,不会进行阻塞,即parkunpark不区分先后顺序,该操作被封装在LockSupport类中

// 阻塞线程
public native void park(boolean isAbsolute, long time);  

// 解除阻塞或者让下一次阻塞调用失效
public native void unpark(Object thread);

内存屏障

确保内存可见性,在适当的位置插入内存屏障,JMM把内存屏障分为4种LoadLoad、LoadStore、StoreStore、StoreLoad

//在屏障之前的读操作,不会和之后的读写操作重排序,相当于LoadLoad 加上 LoadStore 屏障
public native void loadFence();
//在屏障之前的读写操作,不会和之后的写操作重排序,相当于StoreStore 加上 LoadStore 屏障
public native void storeFence();
//在该方法之前的所有读写操作,不会和之后的读写操作重排序,功能上相当于上面两个的功能和,加上StoreLoad屏障
public native void fullFence();

Memory

包括内存的分配,释放,复制

//分配指定大小的内存,内存没有被初始化
public long allocateMemory(long bytes)
//根据给定的内存地址address调整内存大小
public long reallocateMemory(long address, long bytes)

//将内存块中的所有字节设置为固定值,类似于C中的memoryset函数
public void setMemory(Object o, long offset, long bytes, byte value)
public void setMemory(long address, long bytes, byte value)

//内存复制,支持两种地址模式
public void copyMemory(Object srcBase, long srcOffset,
                        Object destBase, long destOffset,
                        long bytes)
public void copyMemory(long srcAddress, long destAddress, long bytes)

//释放allocateMemory和reallocateMemory申请的内存
public native void freeMemory(long l);

内存的其他信息:

// 本地指针的大小 native pointer,4 或者 8
public int addressSize()
// 内存页面大小,通常为4KB,即4096
public native int pageSize()
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,122评论 6 505
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,070评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,491评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,636评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,676评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,541评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,292评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,211评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,655评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,846评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,965评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,684评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,295评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,894评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,012评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,126评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,914评论 2 355

推荐阅读更多精彩内容