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