AtomicLongMap чтения потокобезопасность

Question

У меня есть следующий класс:

public class Storage { 
    protected static final AtomicLongMap<String> MAP; 
    protected Storage() { 
       MAP= AtomicLongMap.create(); 
    } 

    public void decrement(String id) { 
     long num = MAP.get(id); 
     if (num != 0) { 
      MAP.decrementAndGet(id); 
     } 
    } 

    public void putIntoActiveAgents(String id, Integer num) { 
     MAP.put(id, num); 
    } 

    public void remove(String id) { 
     MAP.remove(id); 
    } 

    public Long get(String id) { 
     return MAP.get(ID); 
    } 
} 

В моем случае я скажем 6 темы, которые исполнительское подобные вещи: Каждый из них проверяет нить, если долго на карте равен 1, если нет, они называют декремент, если да, они вызывают удаление. Всюду я читал, что AtomicLongMap является потокобезопасным. Я уверен, что это когда кто-то увеличивает или уменьшает длинные числа, но я не уверен, что он по-прежнему является потокобезопасным, когда другой поток считывает значения с этой карты. Мой сценарий: 1. Thread A считывает значение с карты - это 2 (поэтому он уменьшает значение) 2. Thread B считывает значение до того, как счетчик был уменьшен - он все равно возвращает 2, поэтому он также уменьшает значение. 3. В результате никто не видит, что значение установлено равным 1.

Мой вопрос в таком случае, мне нужно сделать MAP синхронизированным?

Answer 1

Если вы используете Java 8, глядя на свой код, я предлагаю вам использовать ConcurrentHashMap. Интерфейс карты в Java 8 обновлен новыми функциями, такими как computeIfPresent(). Таким образом, ваша функция «декремент (String id)» будет выглядеть так:

public class Storage { 
    protected static final Map<String, Long> MAP = new ConcurrentHashMap<>(); 

    public void decrement(String id) { 
     MAP.computeIfPresent(id, (id, currentValue) -> --currentValue); 
    } 

    public void putIntoActiveAgents(String id, Integer num) { 
     MAP.put(id, num); 
    } 

    public void remove(String id) { 
     MAP.remove(id); 
    } 

    public Long get(String id) { 
     return MAP.get(ID); 
    } 
} 

Answer 2

Если вы посмотрите на источнике вы увидите, что com.google.common.util.concurrent.AtomicLongMap (я предполагаю, что вы отсылая к этому классу) внутренне использует ConcurrentHashMap<K, AtomicLong> поэтому чтение действительно зависит от свойств ConcurrentHashMap, чье JavaDoc состояние:

Операции поиска (включая get) обычно не блокируются, поэтому могут перекрываться с операциями обновления (включая put и remove). Retrievals отражают результаты последних завершенных работ по обновлению с их началом.

Однако, поскольку вы обойдете карту здесь (вы читаете, проверяете и затем уменьшаете), ваш код не является потокобезопасным. Таким образом, вам, возможно, придется синхронизировать свои методы или использовать механизм (вы можете попробовать что-то вроде AtomicLong#compareAndSet, но AtomicLongMap, похоже, не предоставляет для этого доступа).