咖啡因:无法为 AsyncLoadingCache 提供 CacheWriter
Caffeine: Can't provide CacheWriter to AsyncLoadingCache
我正在尝试编写一个接受 CacheWriter
的 AsyncLoadingCache
,我得到一个 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();
});
我得到了这个痕迹
Exception in thread "main" java.lang.IllegalStateException
at com.github.benmanes.caffeine.cache.Caffeine.requireState(Caffeine.java:174)
at com.github.benmanes.caffeine.cache.Caffeine.buildAsync(Caffeine.java:854)
at com.mycompany.caffeinetest.Main.main(Main.java:41)
如果我将缓存更改为 LoadingCache
或删除 .writer(cacheWriter)
,代码将 运行 正确。我究竟做错了什么?看来我为这两个对象提供了正确的类型。
不幸的是,这两个功能不兼容。虽然文档说明了这一点,但我已经更新了异常以更好地传达这一点。在 Caffeine.writer
中指出,
This feature cannot be used in conjunction with {@link #weakKeys()} or {@link #buildAsync}.
A CacheWriter
是用于条目突变的同步拦截器。例如,它可能用于作为第二层逐出到磁盘缓存中,而 RemovalListener
是异步的,使用它会留下一个条目不存在于任何一个缓存中的竞争。该机制是使用ConcurrentHashMap's
compute
方法执行写入或删除,并调用该块内的CacheWriter
。
在 AsyncLoadingCache
中,该值稍后在 CompletableFuture
成功时具体化,或者在 null
或错误时自动删除。当条目在散列 table 中被修改时,这个未来可能正在运行中。这意味着 CacheWriter
经常会在没有物化值的情况下被调用,并且可能无法做非常智能的事情。
从 API 的角度来看,不幸的是,伸缩构建器(使用类型系统来禁止不兼容的链)比使用运行时异常更令人困惑。很抱歉没有弄清楚错误,现在应该修复了。
我正在尝试编写一个接受 CacheWriter
的 AsyncLoadingCache
,我得到一个 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();
});
我得到了这个痕迹
Exception in thread "main" java.lang.IllegalStateException at com.github.benmanes.caffeine.cache.Caffeine.requireState(Caffeine.java:174) at com.github.benmanes.caffeine.cache.Caffeine.buildAsync(Caffeine.java:854) at com.mycompany.caffeinetest.Main.main(Main.java:41)
如果我将缓存更改为 LoadingCache
或删除 .writer(cacheWriter)
,代码将 运行 正确。我究竟做错了什么?看来我为这两个对象提供了正确的类型。
不幸的是,这两个功能不兼容。虽然文档说明了这一点,但我已经更新了异常以更好地传达这一点。在 Caffeine.writer
中指出,
This feature cannot be used in conjunction with {@link #weakKeys()} or {@link #buildAsync}.
A CacheWriter
是用于条目突变的同步拦截器。例如,它可能用于作为第二层逐出到磁盘缓存中,而 RemovalListener
是异步的,使用它会留下一个条目不存在于任何一个缓存中的竞争。该机制是使用ConcurrentHashMap's
compute
方法执行写入或删除,并调用该块内的CacheWriter
。
在 AsyncLoadingCache
中,该值稍后在 CompletableFuture
成功时具体化,或者在 null
或错误时自动删除。当条目在散列 table 中被修改时,这个未来可能正在运行中。这意味着 CacheWriter
经常会在没有物化值的情况下被调用,并且可能无法做非常智能的事情。
从 API 的角度来看,不幸的是,伸缩构建器(使用类型系统来禁止不兼容的链)比使用运行时异常更令人困惑。很抱歉没有弄清楚错误,现在应该修复了。