Java的WeakHashMap源碼解析及使用場景詳解
WeakHashMap
目的
讓Map中不再使用的Entry被GC及時回收,釋放內(nèi)存空間
應(yīng)用場景-緩存
應(yīng)用場景:Map本身生命周期很長,需要長期貯留內(nèi)存中,但Map中的Entry可以刪除,使用時可以從其它地方再次取得。
實例:tomcat中的緩存有用到。
源碼解析
先理解HashMap源碼
以及WeakReference:弱引用WeakReference所引用的對象的回收規(guī)則
WeahHashMap與HashMap在代碼實現(xiàn)上的不同點:
- WeahHashMap類的 Entry<K, V> 繼承了 WeakReference,并設(shè)置 referent = key。
- WeakHashMap類內(nèi)定義了一個ReferenceQueue refQueue,每個entry創(chuàng)建時,都會綁定這個refQueue,當(dāng)GC清理了entry的 referent 后,也就是說entry與自己的key斷開引用了,會將entry入隊到其綁定的 refQueue中去。 WeahkHashMap類內(nèi)的任何操作執(zhí)行前(如:get / size 等操作),都會先檢查一遍這個refQueue,將已經(jīng)被GC斷開了對key的引用的entry全都從map中remove掉。
private final ReferenceQueue<Object> queue = new ReferenceQueue<>(); // 定義一個隊列,GC會自動將綁定到了此隊列的weak實例入隊到此隊列,用戶應(yīng)當(dāng)在每次訪問weak實例前,都要檢查實例是否已經(jīng)被GC入隊到此隊列中,如果是,說明實例已經(jīng)被GC,應(yīng)當(dāng)放棄使用。 ... private static class Entry<K,V> extends WeakHashMap<Object> implements Map.Entry<K,V>{ V value; int hash; Entry<K,V> next; Entry(Object key, V value, ReferenceQueue queue, int hash, Entry<K,V> next){ super(key, queue); // 調(diào)用父類WeakReference的構(gòu)造方法,設(shè)置referent = key, queue = refQueue; this.value = value; this.hash = hash; this.next = next; } }
具體如下:
1.在WeakHashMap類中定義了一個實例域ReferenceQueue<Map.Entry> queue。
/** * Reference queue for cleared WeakEntries */ private final ReferenceQueue<Object> queue = new ReferenceQueue<>();
2.定義了一個內(nèi)部類WeakHashMap.Entry,直接繼承了WeakReference,Entry中沒有定義key字段,而是調(diào)用super(key,queue),將 key 保存在Reference類的referent字段中。
3.由于Entry本身對key是弱引用,因此GC會監(jiān)測key,在某個Entry的key處于適當(dāng)狀態(tài)時,Entry會被加入到pending列表,然后由ReferenceHandler將Entry添加到queue隊列。
4.WeakHashMap中的許多操作,比如get(K key),size(),remove(K key)時,都會先調(diào)用expungeStaleEntries();方法,這個方法會將已經(jīng)被添加到queue中的Entry從map中移除,同時會將entry的value變量的值置為null。
5.經(jīng)過步驟4,entry被從Map中移除后,不再有對此entry的引用,entry對key即referent的引用是弱引用,entry的value的值被賦值為null,原來的value的對象也不再被引用。GC就可以回收這些對象了。
代碼詳解
- 自定義的內(nèi)部類Entry<K,V>,實現(xiàn)了Map.Entry<K,V>,同時繼承了WeakReference。其referent指向key。也就是說,WeakHahsMap中的每個Entry都是一個weakRefer實例。
可以看到代碼中沒有定義實例域key,而是調(diào)用WeakReference的構(gòu)造函數(shù)super(key,queue),使得weakRefer實例的referent變量指向了key。
Entry的getKey()方法,就是調(diào)用WeakReference的get()方法,返回referent引用的key。
put(k, v)方法執(zhí)行,構(gòu)造Entry時,會將給定的key賦值給referent。
get( k) 方法執(zhí)行時,根據(jù) k.hash == entry.hash && k.equals(entry.get()) 來比較和查找,其中entry.get()得到的就是referent引用的key。
private static class Entry<K,V> extends WeakReference<Object> implements Map.Entry<K,V> { V value; final int hash; Entry<K,V> next; /** * Creates new entry. */ Entry(Object key, V value, ReferenceQueue<Object> queue, int hash, Entry<K,V> next) { super(key, queue); this.value = value; this.hash = hash; this.next = next; } @SuppressWarnings("unchecked") public K getKey() { return (K) WeakHashMap.unmaskNull(get()); } public int hashCode() { /* 重寫實現(xiàn)了Object類中的hashCode,此方法是計算整個Entry實例對象的hashCode,不是計算key的hashCode */ K k = getKey(); V v = getValue(); return Objects.hashCode(k) ^ Objects.hashCode(v); } }
類中定義了一個聲明的同時也初始化了的ReferenceQueue類型的變量: private final ReferenceQueue<Object> queue = new ReferenceQueue<>();
- WeakHashMap中的所有Entry的key都會在super(key,queue)時,注冊到此queue上。GC線程會監(jiān)測這些key的可達(dá)性的狀態(tài),在key處于一個特殊狀態(tài)時,就會將引用key的WeakReference實例對象的狀態(tài)設(shè)置為pending,并將WeakReference實例添加到pengding列表中去。而Reference類創(chuàng)建的ReferenceHandler線程則會自旋處理pending列表中的所有處于pending狀態(tài)的Reference實例,將它們enqueue()到queue中去,最終GC會回收queue里的所有Reference實例,由于是Entry實現(xiàn)了WeakReference,因此最終是整個entry被回收。
- 獲取WeakHashMap的table[]數(shù)組時,會將已經(jīng)被GC入隊的key關(guān)聯(lián)的entry從map中刪除。
private Entry<K,V>[] getTable(){ Entry<K,V>[] table = expungeStaleEntries(); return table; } /** * Expunges stale entries from the table. */ private void expungeStaleEntries() { for (Object x; (x = queue.poll()) != null; ) { synchronized (queue) { @SuppressWarnings("unchecked") Entry<K,V> e = (Entry<K,V>) x; int i = indexFor(e.hash, table.length); Entry<K,V> prev = table[i]; Entry<K,V> p = prev; while (p != null) { Entry<K,V> next = p.next; if (p == e) { if (prev == e) table[i] = next; else prev.next = next; // Must not null out e.next; // stale entries may be in use by a HashIterator e.value = null; // Help GC size--; break; } prev = p; p = next; } } } }
get(K key)時,會調(diào)用Reference的get()獲得Entry真正的key,與參數(shù)key做比較
public V get(Object key) { Object k = maskNull(key); int h = hash(k); Entry<K,V>[] tab = getTable(); int index = indexFor(h, tab.length); Entry<K,V> e = tab[index]; while (e != null) { if (e.hash == h && eq(k, e.get())) return e.value; e = e.next; } return null; }
實例解析:WeakHashMap在tomcat的緩存中的應(yīng)用
public final class ConcurrentCache<K,V>{ private final int size; private final Map<K,V> eden; //新創(chuàng)建的,最近使用的,放在eden里。 private final Map<K,V> longTerm; // 當(dāng)eden滿了后,將eden里的所有對象移動到longTerm里。longTerm是一個WeakHashMap,GC及時清理其中的數(shù)據(jù)。 public ConcurrentCache(int size){ this.size=size; eden= new ConcurrentHashMap(size); longTerm = new WeakHashMap(); } public V get(K k){ /* 被get,最新被使用了,必須要在eden中*/ V v = eden.get(k) ; if(v==null){ synchronized(longTerm){ v = longTerm.get(k); } if(v!=null){ eden.put(k,v); } } return v; } public V put(K K,V v){ /*最新創(chuàng)建的,放到eden中*/ if(eden.size()>=size){ synchronized(longTerm){ longTerm.putAll(eden); } eden.clear(); } eden.put(k,v); } }
get時,如果eden中沒有,而longTerm中有,則將數(shù)據(jù)取出后,再添加到eden中,保證最新最近使用的放在eden中。
put時,如果eden已經(jīng)滿了,就將eden中的全部倒換到longTerm中去,將新創(chuàng)建的這個要put到eden中。
如此,longTerm中就是長期未使用的、不常用的,因此用WeakHashMap以便GC回收,釋放空間。
緩存使用 ConcurrentHashMap 和 synchronized(longTerm) 很簡單地實現(xiàn)了多線程安全的緩存。
到此這篇關(guān)于Java的WeakHashMap源碼解析及使用場景詳解的文章就介紹到這了,更多相關(guān)Java的WeakHashMap內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SpringBoot+Druid開啟監(jiān)控頁面的實現(xiàn)示例
本文主要介紹了SpringBoot+Druid開啟監(jiān)控頁面的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-06-06Spring如何根據(jù)條件創(chuàng)建bean,@Conditional注解使用方式
這篇文章主要介紹了Spring如何根據(jù)條件創(chuàng)建bean,@Conditional注解使用方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-06-06Java concurrency之公平鎖(二)_動力節(jié)點Java學(xué)院整理
這篇文章主要為大家詳細(xì)介紹了Java concurrency之公平鎖的第二篇內(nèi)容,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-06-06java解析json復(fù)雜數(shù)據(jù)的方法詳解
這篇文章主要為大家詳細(xì)介紹了java解析json復(fù)雜數(shù)據(jù)的兩種常用方法,文中的示例代碼講解詳細(xì),具有一定的借鑒價值,需要的小伙伴可以了解下2024-01-01Java 編程如何使用 Class.forName() 加載類
在一些應(yīng)用中,無法事先知道使用者將加載什么類,而必須讓使用者指定類名稱以加載類,可以使用 Class的靜態(tài)forName()方法實現(xiàn)動態(tài)加載類,這篇文章主要介紹了Java編程如何使用Class.forName()加載類,需要的朋友可以參考下2022-06-06