Cache2K auto refreshAhead 无法按预期工作
Cache2K auto refreshAhead does'nt work as expected
我正在尝试使用 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 会触发新的加载。
我正在尝试使用 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 会触发新的加载。