并发 hashmap 和 copyonwritearraylist

Question

我正在尝试使用 ConcurrentHashMap 填充保存键/值的缓存。

我假设使用 CopyOnWriteArrayList 来处理并发性，我将其作为我的键值，但我在下面的代码中遗漏了一些内容，并且在执行多个线程时它会覆盖其值。

if (testMap.get(id) == null) {
   CopyOnWriteArrayList<String> copyArr = new CopyOnWriteArrayList<String>();
   copyArr.add("Add Value");
   testMap().putIfAbsent(id, copyArr);
} else {                    
   testMap.put(id,testMap.get().add("Append Value"));
}

如何保护从多个线程创建CopyOnWriteArrayList 的代码。

这是根据以下建议修改后的代码。

CopyOnWriteArrayList<Subscriber> subscriberArr =  CacheUtils.getSubscriberMap().get(syncDet.getCardNumber());

if (subscriberArr == null) {

subscriberArr = new CopyOnWriteArrayList<Subscriber>();
CopyOnWriteArrayList<Subscriber> refArr = 

cacheUtils.getSubscriberMap().putIfAbsent(syncDet.getCardNumber(), subscriberArr);

if (refArr != null) {
 subscriberArr = refArr;
}

}
 subscriberArr.add(syncDet.getSubScriber());

在迭代订阅者映射时，我没有看到值对象。大小为 0。

Answer 1

您需要首先检索适当的列表，然后填充它。比如：

List<String> copyArr = testMap.get(id);
if (copyArr == null) {
    copyArr = new CopyOnWriteArrayList<String>();
    List<String> inMap = testMap.putIfAbsent(id, copyArr);
    if (inMap != null) copyArr = inMap; // already in map
}
copyArr.add("Add Value");

这样，您只需在地图中没有新列表的情况下将其添加到地图中的任何列表中。

Answer 2

您的实现存在一些问题。

首先，您正在以非线程安全的方式检查给定键是否没有列表。完全有可能两个线程可以执行if (testMap.get(id) == null)在其中任何一个放入密钥之前。这不会导致密钥本身被覆盖。

但是，两个列表都会生成，并且由于您要在不安全的if 块中向这些列表中添加元素在设置键之前，所以元素最终出现在实际的键->值映射中是任何人的猜测。

另外，完全没有必要这样做：

testMap.put(id,testMap.get(id).add("Append Value"));

在这种情况下，列表实例已经在地图中，您只需 get 它并添加值。请注意，这也可能会弄乱您之前的按键分配！

---

第二，潜在的问题是您正在使用CopyOnWriteList，它会在添加新元素时创建一个新的支持数组。这里有两个后果：

• 如果有很多添加，那就很贵了。
• 由于add操作是同步的（通过ReentrantLock），但get不是，你可能会在短时间内在不同的线程中得到不同的列表内容（不过，列表最终与添加一致）。这实际上是设计使然 - CopyOnWriteArrayList 面向高读/低写操作。

你至少有两种方法：

• 以线程安全的方式进行put操作，即
  • 仅使用putIfAbsent。
  • 不要将任何值添加到列表的本地副本，只添加从 get 获取的值。
• 如果您需要绝对一致性而不是最终一致性，请不要使用CopyOnWriteArrayList。改用带有“手动”同步的普通列表。您可以使用例如Guava 的 Multimap，例如 as this one，带有同步包装器，可以为您省去麻烦（Javadoc 解释了如何）。