MutableMap 被多线程修改且 map.size 不等于键数

Question

我正在使用 Kotlin，并且我有一个 key 作为 String 的 mutableMap，当我有 2 个线程尝试访问并使用相同的 key 放置时，会发生一些奇怪的事情，我的日志显示映射大小为 2（而不是 1），我还记录了那里有键和值，但只有一个条目...

@Component
class CacheImpl {
protected val cache: MutableMap<String, String> = HashMap() //same behavior with ConcurrentHashMap

fun fetchFromCache(key: String) {
   log.info("cache size: ${cache.size}")
   log.info("cache keys: ${cache.keys}")
   log.info("cache keys count: ${cache.keys.count()}")
   cache.computeIfAbsent(id) {
       key -> fetchFromClient(key)
   }
}
}

fun serviceCall() {
  // should fetch from client
  val result1 = cache.fetchFromCache("123")
  // should fetch from service
  val result2 = cache.fetchFromCache("123")
}

所以我有2个线程同时调用serviceCall，在日志中我发现

[thread: 2] - cache size: 0
[thread: 4] - cache size: 0
[thread: 2] - cache keys: []
[thread: 4] - cache keys: []
[thread: 2] - cache keys count: 2
[thread: 4] - cache keys count: 2
[thread: 2] - cache size: 2
[thread: 2] - cache keys count: 2
[thread: 2] - cache keys: [123]
[thread: 4] - cache size: 2
[thread: 4] - cache keys count: 2
[thread: 4] - cache keys: [123]

我也尝试过LinkedHashMap，更奇怪的是，在LinkedHashMap中你可以看到我的地图包含两个确切的相同的钥匙！

[thread: 2] - cache size: 0
[thread: 4] - cache size: 0
[thread: 2] - cache keys: []
[thread: 4] - cache keys: []
[thread: 2] - cache keys count: 2
[thread: 4] - cache keys count: 2
[thread: 2] - cache size: 2
[thread: 2] - cache keys count: 2
[thread: 2] - cache keys: [123,123]
[thread: 4] - cache size: 2
[thread: 4] - cache keys count: 2
[thread: 4] - cache keys: [123,123]

• Map 不应该只维护一个唯一的键吗？
• 为什么我的地图大小与按键数量不匹配？

Answer 1

HashMap不是线程安全的，所以当你放入两个线程时，就会发生奇怪的场景。我建议您使用ConcurrentWeakMap。正如医生所说

这是一个非常有限的实现，不适合作为通用地图替代品。
// 为了简单起见，它具有无锁获取和同步重新哈希的放置（以及在争用时更好的 CPU 使用率）

但它只能确保映射操作是线程安全的，您必须使该方法成为线程安全的。

@Synchronized
fun fetchFromCache(key: String) {
   log.info("cache size: ${cache.size}")
   log.info("cache keys: ${cache.keys}")
   log.info("cache keys count: ${cache.keys.count()}")
   cache.computeIfAbsent(id) {
       key -> fetchFromClient(key)
   }
}

同时，每次返回一个新对象时，您使用的密钥都会从 fetchFromClient 生成。这也是原因。如果您想覆盖已退出的值，您应该使用 putIfAbsent