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 会触发新的加载。