GUAVA Cache源码阅读-cache、AbstractCache 、AbstractLoadingCache、CacheBuilder

  1. cache 接口
    主要有这几个方法 :
    • V getIfPresent(Object var1);

    • V get(K var1, Callable<? extends V> var2) throws ExecutionException;

    • ImmutableMap<K, V> getAllPresent(Iterable<?> var1);

    • void put(K var1, V var2);

    • void putAll(Map<? extends K, ? extends V> var1);

    • void invalidate(Object var1);

    • void invalidateAll(Iterable<?> var1);

    • void invalidateAll();

    • long size();

    • CacheStats stats();

    • ConcurrentMap<K, V> asMap();

    • void cleanUp();


AbstractCache 是个抽象类 ,继承了Cache

  1. 如果调用AbstractCache的get、put、size、invalidate、invalidateAll()、stats()、asMap()方法,会抛出UnsupportedOperationException()异常。
  2. getAllPresent 返回的ImmutableMap为LinkedHashMap。
    当插入一串新数据时,会首先判断是否当前插入的是否存在于之前已经插入的数据中 ,如果不存在,继续判断是否已经当前对象中 ,如果不是,就插入结果集合。最后返回结果集合 。
  3. invalidateAll(Iterable<?> keys),调用invalidate删除数据
  4. 里面有一个SimpleStatsCounter内部类 ,实现了AbstractCache.StatsCounter接口。
    同时定义了一个LongAddable 接口。
    statsCounter 接口
    public interface StatsCounter
    {
    void recordHits(int var1);
    void recordMisses(int var1);
    void recordLoadSuccess(long var1);
    void recordLoadException(long var1);
    void recordEviction();
    CacheStats snapshot();
    }
    LongAddable 接口
    interface LongAddable
    {
    void increment();
    void add(long var1);
    long sum();
    }
    SimpleStateCounter中定义了一系列LongAddAble操作。包括命中计数、未命中计数、装载成功计数、装载异常计数、总共装载计数、换出计数。(
    long hitCount, long missCount, long loadSuccessCount, long loadExceptionCount, long totalLoadTime, long evictionCount)
    snapshot()函数将返回当前所有计数的数量。
    incrementBy(AbstractCache.StatsCounter other)可以直接在一系列的计数中加上另外一个AbstractCache.StatsCounter的数量。

AbstractLoadingCache是个抽象类,继承了AbstractCache.

方法 含义
V getUnchecked(K key) 暂时不理解
ImmutableMap<K, V> getAll(Iterable<? extends K> keys) 在内部创建了一个链表哈希map,将传入的值放入linkHashMap中,用迭代器进行遍历。最后返回ImmutableMap类型的对象。
V apply(K key) 调用getUnchecked返回对象
refresh 抛出UnsupportedOperationException异常

CacheBuilder
在cacheBuilder的文档中提到,一个LoadingCache和Cache的实例的构造者应该具有以下特点:
A builder of LoadingCache and Cache instances having any combination of the following features:

  • automatic loading of entries into the cache
  • least-recently-used eviction when a maximum size is exceeded
  • time-based expiration of entries, measured since last access or last write
  • keys automatically wrapped in [weak]references
  • values automatically wrapped in [weak] or [soft] references
  • notification of evicted (or otherwise removed) entries
  • accumulation of cache access statistics

中文翻译就是

  • 自动装载实体到内存。
  • 当超过最大内存时,会清除最近最少使用的
  • 按照上次访问或写入的时间来测量条目是否达到过期时间。
  • 键自动包裹在弱引用中。
  • 值自动包裹到强引用或软引用中。
  • 删除或换出数据时有通知
  • 积累缓存访问的数据

These features are all optional; caches can be created using all or none of them. By default cache instances created by CacheBuilder will not perform any type of eviction.

这些功能都是可选的;可以使用全部或不创建高速缓存。默认情况下,CacheBuilder创建的缓存实例不会执行任何类型的逐出。
一个使用cachebuilder的实例:

  LoadingCache<Key, Graph> graphs = CacheBuilder.newBuilder()
   .maximumSize(10000)
   .expireAfterWrite(10, TimeUnit.MINUTES)
   .removalListener(MY_LISTENER)
   .build(
       new CacheLoader<Key, Graph>() {
         public Graph load(Key key) throws AnyException {
           return createExpensiveGraph(key);
         }
       }); 

