為什么80%的碼農都做不了架構師？>>> ??

整體設計

下面的圖更能說明Guava Cache的整體結構：

主要有以下幾點：

初始化segment數組和JDK1.7里面的HashMap是差不多的，基本沒差別

可是，再每個segment下面會初始化一個ReferenceEntry數組，而且這個數組是AtomicReferenceArray類型的，用于多線程并發操作

每個ReferenceEntry對象里面，有三個很重要的屬性：key、valueReference、next，分別對應著鍵值對的，鍵和值，還有指向下一個節點的指針

說明ReferenceEntry數組每個元素都是一個鏈表，這種也是傳統的一個設計

每個segment下面，還會有三個重要的隊列：

• keyReferenceQueue（用于軟引用與弱引用的時候）
• valueReferenceQueue（用于軟引用與弱引用的時候）
• writeQueue（用于時間淘汰算法）
• accessQueue（用于LRU、時間淘汰算法）

初始化過程

針對guavacache的初始化，我畫了個時序圖

//中文偽代碼 public class LocalCache{LocalCache(CacheBuilder<? super K, ? super V> builder, @Nullable CacheLoader<? super K, V> loader){//獲取各種使用CacheBuilder初始化的參數//各種位運算獲取segment數組大小與referenceEntry數組大小//初始化一個segment類型的數組Segment[size]//初始化每個segment}static class Segment<K, V> extends ReentrantLock{Segment(LocalCache<K, V> map, int initialCapacity, long maxSegmentWeight, StatsCounter statsCounter){//segment內部持有Localcache與maxSegmentWeight//初始化ReferenceEntry數據//初始化keyReferenceQueue、valueReferenceQueue、writeQueue、accessQueue}} }

put的過程

//中文偽代碼 public class LocalCache{@Overridepublic V put(K key, V value) {//通過二次hash找到對應的ReferenceEntry數組的索引值//這里調用segment的put方法}static class LocalLoadingCache<K, V> extends LocalManualCache<K, V> implements LoadingCache<K, V> {@Overridepublic void put(K key, V value) {localCache.put(key, value);}}static class Segment<K, V> extends ReentrantLock{@NullableV put(K key, int hash, V value, boolean onlyIfAbsent) {try{//加鎖//使用基于時間（最后寫時間或是最后訪問時間）淘汰策略，淘汰一下元素//擴容（如果超出最大限制的話）//通過二次hash的值定位到那個ReferenceEntryfor（遍歷這個ReferenceEntry鏈表）{if(這個entry的hash值等于傳入的hash && entry的key不等于null && 傳入的key值等于當前key)//這個時候說明命中了元素//取當前ReferenceEntry的valueReference里面對應的具體value值if(value等于null){if(valueReference是已經被初始化的狀態){//這說明value值是軟引用或是弱引用，已經被GC回收了//將當前的鍵值對放入到刪除的監聽隊列里面，并且將當前Segment的容量減去當前元素的容量//設置傳入的值到鏈表當中去//將當前Segment的容量加上當前元素的容量//元素數目加一}else{//這種情況說明這個值沒有被初始化過//直接設置值，并加容量}//這里做一次基于LRU的緩存淘汰策略return null}else{//這種情況說明這個元素的value不為null切命中//將當前元素放入刪除監聽隊列并減去當前Segment容量//刪除當前找到的值//設置傳入的值到這個鏈表中//這里再一次做基于LRU的緩存淘汰return value}}//這里說明沒有找到對應的key值//心初始化一個ReferenceEntry并將傳入的value包裝成valueReference并set進當前ReferenceEntry//將ReferenceEntry設置到對應的索引位置//元素數目加一//這里進行LRU緩存淘汰return null}finally{//釋放鎖//將整個過程中刪除隊列中刪除的值，一個個回調用戶自定義的刪除回調監聽函數}}} }

get（普通的get）的過程

//中文偽代碼 public class LocalCache{static class LocalLoadingCache<K, V> extends LocalManualCache<K, V> implements LoadingCache<K, V> {@Overridepublic V get(K key) throws ExecutionException {return localCache.getOrLoad(key);}}V getOrLoad(K key) throws ExecutionException {return get(key, defaultLoader);}V get(K key, CacheLoader<? super K, V> loader) throws ExecutionException {//這里是二次hash找到那個最終的ReferenceEntry那個hash值int hash = hash(checkNotNull(key));return segmentFor(hash).get(key, hash, loader);}static class Segment<K, V> extends ReentrantLock{V get(K key, int hash, CacheLoader<? super K, V> loader) throws ExecutionException {//檢查key值與加載器不能為空try{if(如果元素數目不為0){//獲取當前hash對應的ReferenceEntryif(entry不為null){//獲取當前時間value = (entry){if(entry里面的key為null){return null}if(entry里面的value為null){return null}if(entry根據設置的時間超時){//將對應的寫隊列或是訪問隊列里面的值淘汰return null}return entry.value}if(value不為null){//將此value最后訪問時間設置成上面獲取到的當前時間if(設置了刷新時間 && 當前超過了刷新時間 && 當前entry不是正在加載中的entry){//使用用戶設置的加載器刷新當前值if(如果當前值不為空){return value}}return entry.value}//獲取當前entry里面的ValueReferenceif(ValueReference是正在加載狀態的){//循環等待正在加載的value//將等待的value記錄到訪問隊列return value}}return 用用戶自定義加載器加載那個value}}catch(異常){//異常處理}finally{//基于過期時間進行淘汰//將整個過程中刪除隊列中刪除的值，一個個回調用戶自定義的刪除回調監聽函數}}}}

轉載于:https://my.oschina.net/UBW/blog/1594865

總結

以上是生活随笔為你收集整理的Guava Cache 1（脉络）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。