rest - Guava LoadingCache 与 Kotlin 协程

Question

我正在使用 Guava 的 Loading Cache缓存 HTTP 请求的结果。 Kotlin/KTOR 提供了一个 HTTP Client Library基于协程(即非阻塞 HTTP 请求)。

我的问题是加载缓存不知道suspending 函数。我传递给加载缓存的 load 函数不能挂起。所以我被迫在 runBlocking 调用中执行 HTTP 请求，完全消除了非阻塞调用的好处。

我的问题是:有没有更好的方法？您将如何实现协同程序结果的缓存？

Answer 1

你可以将 Deferred 从协程 async { ... } 放入 guava 的缓存中

像这样

LoadingCache<Key, Deferred<Value>> = CacheBuilder.newBuilder()
    // ...
    .build(CacheLoader<Key, Deferred<Value>> { key ->
        someScope.async { computeMyValueSuspend(key) }
    })