Если вы проверяете, содержит ли карта containsKey перед использованием Putifabsent ConcurrentMap

ответ Тома верен в том, что касается использования API для ConcurrentMap. Альтернативой, которая позволяет избежать использования putIfAbsent, является использование вычислительной карты из GoogleCollections/Guava MapMaker, которая автоматически заполняет значения поставляемой функцией и обрабатывает всю потокобезопасность для вас. На самом деле он создает только одно значение для каждого ключа, и если функция create стоит дорого, другие потоки, запрашивающие получение того же ключа, будут блокироваться до тех пор, пока значение не станет доступный.

Edit из Guava 11 MapMaker устарел и заменяется материалом Cache/LocalCache/CacheBuilder. Это немного сложнее в использовании, но в основном изоморфны.

можно использовать MutableMap.getIfAbsentPut(K, Function0<? extends V>) С Коллекции Eclipse (ранее коллекции GS).

преимущество над вызовом get(), делая нулевую проверку, а затем вызывая putIfAbsent() это то, что мы будем только вычислять хэш-код ключа один раз, и найти нужное место в хэш-таблице один раз. В ConcurrentMaps, как org.eclipse.collections.impl.map.mutable.ConcurrentHashMap реализация getIfAbsentPut() также потокобезопасен и атомарен.

import org.eclipse.collections.impl.map.mutable.ConcurrentHashMap;
...
ConcurrentHashMap<String, MyObject> map = new ConcurrentHashMap<>();
map.getIfAbsentPut("key", () -> someExpensiveComputation());

реализация org.eclipse.collections.impl.map.mutable.ConcurrentHashMap is действительно не блокирует. Хотя предпринимаются все усилия, чтобы не вызывать заводскую функцию без необходимости, все еще есть шанс, что она будет вызвана более одного раза во время конфликта.

этот факт отличает его от Java 8-х ConcurrentHashMap.computeIfAbsent(K, Function<? super K,? extends V>). Javadoc для этого метода гласит:

все вызов метода выполняется атомарно, поэтому функция применяется не более одного раза на клавишу. Некоторые попытки обновления операций на эта карта другими потоками может быть заблокирован во время вычислений прогресс, поэтому вычисление должно быть коротким и простым...

Примечание: я коммиттер для коллекций Eclipse.

сохраняя предварительно инициализированное значение для каждого потока, вы можете улучшить принятый ответ:

Set<X> initial = new HashSet<X>();
...
Set<X> set = map.putIfAbsent(name, initial);
if (set == null) {
    set = initial;
    initial = new HashSet<X>();
}
set.add(Y);

Я недавно использовал это со значениями карты AtomicInteger, а не Set.

через 5 лет я не могу поверить, что никто не упомянул или не опубликовал решение, которое использует ThreadLocal чтобы решить эту проблему; и несколько решений на эту страницу не ориентирована на многопотоковое исполнение и просто неаккуратно.

использование ThreadLocals для этой конкретной проблемы не только рассматривается лучшие практики для параллелизма, но для минимизации мусора/создание объекта во время нить раздора. Кроме того, это невероятно чистый код.

например:

private final ThreadLocal<HashSet<X>> 
  threadCache = new ThreadLocal<HashSet<X>>() {
      @Override
      protected
      HashSet<X> initialValue() {
          return new HashSet<X>();
      }
  };


private final ConcurrentMap<String, Set<X>> 
  map = new ConcurrentHashMap<String, Set<X>>();

и собственно логика...

// minimize object creation during thread contention
final Set<X> cached = threadCache.get();

Set<X> data = map.putIfAbsent("foo", cached);
if (data == null) {
    // reset the cached value in the ThreadLocal
    listCache.set(new HashSet<X>());
    data = cached;
}

// make sure that the access to the set is thread safe
synchronized(data) {
    data.add(object);
}

мое общее приближение:

public class ConcurrentHashMapWithInit<K, V> extends ConcurrentHashMap<K, V> {
  private static final long serialVersionUID = 42L;

  public V initIfAbsent(final K key) {
    V value = get(key);
    if (value == null) {
      value = initialValue();
      final V x = putIfAbsent(key, value);
      value = (x != null) ? x : value;
    }
    return value;
  }

  protected V initialValue() {
    return null;
  }
}

и в качестве примера использования:

public static void main(final String[] args) throws Throwable {
  ConcurrentHashMapWithInit<String, HashSet<String>> map = 
        new ConcurrentHashMapWithInit<String, HashSet<String>>() {
    private static final long serialVersionUID = 42L;

    @Override
    protected HashSet<String> initialValue() {
      return new HashSet<String>();
    }
  };
  map.initIfAbsent("s1").add("chao");
  map.initIfAbsent("s2").add("bye");
  System.out.println(map.toString());
}