為什么80%的碼農(nóng)都做不了架構(gòu)師？>>> ??

整體設(shè)計

下面的圖更能說明Guava Cache的整體結(jié)構(gòu)：

主要有以下幾點：

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

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

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

說明ReferenceEntry數(shù)組每個元素都是一個鏈表，這種也是傳統(tǒng)的一個設(shè)計

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

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

初始化過程

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

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

put的過程

//中文偽代碼 public class LocalCache{@Overridepublic V put(K key, V value) {//通過二次hash找到對應(yīng)的ReferenceEntry數(shù)組的索引值//這里調(diào)用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{//加鎖//使用基于時間（最后寫時間或是最后訪問時間）淘汰策略，淘汰一下元素//擴(kuò)容（如果超出最大限制的話）//通過二次hash的值定位到那個ReferenceEntryfor（遍歷這個ReferenceEntry鏈表）{if(這個entry的hash值等于傳入的hash && entry的key不等于null && 傳入的key值等于當(dāng)前key)//這個時候說明命中了元素//取當(dāng)前ReferenceEntry的valueReference里面對應(yīng)的具體value值if(value等于null){if(valueReference是已經(jīng)被初始化的狀態(tài)){//這說明value值是軟引用或是弱引用，已經(jīng)被GC回收了//將當(dāng)前的鍵值對放入到刪除的監(jiān)聽隊列里面，并且將當(dāng)前Segment的容量減去當(dāng)前元素的容量//設(shè)置傳入的值到鏈表當(dāng)中去//將當(dāng)前Segment的容量加上當(dāng)前元素的容量//元素數(shù)目加一}else{//這種情況說明這個值沒有被初始化過//直接設(shè)置值，并加容量}//這里做一次基于LRU的緩存淘汰策略return null}else{//這種情況說明這個元素的value不為null切命中//將當(dāng)前元素放入刪除監(jiān)聽隊列并減去當(dāng)前Segment容量//刪除當(dāng)前找到的值//設(shè)置傳入的值到這個鏈表中//這里再一次做基于LRU的緩存淘汰return value}}//這里說明沒有找到對應(yīng)的key值//心初始化一個ReferenceEntry并將傳入的value包裝成valueReference并set進(jìn)當(dāng)前ReferenceEntry//將ReferenceEntry設(shè)置到對應(yīng)的索引位置//元素數(shù)目加一//這里進(jìn)行LRU緩存淘汰return null}finally{//釋放鎖//將整個過程中刪除隊列中刪除的值，一個個回調(diào)用戶自定義的刪除回調(diào)監(jiān)聽函數(shù)}}} }

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(如果元素數(shù)目不為0){//獲取當(dāng)前hash對應(yīng)的ReferenceEntryif(entry不為null){//獲取當(dāng)前時間value = (entry){if(entry里面的key為null){return null}if(entry里面的value為null){return null}if(entry根據(jù)設(shè)置的時間超時){//將對應(yīng)的寫隊列或是訪問隊列里面的值淘汰return null}return entry.value}if(value不為null){//將此value最后訪問時間設(shè)置成上面獲取到的當(dāng)前時間if(設(shè)置了刷新時間 && 當(dāng)前超過了刷新時間 && 當(dāng)前entry不是正在加載中的entry){//使用用戶設(shè)置的加載器刷新當(dāng)前值if(如果當(dāng)前值不為空){return value}}return entry.value}//獲取當(dāng)前entry里面的ValueReferenceif(ValueReference是正在加載狀態(tài)的){//循環(huán)等待正在加載的value//將等待的value記錄到訪問隊列return value}}return 用用戶自定義加載器加載那個value}}catch(異常){//異常處理}finally{//基于過期時間進(jìn)行淘汰//將整個過程中刪除隊列中刪除的值，一個個回調(diào)用戶自定義的刪除回調(diào)監(jiān)聽函數(shù)}}}}

轉(zhuǎn)載于:https://my.oschina.net/UBW/blog/1594865

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。