摘要：它的目的是為了增強語言直接操作底層資源的能力，無疑帶來很多方便。這樣可以有效避免多線程環(huán)境下的同步問題。另外還有的匿名內(nèi)部類的生成，數(shù)組內(nèi)存操作等。

本文原創(chuàng)地址，我的博客：jsbintask的博客(食用效果最佳)，轉(zhuǎn)載請注明出處!

Unsafe是jdk提供的一個直接訪問操作系統(tǒng)資源的工具類（底層c++實現(xiàn)），它可以直接分配內(nèi)存，內(nèi)存復制，copy，提供cpu級別的CAS樂觀鎖等操作。它的目的是為了增強java語言直接操作底層資源的能力，無疑帶來很多方便。但是，使用的同時就得額外小心！它的總體作用如下（圖片來源網(wǎng)絡(luò)）：

Unsafe位于sun.misc包下，jdk中的并發(fā)編程包juc(java.util.concurrent)基本全部靠Unsafe實現(xiàn)，由此可見其重要性。

Unsafe被設(shè)計為單例，并且只允許被引導類加載器（BootstrapClassLoader)加載的類使用：

public static void main(String[] args) throws Exception{
    // method 1
    Class unsafeClass = Unsafe.class;
    Constructor constructor = unsafeClass.getDeclaredConstructor();
    constructor.setAccessible(true);
    Unsafe unsafe1 = constructor.newInstance();
    System.out.println(unsafe1);

    // method2
    Field theUnsafe = unsafeClass.getDeclaredField("theUnsafe");
    theUnsafe.setAccessible(true);
    Unsafe unsafe2 = (Unsafe) theUnsafe.get(null);
    System.out.println(unsafe2);
}

CAS

CAS譯為Compare And Swap，它是樂觀鎖的一種實現(xiàn)。假設(shè)內(nèi)存值為v，預期值為e，想要更新成得值為u，當且僅當內(nèi)存值v等于預期值e時，才將v更新為u。 這樣可以有效避免多線程環(huán)境下的同步問題。

在unsafe中，實現(xiàn)CAS算法通過cpu的原子指令cmpxchg實現(xiàn)，它對應(yīng)的方法如下：

為了方便理解，舉個栗子。類User有一個成員變量name。我們new了一個對象User后，就知道了它在內(nèi)存中的起始值,而成員變量name在對象中的位置偏移是固定的。這樣通過這個起始值和這個偏移量就能夠定位到name在內(nèi)存中的具體位置。

所以我們現(xiàn)在的問題就是如何得出name在對象User中的偏移量，Unsafe自然也提供了相應(yīng)的方法：

public class UnsafeTest {
    public static void main(String[] args) throws Exception {
        Field theUnsafe = Unsafe.class.getDeclaredField("theUnsafe");
        theUnsafe.setAccessible(true);
        Unsafe unsafe = (Unsafe) theUnsafe.get(null);

        User user = new User("jsbintask");
        long nameOffset = unsafe.objectFieldOffset(User.class.getDeclaredField("name"));
        unsafe.compareAndSwapObject(user, nameOffset, "jsbintask1", "jsbintask2");
        System.out.println("第一次更新后的值：" + user.getName());
        unsafe.compareAndSwapObject(user, nameOffset, "jsbintask", "jsbintask2");
        System.out.println("第二次更新后的值：" + user.getName());
    }
}

class User {
    private String name;

    public User(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }
}

如果我們分析juc包下的Atomic開頭的原子類就會發(fā)現(xiàn)，它內(nèi)部的原子操作全部來源于unsafe的CAS方法，比如AtomicInteger的getAndIncrement方法，內(nèi)部直接調(diào)用unsafe的getAndAddInt方法，它的實現(xiàn)原理為：cas失敗，就循環(huán)，直到成功為止，這就是我們所說的自旋鎖！

內(nèi)存分配

Unsafe還給我們提供了直接分配內(nèi)存，釋放內(nèi)存，拷貝內(nèi)存，內(nèi)存設(shè)置等方法，值得注意的是，這里的內(nèi)存指的是堆外內(nèi)存！它是不受jvm內(nèi)存模型掌控的，所以使用需要及其小心：

//分配內(nèi)存, 相當于C++的malloc函數(shù)
public native long allocateMemory(long bytes);
//釋放內(nèi)存
public native void freeMemory(long address);
//在給定的內(nèi)存塊中設(shè)置值
public native void setMemory(Object o, long offset, long bytes, byte value);
//內(nèi)存拷貝
public native void copyMemory(Object srcBase, long srcOffset, Object destBase, long destOffset, long bytes);
//為給定地址設(shè)置值，忽略修飾限定符的訪問限制，與此類似操作還有: putInt,putDouble，putLong，putChar等
public native void putObject(Object o, long offset, Object x);

我們可以寫一段代碼驗證一下：

public static void main(String[] args) throws Exception {
    Field theUnsafe = Unsafe.class.getDeclaredField("theUnsafe");
    theUnsafe.setAccessible(true);
    Unsafe unsafe = (Unsafe) theUnsafe.get(null);

    // 分配 10M的堆外內(nèi)存
    long _10M_Address = unsafe.allocateMemory(1 * 1024 * 1024 * 10);
    // 將10M內(nèi)存的 前面1M內(nèi)存值設(shè)置為10
    unsafe.setMemory(_10M_Address, 1 * 1024 * 1024 * 1, (byte) 10);
    // 獲取第1M內(nèi)存的值： 10
    System.out.println(unsafe.getByte(_10M_Address + 1000));
    // 獲取第1M內(nèi)存后的值： 0（沒有設(shè)置）
    System.out.println(unsafe.getByte(_10M_Address + 1 * 1024 * 1024 * 5));
}

