concurrent 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 ориентирован на операции hi-read/lo-write.

У вас есть по крайней мере два способа здесь:

• поведения put операции в поточно-образом, т.е.
  • использование только putIfAbsent.
  • не добавляйте никаких значений в локальную копию списка, только тот, который вы берете с get.
• Если вам нужна абсолютная, а не возможная согласованность, не используйте вообще CopyOnWriteArrayList. Вместо этого используйте обычный список с «ручной» синхронизацией. Вы можете использовать, например. Многомапсы Guava, такие как as this one, с оберткой для синхронизации, чтобы избавить вас от неприятностей (объясняет Javadoc).