2

我使用 Google Guava 实现了一个非阻塞缓存,缓存中只有一个键,并且键的值仅异步刷新(通过覆盖 reload())。

我的问题是,如果第一个 reload() 任务尚未完成并且新的 get() 请求进来,Guava 缓存是否会处理重复数据删除。

    //Cache is defined like below
    this.cache = CacheBuilder
            .newBuilder()
            .maximumSize(1)
            .refreshAfterWrite(10, TimeUnit.MINUTES)
            .recordStats()
            .build(loader);

//reload is overwritten asynchronously
@Override
public ListenableFuture<Map<String, CertificateInfo>> reload(final String key, Map<String, CertificateInfo> prevMap) throws IOException {
    LOGGER.info("Refreshing certificate cache.");
    ListenableFutureTask<Map<String, CertificateInfo>> task = ListenableFutureTask.create(new Callable<Map<String, CertificateInfo>>() {
        @Override
        public Map<String, CertificateInfo> call() throws Exception {
            return actuallyLoad();
        }
    });
    executor.execute(task);
    return task;
}
4

1 回答 1

4

是的,请参阅LoadingCache.get(K)(及其兄弟Cache.get(K, Runnable))的文档:

如果另一个调用get(K)orgetUnchecked(K)当前正在加载 key 的值,只需等待该线程完成并返回其加载的值。

因此,如果当前正在计算(或重新加载/重新计算)缓存条目,则尝试检索该条目的其他线程将简单地等待计算完成 - 他们不会启动自己的冗余刷新。

于 2017-12-06T09:04:33.160 回答