## 前言 C++可以動態的分類記憶體(但是得主動釋放記憶體,避免記憶體泄漏),而java並不能這樣,java的記憶體分配和垃圾回收統一由JVM管理,是不是java就不能操作記憶體呢?當然有其他辦法可以操作記憶體,接下來有請`Unsafe`出場,我們一起看看`Unsafe`是如何花式操作記憶體的。 ## Unsa ...
前言
C++可以動態的分類記憶體(但是得主動釋放記憶體,避免記憶體泄漏),而java並不能這樣,java的記憶體分配和垃圾回收統一由JVM管理,是不是java就不能操作記憶體呢?當然有其他辦法可以操作記憶體,接下來有請Unsafe
出場,我們一起看看Unsafe
是如何花式操作記憶體的。
Unsafe介紹
Unsafe
見名知意,不安全的意思,因為通過這個類可以繞過JVM的管理直接去操作記憶體,如果操作不當或者使用完成後沒有及時釋放的話,這部分的記憶體不會被回收,久而久之,這種沒有被釋放的記憶體會越來越多造成記憶體泄漏。所以這是一個比較不安全的操作,一般不建議直接使用,畢竟這種問題導致的線上問題很難查出,另外通常的解決辦法就是重啟系統了。
雖然Unsafe
是不安全的操作,但可以根據實際情況合理使用可以達到更好的效果,比如像java NIO里就有通過這種方式創建堆外存。Unsafe
常用的操作包括:分配記憶體釋放記憶體、實例化及對象操作、數組操作、CAS、線程同步等。
Unsafe實例對象的獲取
Unsafe不能直接獲取到,像下麵這樣使用會直接拋出安全檢查異常。
public static void main(String[] args) throws Exception {
Unsafe unsafe = Unsafe.getUnsafe();
}
運行結果就這樣:
Exception in thread "main" java.lang.SecurityException: Unsafe
at sun.misc.Unsafe.getUnsafe(Unsafe.java:90)
at com.star95.study.UnsafeTest.main(UnsafeTest.java:21)
我們來看看sun.misc.Unsafe.getUnsafe
這個方法的源碼:
public static Unsafe getUnsafe() {
Class var0 = Reflection.getCallerClass();
if (!VM.isSystemDomainLoader(var0.getClassLoader())) {
throw new SecurityException("Unsafe");
} else {
return theUnsafe;
}
}
這裡會判斷這個類的載入器是否是啟用類載入器Bootstrap ClassLoader
,如果不是啟動類載入器載入的則拋異常。
Bootstrap ClassLoader
這個類載入器主要載入java核心類庫,比如rt.jar這類包的,java採用的是雙親委托方式載入類,如果父載入器已載入了某個類,則子載入器不再載入,採用這樣的方式進一步加強安全性。關於啟動類載入器Bootstrap ClassLoader
、擴展類載入器Extension Classloader
、應用程式類載入器Application Classloader
這裡不再介紹,感興趣的可自行搜索。
以下介紹3種方法來獲取Unsafe
。
1、修改啟動類載入器的搜索路徑
public class UnsafeUtil {
private UnsafeUtil() {}
public static Unsafe getUnsafe() {
System.out.println("get getUnsafe...");
return Unsafe.getUnsafe();
}
}
就這一個類,打成一個jar包。
把這個jar包的路徑放到jvm啟動參數里-Xbootclasspath/a:D:\work\projects\test\unsafe\target\unsafe-1.0-SNAPSHOT.jar
,然後調用即可獲取到Unsafe
。
關於jvm參數-Xbootclasspath
說明:
-Xbootclasspath:新jar路徑(Windows用;分隔,linux用:分隔),這種相當於覆蓋了java預設的核心類搜索路徑,包括核心類庫例如rt.jar,這種基本不用。
-Xbootclasspath/a:新jar路徑(Windows用;分隔,linux用:分隔),這種是把新jar路徑追加到已有的classpath後,相當於擴大了核心類的範圍,這個常用。
-Xbootclasspath/p:新jar路徑(Windows用;分隔,linux用:分隔),這種是把新jar路徑追加到已有的classpath前,也相當於擴大了核心類的範圍,但是放到核心類前可能會引起衝突,這個不常用。
2、利用反射使用構造方法創建實例
Unsafe
有一個私有的無參構造方法,利用反射使用構造方法也可以創建Unsafe
實例。
Constructor constructor = Unsafe.class.getDeclaredConstructors()[0];
constructor.setAccessible(true);
Unsafe unsafe = (Unsafe)constructor.newInstance();
System.out.println(unsafe);
3、利用反射獲取Unsafe屬性創建實例
Unsafe
類里有一個屬性private static final Unsafe theUnsafe;
利用反射獲取到這個屬性然後對null
這個對象獲取屬性值就會觸發類靜態塊兒的執行,從而達到實例化的目的。
private static Unsafe getUnsafe() {
try {
Field field = Unsafe.class.getDeclaredField("theUnsafe");
field.setAccessible(true);
return (Unsafe)field.get(null);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
以上3種方法雖然都可以獲取到Unsafe
的實例,但第三種更常用一些。
Unsafe常用操作
Unsafe類里大概有100多個方法,按用途主要分為以下幾大類,分別介紹。
Unsafe操作記憶體
記憶體操作主要包括記憶體分配、擴展記憶體、設置記憶體值、釋放記憶體等,常用的方法介紹如下。
//分配指定大小的記憶體
public long allocateMemory(long bytes)
//根據給定的記憶體地址address調整記憶體大小
public long reallocateMemory(long address, long bytes)
//設置記憶體值
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)
//釋放allocateMemory和reallocateMemory申請的記憶體
public native void freeMemory(long address)
舉個慄子:
public void test() throws Exception {
Unsafe unsafe = getUnsafe();
long address = unsafe.allocateMemory(8);
System.out.println("allocate memory with 8 bytes, address=" + address);
long data = 13579L;
unsafe.putLong(address, data);
System.out.println("direct put data to address, data=" + data);
System.out.println("get address data=" + unsafe.getLong(address));
long address1 = unsafe.allocateMemory(8);
System.out.println("allocate memory with 8 bytes, address1=" + address);
unsafe.copyMemory(address, address1, 8);
System.out.println("copy memory with 8 bytes to address1=" + address1);
System.out.println("get address1 data=" + unsafe.getLong(address1));
unsafe.reallocateMemory(address1, 16);
unsafe.setMemory(address1, 16, (byte)20);
System.out.println("after setMemory address1=" + unsafe.getByte(address1));
unsafe.freeMemory(address1);
unsafe.freeMemory(address);
System.out.println("free memory over");
long[] l1 = new long[] {11, 22, 33, 44};
long[] l2 = new long[4];
long offset = unsafe.arrayBaseOffset(long[].class);
unsafe.copyMemory(l1, offset, l2, offset, 32);
System.out.println("l2=" + Arrays.toString(l2));
}
輸出結果:
allocate memory with 8 bytes, address=510790256
direct put data to address, data=13579
get address data=13579
allocate memory with 8 bytes, address1=510790256
copy memory with 8 bytes to address1=510788736
get address1 data=13579
after setMemory address1=20
free memory over
l2=[11, 22, 33, 44]
Unsafe操作類、對象及變數
下麵介紹關於類、對象及變數相關的一些操作,還有一些其他的方法沒有一一列出,大家可以自行研究。
//實例化對象,不調構造方法
Object allocateInstance(Class<?> cls)
//欄位在記憶體中的地址相對於實例對象記憶體地址的偏移量
public long objectFieldOffset(Field f)
//欄位在記憶體中的地址相對於class記憶體地址的偏移量
public long objectFieldOffset(Class<?> c, String name)
//靜態欄位在class對象中的偏移
public long staticFieldOffset(Field f)
//獲得靜態欄位所對應類對象
public Object staticFieldBase(Field f)
//獲取對象中指定偏移量的int值,這裡還有基本類型的其他其中,比如char,boolean,long等
public native int getInt(Object o, long offset);
//將int值放入指定對象指定偏移量的位置,這裡還有基本類型的其他其中,比如char,boolean,long等
public native void putInt(Object o, long offset, int x);
//獲取obj對象指定offset的屬性對象
public native Object getObject(Object obj, long offset);
//將newObj對象放入指定obj對象指定offset偏移量的位置
public native void putObject(Object obj, long offset, Object newObj);
實戰一下吧
class Cat {
private String name;
private long speed;
public Cat(String name, long speed) {
this.name = name;
this.speed = speed;
}
public Cat() {
System.out.println("constructor...");
}
static {
System.out.println("static...");
}
@Override
public String toString() {
return "Cat{" + "name='" + name + '\'' + ", speed=" + speed + '}';
}
}
class Foo {
private int age;
private Cat cat;
private static String defaultString = "default........";
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public Cat getCat() {
return cat;
}
public void setCat(Cat cat) {
this.cat = cat;
}
}
//測試方法
public void test1() throws Exception {
// 使用allocateInstance方法創建一個Cat實例,這裡不會調用構造方法,但是靜態塊會執行,所以會輸出"static..."
Cat cat = (Cat)unsafe.allocateInstance(Cat.class);
System.out.println("allocateInstance cat--->" + cat);
Foo f = new Foo();
f.setAge(13);
f.setCat(new Cat("ketty", 120));
long ageOffset = unsafe.objectFieldOffset(Foo.class.getDeclaredField("age"));
// 這個offset的屬性是一個Cat對象
long catOffset = unsafe.objectFieldOffset(Foo.class.getDeclaredField("cat"));
// 獲取靜態屬性的時候直接用Class對象,用實例對象的話會發生NPE異常
long defaultStringOffset = unsafe.staticFieldOffset(Foo.class.getDeclaredField("defaultString"));
System.out.println("get age=" + unsafe.getInt(f, ageOffset));
System.out.println("get cat=" + unsafe.getObject(f, catOffset));
System.out.println("get defaultString=" + unsafe.getObject(Foo.class, defaultStringOffset));
System.out.println("---------------------");
// 操作記憶體放入新值
unsafe.putInt(f, ageOffset, 100);
unsafe.putObject(f, catOffset, new Cat("hello", 333));
unsafe.putObject(f, defaultStringOffset, "new default string");
System.out.println("after put then get age=" + unsafe.getInt(f, ageOffset));
System.out.println("after put then get cat=" + unsafe.getObject(f, catOffset));
System.out.println("after put then get defaultString=" + unsafe.getObject(f, defaultStringOffset));
System.out.println("---------------------");
}
程式輸出如下:
static...
allocateInstance cat--->Cat{name='null', speed=0}
get age=13
get cat=Cat{name='ketty', speed=120}
get defaultString=default........
---------------------
after put then get age=100
after put then get cat=Cat{name='hello', speed=333}
after put then get defaultString=new default string
---------------------
Unsafe操作數組
數組除了8種基本類型外,還包括Object數組。在Unsafe
類里是通過靜態塊來獲取這些數據。
public void test2() {
// 獲取8種基本類型和Object類型數組的基礎偏移量,scale相關的可以理解每個類型對應的值所占的大小
// 通過輸出信息我們可以看到基礎偏移量都是16,scale除Object的是4外,基礎數據類型的scale就是相應的位元組大小
System.out.println("Unsafe.ARRAY_BOOLEAN_BASE_OFFSET=" + Unsafe.ARRAY_BOOLEAN_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_BOOLEAN_INDEX_SCALE=" + Unsafe.ARRAY_BOOLEAN_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_BYTE_BASE_OFFSET=" + Unsafe.ARRAY_BYTE_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_BYTE_INDEX_SCALE=" + Unsafe.ARRAY_BYTE_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_SHORT_BASE_OFFSET=" + Unsafe.ARRAY_SHORT_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_SHORT_INDEX_SCALE=" + Unsafe.ARRAY_SHORT_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_CHAR_BASE_OFFSET=" + Unsafe.ARRAY_CHAR_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_CHAR_INDEX_SCALE=" + Unsafe.ARRAY_CHAR_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_INT_BASE_OFFSET=" + Unsafe.ARRAY_INT_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_INT_INDEX_SCALE=" + Unsafe.ARRAY_INT_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_LONG_BASE_OFFSET=" + Unsafe.ARRAY_LONG_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_LONG_INDEX_SCALE=" + Unsafe.ARRAY_LONG_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_FLOAT_BASE_OFFSET=" + Unsafe.ARRAY_FLOAT_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_FLOAT_INDEX_SCALE=" + Unsafe.ARRAY_FLOAT_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_DOUBLE_BASE_OFFSET=" + Unsafe.ARRAY_DOUBLE_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_DOUBLE_INDEX_SCALE=" + Unsafe.ARRAY_DOUBLE_INDEX_SCALE);
System.out.println("Unsafe.ARRAY_OBJECT_BASE_OFFSET=" + Unsafe.ARRAY_OBJECT_BASE_OFFSET);
System.out.println("Unsafe.ARRAY_OBJECT_INDEX_SCALE=" + Unsafe.ARRAY_OBJECT_INDEX_SCALE);
System.out.println("------------------------------");
// 基本數據數組類型操作
int[] array = new int[] {11, 22, 33};
/*
改變最後一個元素的值,地址的演算法就是:基礎地址+偏移量,這個偏移量就是類型占用的大小*位置,Unsafe.ARRAY_INT_BASE_OFFSET + (array.length - 1) * Unsafe.ARRAY_INT_INDEX_SCALE
*/
System.out.println("before put array[2]=" + array[2]);
unsafe.putInt(array, (long)Unsafe.ARRAY_INT_BASE_OFFSET + (array.length - 1) * Unsafe.ARRAY_INT_INDEX_SCALE,
100);
// 獲取最後一個元素的值
System.out.println("after put array[2]=" + array[2]);
// 也可以這麼獲取,使用基礎地址+偏移量的方式
System.out.println("after put array[2]=" + unsafe.getInt(array,
(long)Unsafe.ARRAY_INT_BASE_OFFSET + (array.length - 1) * Unsafe.ARRAY_INT_INDEX_SCALE));
System.out.println("-------------------");
// Object類型數組操作
Cat[] cats = {new Cat("cat1", 1), new Cat("cat2", 2), new Cat("cat3", 3)};
System.out.println("before put cats[2]=" + cats[2]);
unsafe.putObject(cats,
(long)Unsafe.ARRAY_OBJECT_BASE_OFFSET + (cats.length - 1) * Unsafe.ARRAY_OBJECT_INDEX_SCALE,
new Cat("newcat", 10000));
// 獲取最後一個元素的值
System.out.println("after put cats[2]=" + cats[2]);
// 也可以這麼獲取,使用基礎地址+偏移量的方式
System.out.println("after put cats[2]=" + unsafe.getObject(cats,
(long)Unsafe.ARRAY_OBJECT_BASE_OFFSET + (cats.length - 1) * Unsafe.ARRAY_OBJECT_INDEX_SCALE));
System.out.println("-------------------");
}
輸出:
Unsafe.ARRAY_BOOLEAN_BASE_OFFSET=16
Unsafe.ARRAY_BOOLEAN_INDEX_SCALE=1
Unsafe.ARRAY_BYTE_BASE_OFFSET=16
Unsafe.ARRAY_BYTE_INDEX_SCALE=1
Unsafe.ARRAY_SHORT_BASE_OFFSET=16
Unsafe.ARRAY_SHORT_INDEX_SCALE=2
Unsafe.ARRAY_CHAR_BASE_OFFSET=16
Unsafe.ARRAY_CHAR_INDEX_SCALE=2
Unsafe.ARRAY_INT_BASE_OFFSET=16
Unsafe.ARRAY_INT_INDEX_SCALE=4
Unsafe.ARRAY_LONG_BASE_OFFSET=16
Unsafe.ARRAY_LONG_INDEX_SCALE=8
Unsafe.ARRAY_FLOAT_BASE_OFFSET=16
Unsafe.ARRAY_FLOAT_INDEX_SCALE=4
Unsafe.ARRAY_DOUBLE_BASE_OFFSET=16
Unsafe.ARRAY_DOUBLE_INDEX_SCALE=8
Unsafe.ARRAY_OBJECT_BASE_OFFSET=16
Unsafe.ARRAY_OBJECT_INDEX_SCALE=4
------------------------------
before put array[2]=33
after put array[2]=100
after put array[2]=100
-------------------
static...
before put cats[2]=Cat{name='cat3', speed=3}
after put cats[2]=Cat{name='newcat', speed=10000}
after put cats[2]=Cat{name='newcat', speed=10000}
-------------------
Tips:
如果操作的元素位置沒有在數組範圍內的話,put和get操作不會異常,都會成功,因為這是記憶體操作,使用的是基礎地址+偏移量,但是並沒有改變原始數組的大小,put後可以獲取相應位置的記憶體數據,在沒有put前調用get則獲取的是數據類型的預設值。
CAS
比較並交換(Compare And Swap),在jvm里是一個原子操作,先獲取記憶體的值,然後判斷記憶體值和預期值是否相同,相同則更新為新值表示操作成功,不同則直接返回false,表明操作失敗。java里的JUC包下很多隊列或者鎖都採用了這種實現方式。
//每次都從主記憶體獲取var1對象var2偏移量的long值
public native long getLongVolatile(Object var1, long var2);
//將var4值放入指定var1對象的var2偏移量位置,直接刷新到主記憶體
public native void putLongVolatile(Object var1, long var2, long var4);
// 比較並替換原值為新值,操作成功返回true否則false,var1是指定對象,var2是偏移量地址,var4是預期的原值,var5是要更新的新值
public final native boolean compareAndSwapLong(Object var1, long var2, long var4, long var6);
// 自旋獲取原值並增加數值,var1是指定對象,var2是偏移量地址,var4是要增加的值
public final int getAndAddLong(Object var1, long var2, long var4) {
int var5;
do {
var5 = this.getLongVolatile(var1, var2);
} while(!this.compareAndSwapLong(var1, var2, var5, var5 + var4));
return var5;
}
// 自旋獲取原值並設置新值,var1是指定對象,var2是偏移量地址,var4是要設置的新值
public final int getAndSetLong(Object var1, long var2, long var4) {
int var5;
do {
var5 = this.getIntVolatile(var1, var2);
} while(!this.compareAndSwapLong(var1, var2, var5, var4));
return var5;
}
// 還有Object相關的cas操作這裡沒有列出
舉幾個慄子
public void test3() throws Exception {
Cat cat = new Cat("Kitty", 1000);
long speedOffset = unsafe.objectFieldOffset(Cat.class.getDeclaredField("speed"));
System.out.println("before putLongVolatile,getLongVolatile=" + unsafe.getLongVolatile(cat, speedOffset));
// 設置speed的值為2000
unsafe.putLongVolatile(cat, speedOffset, 2000);
System.out.println("after putLongVolatile,getLongVolatile=" + unsafe.getLongVolatile(cat, speedOffset));
// 到這裡speed的值是2000,但是compareAndSwapLong里預期的值是3000,所以cas失敗,返回false
System.out.println("compareAndSwapLong result:" + unsafe.compareAndSwapLong(cat, speedOffset, 3000, 4000));
// 到這裡speed的值是2000,但是compareAndSwapLong里預期的值是2000,cas更新成功,返回true
System.out.println("compareAndSwapLong result:" + unsafe.compareAndSwapLong(cat, speedOffset, 2000, 4000));
// cas後speed的值就是4000了
System.out.println("after compareAndSwapLong,getLongVolatile=" + unsafe.getLongVolatile(cat, speedOffset));
// getAndAddLong會返回原值4000,新值=原值+10
System.out.println("getAndAddLong:" + unsafe.getAndAddLong(cat, speedOffset, 10));
// getAndAddLong後speed新值是4010
System.out.println("after getAndAddLong,getLongVolatile=" + unsafe.getLongVolatile(cat, speedOffset));
// getAndSetLong會返回原值4010,新值=要設置的新值1000
System.out.println("getAndSetLong:" + unsafe.getAndSetLong(cat, speedOffset, 1000));
// getAndSetLong後speed新值是1000
System.out.println("after getAndSetLong,getLongVolatile=" + unsafe.getLongVolatile(cat, speedOffset));
}
輸出結果:
static...
before putLongVolatile,getLongVolatile=1000
after putLongVolatile,getLongVolatile=2000
compareAndSwapLong result:false
compareAndSwapLong result:true
after compareAndSwapLong,getLongVolatile=4000
getAndAddLong:4000
after getAndAddLong,getLongVolatile=4010
getAndSetLong:4010
after getAndSetLong,getLongVolatile=1000
線程調度及同步
// 釋放線程讓其繼續執行,多次調用只會生效一次,可以在park前調用
public native void unpark(Object thread);
// 阻塞線程,isAbsolute為true:表示絕對時間,time的單位是毫秒ms,false:表示相對時間,time的單位是納秒級的時間
public native void park(boolean isAbsolute, long time);
//以下3個方法均標註過期了,建議使用其他同步方法
// 獲取var1的對象鎖,沒獲取到則阻塞等待
public native void monitorEnter(Object var1);
// 嘗試獲取var1的對象鎖,不阻塞,獲取到則返回true,沒獲取到返回false
public native boolean tryMonitorEnter(Object var1);
// 釋放var1對象鎖
public native void monitorExit(Object var1);
我們先看看monitor同步相關的測試:
public void test4() {
Object obj = new Object();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " isrunning...");
unsafe.monitorEnter(obj);
System.out.println(Thread.currentThread().getName() + " got monitorEnter...");
Thread.sleep(3000);
System.out.println(Thread.currentThread().getName() + " business over...");
} catch (Exception e) {
e.printStackTrace();
} finally {
unsafe.monitorExit(obj);
System.out.println(Thread.currentThread().getName() + " monitorExit...");
}
}
});
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " isrunning...");
unsafe.monitorEnter(obj);
System.out.println(Thread.currentThread().getName() + " got monitorEnter...");
Thread.sleep(2000);
System.out.println(Thread.currentThread().getName() + " business over...");
} catch (Exception e) {
e.printStackTrace();
} finally {
unsafe.monitorExit(obj);
System.out.println(Thread.currentThread().getName() + " monitorExit...");
}
}
});
Thread t3 = new Thread(new Runnable() {
@Override
public void run() {
boolean flag = false;
try {
System.out.println(Thread.currentThread().getName() + " isrunning...");
flag = unsafe.tryMonitorEnter(obj);
System.out.println(Thread.currentThread().getName() + " tryMonitorEnter:" + flag);
} catch (Exception e) {
e.printStackTrace();
} finally {
if (flag) {
unsafe.monitorExit(obj);
System.out.println(Thread.currentThread().getName() + " monitorExit...");
}
}
System.out.println(Thread.currentThread().getName() + " over...");
}
});
t1.start();
t2.start();
t3.start();
}
可能的一種輸出如下(線程是根據系統分配資源調度的,輸出先後順序會有多種),下麵的這個輸出我們可以看到先輸出3個線程都啟動了,Thread-2嘗試獲取鎖失敗就結束了,然後Thread-0競爭到了對象鎖,等Thread-0線程運行完畢釋放了鎖,Thread-1才會獲取到鎖繼續執行直到結束釋放鎖。
Tips:
monitor相關的方法已經加了@deprecated註解,官方已經不再建議使用,可以換成其他鎖或者同步方式
Thread-0 isrunning...
Thread-2 isrunning...
Thread-2 tryMonitorEnter:false
Thread-2 over...
Thread-1 isrunning...
Thread-0 got monitorEnter...
Thread-0 business over...
Thread-0 monitorExit...
Thread-1 got monitorEnter...
Thread-1 business over...
Thread-1 monitorExit...
我們在來看看park、unpark相關的使用
public void test5() throws Exception {
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
System.out
.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName() + " is running...");
// 這裡讓當前線程阻塞6s,註意:如果park第一個參數是true的話,表示絕對時間,這個時間是毫秒級的,也就是系統時間,系統到這個絕對時間後才喚醒執行
unsafe.park(true, System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(6));
System.out
.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName() + " continue...");
// 這裡讓當前線程阻塞3s,註意:如果park第一個參數是false的話,這個是納秒級別的時間,表示相對當前時間3s後繼續喚醒執行
unsafe.park(false, TimeUnit.SECONDS.toNanos(3));
System.out
.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName() + " continue...");
// 如果park的第一個參數是false,第二個值是0,則會一直等待,直到其他線程調用了unpark這個線程才會結束阻塞
// 一般像這種無限期等待的調了多少次park(false, 0)就要對於調同樣次數的unpark才會完全解除阻塞
unsafe.park(false, 0);
}
輸出:
2020-05-11 08:01:04 main is running...
2020-05-11 08:01:10 main continue...
2020-05-11 08:01:13 main continue...
再看一個案例:
public void test6() throws Exception {
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName()
+ " is running...");
// 這裡讓當前線程阻塞600s也就是10分鐘,註意:如果park第一個參數是true的話,表示絕對時間,這個時間是毫秒級的,也就是系統時間,系統到這個絕對時間後才喚醒執行
unsafe.park(true, System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(600));
System.out.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName()
+ " continue...");
} catch (Exception e) {
e.printStackTrace();
}
}
});
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName()
+ " is running...");
// 這裡讓當前線程阻塞600s也就是10分鐘,註意:如果park第一個參數是true的話,表示絕對時間,這個時間是毫秒級的,也就是系統時間,系統到這個絕對時間後才喚醒執行
unsafe.park(true, System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(600));
// unsafe.park(true, System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(600));
System.out.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName()
+ " continue...");
} catch (Exception e) {
e.printStackTrace();
}
}
});
t1.start();
t2.start();
// 主線程休眠2秒
Thread.sleep(2000);
System.out
.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName() + " is running...");
// 這裡調了unpark方法,參數就是t1線程,unsafe.unpark喚醒了t1線程,使得t1線程不用等到10分鐘立馬就可以執行
unsafe.unpark(t1);
// 下麵連續調用了兩次unpark t2線程,但是結果只釋放了一次令牌,如果把t2線程的unsafe.park註釋去掉,那麼t2線程會一直等到park的時間到後被喚醒執行,
unsafe.unpark(t2);
unsafe.unpark(t2);
System.out.println(LocalDateTime.now().format(formatter) + " " + Thread.currentThread().getName() + " over...");
}
輸出如下:
2020-05-11 08:05:26 Thread-1 is running...
2020-05-11 08:05:26 Thread-0 is running...
2020-05-11 08:05:28 main is running...
2020-05-11 08:05:28 main over...
2020-05-11 08:05:28 Thread-1 continue...
2020-05-11 08:05:28 Thread-0 continue...
unsafe的park和unpark在JUC併發包下使用的特別多,後續再介紹吧
記憶體屏障
這個我沒有深入的瞭解,網上找了些資料看了看,沒有具體的實踐過,大家可以瞭解下。
loadFence:保證在這個屏障之前的所有讀操作都已經完成。
storeFence:保證在這個屏障之前的所有寫操作都已經完成。
fullFence:保證在這個屏障之前的所有讀寫操作都已經完成。
其他
類載入,類實例化相關的一些方法,還有其他的方法,這裡不再一一說明,雖然不常用,但是瞭解其運行原理,或者去研究一下jvm的源碼對自己都是一種提升。
再見
好了,就胡扯到這裡吧,文章里的都是個人理解和實踐,難免會有理解錯誤和實踐錯誤的,請各位看官多多指正。