如何解决Cache2K auto refreshAhead 无法按预期工作
我正在尝试使用 org.cache2k 库创建具有自动刷新元素的缓存。 例如,我定义了持续时间为 5 秒的元素加载器。 我将过期时间设置为 5 秒。我将 keepDataAfterExpired 和 refreshAhead 选项设置为 true。
第一次调用 get 方法大约持续 5 秒。没关系。 然后我希望该元素将在接下来的 15 秒内过期并自动重新加载 第二个 get 将立即获取元素。但我的输出是:
结果
5011
结果
5000
第二次获得第一次也持续 5 秒。 我的目标是让元素自动刷新,只有第一次获取才会延迟。 它是否可以到达以及如何到达?谢谢。
static String expensiveOperation(String name) throws InterruptedException {
Thread.sleep(5000);
return "result";
}
public static void main (String... args) throws InterruptedException {
Cache<String,String> cache = new Cache2kBuilder<String,String>() {}
.expireAfterWrite(5000,TimeUnit.MILLISECONDS) // expire/refresh after 5 seconds
.keepDataAfterExpired(true)
.refreshAhead(true) // keep fresh when expiring
.loader(s->expensiveOperation(s)) // auto populating function
.build();
Instant i1 = Instant.Now();
System.out.println(cache.get("a"));
Instant i2 = Instant.Now();
System.out.println(Duration.between(i1,i2).toMillis());
Thread.sleep(15000);
Instant i11 = Instant.Now();
System.out.println(cache.get("a"));
Instant i22 = Instant.Now();
System.out.println(Duration.between(i11,i22).toMillis());
解决方法
我在有关 Cache2k 中 refreshAhead 的文档中找到了答案:
"一旦刷新,该条目处于跟踪期。如果直到下一次到期才访问它,则不会进行刷新,该条目过期并将从缓存中删除。这意味着条目停留的时间跟踪周期内由配置的到期时间或 ExpiryPolicy 决定。"
因此,在我的情况下,15 秒足以让条目自动刷新,然后过期并删除,因此下一个 get 会触发新的加载。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。