堆外內(nèi)存不受jvm內(nèi)存模型掌控，在nio（netty，mina）中大量使用對外內(nèi)存進行管道傳輸，copy等，使用它們的好處如下：

對垃圾回收停頓的改善。由于堆外內(nèi)存是直接受操作系統(tǒng)管理而不是JVM，所以當我們使用堆外內(nèi)存時，即可保持較小的堆內(nèi)內(nèi)存規(guī)模。從而在GC時減少回收停頓對于應(yīng)用的影響。

提升程序I/O操作的性能。通常在I/O通信過程中，會存在堆內(nèi)內(nèi)存到堆外內(nèi)存的數(shù)據(jù)拷貝操作，對于需要頻繁進行內(nèi)存間數(shù)據(jù)拷貝且生命周期較短的暫存數(shù)據(jù)，都建議存儲到堆外內(nèi)存。 而在jdk中，堆外內(nèi)存對應(yīng)的類為DirectByteBuffer，它內(nèi)部也是通過unsafe分配的內(nèi)存:

通過Unsafe還可以直接將某個線程掛起，這和調(diào)用Object.wait()方法作用是一樣的，但是效率確更高！

public static void main(String[] args) throws Exception {
    Field theUnsafe = Unsafe.class.getDeclaredField("theUnsafe");
    theUnsafe.setAccessible(true);
    Unsafe unsafe = (Unsafe) theUnsafe.get(null);

    Thread t1 = new Thread(() -> {
        for (int i = 0; i < 10; i++) {
            if (i == 5) {
                // i == 5時，將當前線程掛起
                unsafe.park(false, 0L);
            }
            System.out.println(Thread.currentThread().getName() + " printing i : " + i);
        }
    }, " Thread__Unsafe__1");

    t1.start();

    // 主線程休息三秒
    Thread.sleep(3000L);
    for (int i = 0; i < 10; i++) {
        System.out.println(Thread.currentThread().getName() + " printing i : " + i);
        if (i == 9) {
            // 將線程 t1 喚醒
            unsafe.unpark(t1);
        }
    }

    System.in.read();
}

數(shù)組操作

對于數(shù)組，Unsafe提供了特別的方法返回不同類型數(shù)組在內(nèi)存中的偏移量：

public static void main(String[] args) throws Exception{
    Class unsafeClass = Unsafe.class;
    Constructor constructor = unsafeClass.getDeclaredConstructor();
    constructor.setAccessible(true);
    Unsafe unsafe = constructor.newInstance();

    Integer[] integers = new Integer[10];
    // 打印數(shù)組的原始值
    System.out.println(Arrays.toString(integers));
    // 獲取Integer數(shù)組在內(nèi)存中的固定的偏移量
    long arrayBaseOffset = unsafe.arrayBaseOffset(Integer[].class);
    System.out.println(unsafe.arrayIndexScale(Integer[].class));
    System.out.println(unsafe.arrayIndexScale(double[].class));
    // 將數(shù)組中第一個元素的更新為100
    unsafe.putObject(integers, arrayBaseOffset, 100);
    // 將數(shù)組中第五個元素更新為50  注意 引用類型占用4個字節(jié)，所以內(nèi)存地址 需要 4 * 4 = 16
    unsafe.putObject(integers, arrayBaseOffset + 16, 50);
    // 打印更新后的值
    System.out.println(Arrays.toString(integers));
}

數(shù)組的原子操作，juc包也已經(jīng)提供了相應(yīng)的工具類，比如AtomicIntegerArray內(nèi)部就是同過Unsafe的上述方法實現(xiàn)了數(shù)組的原子操作。

其它操作

Unsafe還提供了操作系統(tǒng)級別的方法如獲取內(nèi)存頁的大小public native int pageSize();，獲取系統(tǒng)指針大小public native int addressSize(); jdk8還加入了新的方法，內(nèi)存屏障，它的目的是為了防止指令重排序（編譯器為了優(yōu)化速度，會在保證單線程不出錯的情況下將某些代碼的順序調(diào)換，比如先分配內(nèi)存，或者先返回引用等，這樣在多線程環(huán)境下就會出錯）：

//內(nèi)存屏障，禁止load操作重排序。屏障前的load操作不能被重排序到屏障后，屏障后的load操作不能被重排序到屏障前
public native void loadFence();
//內(nèi)存屏障，禁止store操作重排序。屏障前的store操作不能被重排序到屏障后，屏障后的store操作不能被重排序到屏障前
public native void storeFence();
//內(nèi)存屏障，禁止load、store操作重排序
public native void fullFence();

jdk1.8引入的StampedLock就是基于此實現(xiàn)的樂觀讀寫鎖. 另外，jdk1.8引入了lambda表達式，它其實會幫我們調(diào)用Unsafe的public native Class<");方法生成匿名內(nèi)部類，如下面的代碼：

public class UnsafeTest2 {
    public static void main(String[] args) {
        Function function = Integer::parseInt;
        System.out.println(function.apply("100"));
    }
}