如何使用分组的 Caffeine Cache 或 ConcurrentHashMap？

如何解决如何使用分组的 Caffeine Cache 或 ConcurrentHashMap？

我想为每个用户 ID 缓存以下数据实体映射对象。

/**
 * Example data object
 */
data class Data(
  val id: Int,val name: String,val age: Int
)

作为想法之一，我考虑了 caffeine 中的以下缓存。

/**
 * Ex.1 cache
 * userId to (dataId to Data)
 */
val userDataCache = caffeine.newBuilder()
  .build<Int,ConcurrentHashMap<Int,Data>>()

/**
 * invalidate by userId
 */
fun invalidate(userId: Int) {
  userDataCache.invalidate(userId)
}

然而，上面例子中的 userDataCache 不是线程安全的，因为它被定义为一个嵌套的 hashmap。

我已经准备了另一个想法来使其线程安全。

/**
 * Ex.2 cache
 * Pair(userId,dataId) to Data
 */
val userDataCache = caffeine.newBuilder()
  .build<Pair<Int,Int>,Data>()

/**
 * invalidate by userId
 */
fun invalidate(userId: Int) {
  Todo("No idea !!!")
}

此方法是线程安全的，因为它不使用嵌套的哈希图。

然而，这个方法不允许我们定义一个 invalidate 方法来使每个 userId 的缓存失效。

如何使用 caffeine Cache 或 ConcurrentHashMap 以满足以下要求？

• 缓存每个用户 ID 的数据映射
• 使每个用户 ID 的数据映射无效
• 使其成为线程安全的