本篇文章給大家分享的是有關(guān)Java中有哪些Unsafe類,小編覺得挺實用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
成都創(chuàng)新互聯(lián)公司擁有一支富有激情的企業(yè)網(wǎng)站制作團隊,在互聯(lián)網(wǎng)網(wǎng)站建設(shè)行業(yè)深耕十余年,專業(yè)且經(jīng)驗豐富。十余年網(wǎng)站優(yōu)化營銷經(jīng)驗,我們已為近1000家中小企業(yè)提供了成都網(wǎng)站設(shè)計、網(wǎng)站建設(shè)解決方案,按需制作,設(shè)計滿意,售后服務(wù)無憂。所有客戶皆提供一年免費網(wǎng)站維護!
1.Unsafe類介紹
Unsafe類是在sun.misc包下,不屬于Java標準。但是很多Java的基礎(chǔ)類庫,包括一些被廣泛使用的高性能開發(fā)庫都是基于Unsafe類開發(fā)的,比如Netty、Hadoop、Kafka等。
使用Unsafe可用來直接訪問系統(tǒng)內(nèi)存資源并進行自主管理,Unsafe類在提升Java運行效率,增強Java語言底層操作能力方面起了很大的作用。
Unsafe可認為是Java中留下的后門,提供了一些低層次操作,如直接內(nèi)存訪問、線程調(diào)度等。
官方并不建議使用Unsafe。
下面是使用Unsafe的一些例子。
1.1實例化私有類
import java.lang.reflect.Field; import sun.misc.Unsafe; public class UnsafePlayer { public static void main(String[] args) throws Exception { //通過反射實例化Unsafe Field f = Unsafe.class.getDeclaredField("theUnsafe"); f.setAccessible(true); Unsafe unsafe = (Unsafe) f.get(null); //實例化Player Player player = (Player) unsafe.allocateInstance(Player.class); player.setName("li lei"); System.out.println(player.getName()); } } class Player{ private String name; private Player(){} public String getName() { return name; } public void setName(String name) { this.name = name; } }
1.2CAS操作,通過內(nèi)存偏移地址修改變量值
java并發(fā)包中的SynchronousQueue中的TransferStack中使用CAS更新棧頂。
/ Unsafe mechanics private static final sun.misc.Unsafe UNSAFE; private static final long headOffset; static { try { UNSAFE = sun.misc.Unsafe.getUnsafe(); Class> k = TransferStack.class; headOffset = UNSAFE.objectFieldOffset (k.getDeclaredField("head")); } catch (Exception e) { throw new Error(e); } } //棧頂 volatile SNode head; //更新棧頂 boolean casHead(SNode h, SNode nh) { return h == head && UNSAFE.compareAndSwapObject(this, headOffset, h, nh); }
1.3直接內(nèi)存訪問
Unsafe的直接內(nèi)存訪問:用Unsafe開辟的內(nèi)存空間不占用Heap空間,當然也不具有自動內(nèi)存回收功能。做到像C一樣自由利用系統(tǒng)內(nèi)存資源。
2.Unsafe類源碼分析
Unsafe的大部分API都是native的方法,主要包括以下幾類:
1)Class相關(guān)。主要提供Class和它的靜態(tài)字段的操作方法。
2)Object相關(guān)。主要提供Object和它的字段的操作方法。
3)Arrray相關(guān)。主要提供數(shù)組及其中元素的操作方法。
4)并發(fā)相關(guān)。主要提供低級別同步原語,如CAS、線程調(diào)度、volatile、內(nèi)存屏障等。
5)Memory相關(guān)。提供了直接內(nèi)存訪問方法(繞過Java堆直接操作本地內(nèi)存),可做到像C一樣自由利用系統(tǒng)內(nèi)存資源。
6)系統(tǒng)相關(guān)。主要返回某些低級別的內(nèi)存信息,如地址大小、內(nèi)存頁大小。
2.1Class相關(guān)
//靜態(tài)屬性的偏移量,用于在對應(yīng)的Class對象中讀寫靜態(tài)屬性 public native long staticFieldOffset(Field f); public native Object staticFieldBase(Field f); //判斷是否需要初始化一個類 public native boolean shouldBeInitialized(Class> c); //確保類被初始化 public native void ensureClassInitialized(Class> c); //定義一個類,可用于動態(tài)創(chuàng)建類 public native Class> defineClass(String name, byte[] b, int off, int len, ClassLoader loader, ProtectionDomain protectionDomain); //定義一個匿名類,可用于動態(tài)創(chuàng)建類 public native Class> defineAnonymousClass(Class> hostClass, byte[] data, Object[] cpPatches);
2.2Object相關(guān)
Java中的基本類型(boolean、byte、char、short、int、long、float、double)及對象引用類型都有以下方法。
//獲得對象的字段偏移量 public native long objectFieldOffset(Field f); //獲得給定對象地址偏移量的int值 public native int getInt(Object o, long offset); //設(shè)置給定對象地址偏移量的int值 public native void putInt(Object o, long offset, int x);
//創(chuàng)建對象,但并不會調(diào)用其構(gòu)造方法。如果類未被初始化,將初始化類。 public native Object allocateInstance(Class> cls) throws InstantiationException;
2.3數(shù)組相關(guān)
/** * Report the offset of the first element in the storage allocation of a * given array class. If {@link #arrayIndexScale} returns a non-zero value * for the same class, you may use that scale factor, together with this * base offset, to form new offsets to access elements of arrays of the * given class. * * @see #getInt(Object, long) * @see #putInt(Object, long, int) */ //返回數(shù)組中第一個元素的偏移地址 public native int arrayBaseOffset(Class> arrayClass); //boolean、byte、short、char、int、long、float、double,及對象類型均有以下方法 /** The value of {@code arrayBaseOffset(boolean[].class)} */ public static final int ARRAY_BOOLEAN_BASE_OFFSET = theUnsafe.arrayBaseOffset(boolean[].class); /** * Report the scale factor for addressing elements in the storage * allocation of a given array class. However, arrays of "narrow" types * will generally not work properly with accessors like {@link * #getByte(Object, int)}, so the scale factor for such classes is reported * as zero. * * @see #arrayBaseOffset * @see #getInt(Object, long) * @see #putInt(Object, long, int) */ //返回數(shù)組中每一個元素占用的大小 public native int arrayIndexScale(Class> arrayClass); //boolean、byte、short、char、int、long、float、double,及對象類型均有以下方法 /** The value of {@code arrayIndexScale(boolean[].class)} */ public static final int ARRAY_BOOLEAN_INDEX_SCALE = theUnsafe.arrayIndexScale(boolean[].class);
通過arrayBaseOffset和arrayIndexScale可定位數(shù)組中每個元素在內(nèi)存中的位置。
2.4并發(fā)相關(guān)
2.4.1CAS相關(guān)
CAS:CompareAndSwap,內(nèi)存偏移地址offset,預(yù)期值expected,新值x。如果變量在當前時刻的值和預(yù)期值expected相等,嘗試將變量的值更新為x。如果更新成功,返回true;否則,返回false。
//更新變量值為x,如果當前值為expected //o:對象 offset:偏移量 expected:期望值 x:新值 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);
從Java 8開始,Unsafe中提供了以下方法:
//增加 public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v = getIntVolatile(o, offset); } while (!compareAndSwapInt(o, offset, v, v + delta)); return v; } public final long getAndAddLong(Object o, long offset, long delta) { long v; do { v = getLongVolatile(o, offset); } while (!compareAndSwapLong(o, offset, v, v + delta)); return v; } //設(shè)置 public final int getAndSetInt(Object o, long offset, int newValue) { int v; do { v = getIntVolatile(o, offset); } while (!compareAndSwapInt(o, offset, v, newValue)); return v; } public final long getAndSetLong(Object o, long offset, long newValue) { long v; do { v = getLongVolatile(o, offset); } while (!compareAndSwapLong(o, offset, v, newValue)); return v; } public final Object getAndSetObject(Object o, long offset, Object newValue) { Object v; do { v = getObjectVolatile(o, offset); } while (!compareAndSwapObject(o, offset, v, newValue)); return v;
2.4.2線程調(diào)度相關(guān)
//取消阻塞線程 public native void unpark(Object thread); //阻塞線程 public native void park(boolean isAbsolute, long time); //獲得對象鎖 public native void monitorEnter(Object o); //釋放對象鎖 public native void monitorExit(Object o); //嘗試獲取對象鎖,返回true或false表示是否獲取成功 public native boolean tryMonitorEnter(Object o);
2.4.3volatile相關(guān)讀寫
Java中的基本類型(boolean、byte、char、short、int、long、float、double)及對象引用類型都有以下方法。
//從對象的指定偏移量處獲取變量的引用,使用volatile的加載語義 //相當于getObject(Object, long)的volatile版本 public native Object getObjectVolatile(Object o, long offset); //存儲變量的引用到對象的指定的偏移量處,使用volatile的存儲語義 //相當于putObject(Object, long, Object)的volatile版本 public native void putObjectVolatile(Object o, long offset, Object x);
/** * Version of {@link #putObjectVolatile(Object, long, Object)} * that does not guarantee immediate visibility of the store to * other threads. This method is generally only useful if the * underlying field is a Java volatile (or if an array cell, one * that is otherwise only accessed using volatile accesses). */ public native void putOrderedObject(Object o, long offset, Object x); /** Ordered/Lazy version of {@link #putIntVolatile(Object, long, int)} */ public native void putOrderedInt(Object o, long offset, int x); /** Ordered/Lazy version of {@link #putLongVolatile(Object, long, long)} */ public native void putOrderedLong(Object o, long offset, long x);
2.4.4內(nèi)存屏障相關(guān)
Java 8引入 ,用于定義內(nèi)存屏障,避免代碼重排序。
//內(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();
2.5直接內(nèi)存訪問(非堆內(nèi)存)
allocateMemory所分配的內(nèi)存需要手動free(不被GC回收)
//(boolean、byte、char、short、int、long、float、double)都有以下get、put兩個方法。 //獲得給定地址上的int值 public native int getInt(long address); //設(shè)置給定地址上的int值 public native void putInt(long address, int x); //獲得本地指針 public native long getAddress(long address); //存儲本地指針到給定的內(nèi)存地址 public native void putAddress(long address, long x); //分配內(nèi)存 public native long allocateMemory(long bytes); //重新分配內(nèi)存 public native long reallocateMemory(long address, long bytes); //初始化內(nèi)存內(nèi)容 public native void setMemory(Object o, long offset, long bytes, byte value); //初始化內(nèi)存內(nèi)容 public void setMemory(long address, long bytes, byte value) { setMemory(null, address, bytes, value); } //內(nèi)存內(nèi)容拷貝 public native void copyMemory(Object srcBase, long srcOffset, Object destBase, long destOffset, long bytes); //內(nèi)存內(nèi)容拷貝 public void copyMemory(long srcAddress, long destAddress, long bytes) { copyMemory(null, srcAddress, null, destAddress, bytes); } //釋放內(nèi)存 public native void freeMemory(long address);
2.6系統(tǒng)相關(guān)
//返回指針的大小。返回值為4或8。 public native int addressSize(); /** The value of {@code addressSize()} */ public static final int ADDRESS_SIZE = theUnsafe.addressSize(); //內(nèi)存頁的大小。 public native int pageSize();
以上就是Java中有哪些Unsafe類,小編相信有部分知識點可能是我們?nèi)粘9ぷ鲿姷交蛴玫降摹OM隳芡ㄟ^這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。