还有一种创建方式

    String spec = "maximumSize=10000,expireAfterWrite=10m";
     LoadingCache<Key, Graph> graphs = CacheBuilder.from(spec)
    .removalListener(MY_LISTENER)
    .build(
       new CacheLoader<Key, Graph>() {
         public Graph load(Key key) throws AnyException {
           return createExpensiveGraph(key);
         }
       });

这两种创建方式是等价的。

The returned cache is implemented as a hash table with similar performance characteristics to ConcurrentHashMap
. It implements all optional operations of the LoadingCache and Cache interfaces. The asMap
view (and its collection views) have weakly consistent iterators. This means that they are safe for concurrent use, but if other threads modify the cache after the iterator is created, it is undefined which of these changes, if any, are reflected in that iterator. These iterators never throw ConcurrentModificationException
.

大概意思如下:

  1. 返回的cache的实现类似于ConcurrentHashMap的哈希表。
    它实现了LoadingCache和Cache的所有接口。
  2. asMap视图是弱一致的迭代器。这意味着他们是线程安全的。它没有定义这些改变,当影响到迭代器时,这些迭代器绝不会抛出ConcurrentModificationException异常。
  3. 已经换出的数据也可能被Cache.size()方法在计数时计算,但是不能对其进行读写操作。
  4. CacheBuilder<K,V> maximumWeight(long weight)这个方法确定了缓存包含的对象的最大权重。
    注意权重只是用来决定缓存是否已经超过其最大容量。它对于接下来要将哪个对象换出内存没有影响。
    抛出的异常
函数 返回值 说明
build() Cache<K1,V1> 创建缓存,此缓存在请求关键字时,不会自动加载值
build(CacheLoader<? super K1,V1> loader) LoadingCache<K1,V1> 创建缓存。它可以返回给定键的已经加载的值,也可以使用提供的CacheLoader来进行原子计算或检索它
ticker CacheBuilder<K,V> 指定一个纳秒精度时间源,用于确定条目何时过期。
concurrencyLevel(int concurrencyLevel) CacheBuilder<K,V> 指导更新操作之间允许的并发性。
initialCapacity(int initialCapacity) CacheBuilder<K,V> 设置内部哈希表的最小长度。
maximumSize(long size) CacheBuilder<K,V> 指定缓存可能包含的最大条目数。
maximumWeight(long weight) CacheBuilder<K,V> 指定缓存可能包含的条目的最大权重。
newBuilder() static CacheBuilder<Object,Object> 构造一个新的CacheBuilder实例,具有默认设置,包括强大的键,强大的值,并且没有任何自动驱逐。
recordStats() CacheBuilder<K,V> 在缓存的操作期间启用CacheStats的累积
refreshAfterWrite(long duration, TimeUnit unit) CacheBuilder<K,V> 指定在条目创建后经过固定持续时间或最近更换其值后,活动条目符合自动刷新的条件。
from(String spec) static CacheBuilder<Object,Object> 使用规范中指定的设置构造新的CacheBuilder实例
removalListener(RemovalListener<? super K1,? super V1> listener) <K1 extends K,V1 extends V> CacheBuilder<K1,V1> 指定一个监听器实例,高速缓存在任何情况下,每次删除一个条目时应该通知它。
softValues() CacheBuilder<K,V> 指定存储在缓存中的每个值(非键)都应该包装在SoftReference中(默认情况下,使用强引用)。
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,456评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,370评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,337评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,583评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,596评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,572评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,936评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,595评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,850评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,601评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,685评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,371评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,951评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,934评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,167评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,636评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,411评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,585评论 18 139
  • 为谁而作?是一件非常重要的事情。 考虑到作是一个非常宽泛的动词,我们暂且把此处的“作”,看作是创作的作。如果分得再...
    岗鉴阅读 332评论 0 3
  • 我们每个人都有一个梦想,希望未来的家庭生活充满了智能,就如同科幻小说里描写的那样,至少也应该有个“大白”陪伴。实际...
    花捧娱乐vlog视频植入阅读 355评论 0 0
  • 各位小伙伴们大家好,这几天弱弱的看了看老掉牙的支持向量机(Support Vector Machine, SVM)...
    云时之间阅读 1,392评论 1 3
  • 今天和大米结束了她喜欢的《窗边的小豆豆》,开始了《疯狂的学校》。一所日本学校的学校生活,一所美国的学校生活;两个国...
    悦米时光阅读 146评论 0 0