1

我正在尝试编写一个AsyncLoadingCache接受 aCacheWriter并且我得到一个IllegalStateException.

这是我的代码：

CacheWriter<String, UUID> cacheWriter = new CacheWriter<String, UUID>() {
        @Override
        public void write(String key, UUID value) {

        }

        @Override
        public void delete(String key, UUID value, RemovalCause cause) {

        }
    };

AsyncLoadingCache<String, UUID> asyncCache = Caffeine.newBuilder()
        .expireAfterWrite(60, TimeUnit.SECONDS)
        .writer(cacheWriter)
        .maximumSize(100L)
        .buildAsync((String s) -> { /* <== line 41, exception occurs here */
            return UUID.randomUUID();
        });

我得到了这个痕迹

com.github.benmanes.caffeine.cache.Caffeine.requireState(Caffeine.java:174) 的线程“main”java.lang.IllegalStateException 中的异常在 com.github.benmanes.caffeine.cache.Caffeine.buildAsync(Caffeine.java :854) 在 com.mycompany.caffeinetest.Main.main(Main.java:41)

如果我将缓存更改为 aLoadingCache或删除.writer(cacheWriter)，代码将正常运行。我究竟做错了什么？看来我为这两个对象提供了正确的类型。

4

1 回答 1

3

不幸的是，这两个功能不兼容。虽然文档说明了这一点，但我已经更新了异常以更好地传达这一点。其中Caffeine.writer指出，

此功能不能与 {@link #weakKeys()} 或 {@link #buildAsync} 一起使用。

ACacheWriter是用于条目突变的同步拦截器。例如，它可能用于将磁盘缓存作为辅助层逐出，而 aRemovalListener是异步的，使用它会导致条目不存在于任何一个缓存中的竞争。该机制是使用ConcurrentHashMap's compute方法来执行写入或删除，并CacheWriter在该块内调用。

在AsyncLoadingCache中，该值稍后会在成功时实现，或者在出现错误时CompletableFuture自动删除。null当哈希表中的条目被修改时，这个未来可能正在发生。这意味着CacheWriter通常会在没有物化值的情况下调用 ，并且可能无法做非常智能的事情。

从 API 的角度来看，不幸的是，伸缩式构建器（使用类型系统来禁止不兼容的链）比使用运行时异常更令人困惑。很抱歉没有明确错误，现在应该修复。

于 2018-01-20T22:02:28.290 回答