我想将我的caffeine
缓存配置为在加载程序无法刷新缓存时返回陈旧的结果。以下Kotlin代码演示了这种情况:
@Test
fun `completeble future`() = runBlocking {
val cache = caffeine.newBuilder()
.refreshAfterWrite(Duration.ofSeconds(1))
.expireAfterWrite(Duration.ofSeconds(1))
.buildAsync<String,String> { key: String,executor ->
GlobalScope.future(executor.asCoroutineDispatcher()) {
throw Exception("== Error ==")
}
}
cache.put("id",CompletableFuture.completedFuture("value"))
delay(2000)
assertEquals("value",cache.get("id").await())
}
我希望该测试通过,但是却出现以下错误:
WARNING: Exception thrown during asynchronous load
java.lang.Exception: == Error ==
at fsra.manager.TranslationmanagerImplTest$completeble future$1$cache$1$1.invokeSuspend(TranslationmanagerImplTest.kt:93)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(Dispatched.kt:241)
at java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteaction.exec(ForkJoinTask.java:1426)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)
java.lang.Exception: == Error ==
at fsra.manager.TranslationmanagerImplTest$completeble future$1$cache$1$1.invokeSuspend(TranslationmanagerImplTest.kt:93)
at |b|b|b(Coroutine boundary.|b(|b)
at fsra.manager.TranslationmanagerImplTest$completeble future$1.invokeSuspend(TranslationmanagerImplTest.kt:101)
Caused by: java.lang.Exception: == Error ==
at fsra.manager.TranslationmanagerImplTest$completeble future$1$cache$1$1.invokeSuspend(TranslationmanagerImplTest.kt:93)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(Dispatched.kt:241)
at java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteaction.exec(ForkJoinTask.java:1426)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)
我用Kotlin编写了代码,但我认为该问题与Kotlin协程无关。我想将caffeine配置为在刷新时不抛出,而是在缓存中返回之前的结果。