Что такое ConcurrentHashMap?

ConcurrentHashMap — это специализированная реализация Map, разработанная для эффективной работы в многопоточных средах. Её ключевая цель — предоставить потокобезопасность без глобальной блокировки всей коллекции, что было бы узким местом для производительности.

Основные принципы работы

Вместо одной блокировки на всю карту, ConcurrentHashMap использует концепцию сегментов (buckets). Внутренняя структура делится на несколько сегментов, и каждый сегмент имеет свою собственную блокировку. Это позволяет разным потокам одновременно работать с разными сегментами. Например, один поток может писать в один сегмент, а другой — читать из другого, без взаимных блокировок.

Отличия от других потокобезопасных карт

• Hashtable: синхронизирует каждый метод, используя одну блокировку на весь экземпляр, что приводит к низкой производительности при высокой конкуренции.
• Collections.synchronizedMap(new HashMap<>()): аналогично, оборачивает все операции в synchronized-блоки, блокируя весь объект.
• ConcurrentHashMap: использует тонкую блокировку (на уровне сегментов или даже отдельных узлов в современных версиях Java), обеспечивая лучший параллелизм.

Практический пример

Рассмотрим пример использования ConcurrentHashMap в качестве простого потокобезопасного кэша:

import java.util.concurrent.ConcurrentHashMap;

public class CacheExample {
    private final ConcurrentHashMap cache = new ConcurrentHashMap<>();

    // Потокобезопасное добавление, если ключ отсутствует
    public String getOrCompute(String key) {
        return cache.computeIfAbsent(key, k -> {
            // Дорогостоящее вычисление значения для ключа
            return expensiveComputation(k);
        });
    }

    private String expensiveComputation(String key) {
        // Имитация долгой операции
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        return "computed_" + key;
    }

    public static void main(String[] args) {
        CacheExample example = new CacheExample();
        // Множество потоков могут безопасно вызывать getOrCompute
        System.out.println(example.getOrCompute("user_1"));
    }
}

Метод computeIfAbsent атомарен для данного ключа. Если несколько потоков попытаются вычислить значение для одного и того же ключа одновременно, только первый поток выполнит вычисление, а остальные получат уже готовый результат.

Важные особенности и методы

ConcurrentHashMap предоставляет атомарные операции, которых нет в обычном HashMap, такие как putIfAbsent, compute, merge. Итераторы, возвращаемые ConcurrentHashMap, обладают свойством "weakly consistent" — они отражают состояние карты на момент создания итератора или его последнего продвижения, но могут не отражать последующие изменения, и при этом их использование не требует блокировки и не вызывает ConcurrentModificationException.

Вывод: ConcurrentHashMap следует применять в многопоточных приложениях, где требуется высокая производительность при частых операциях чтения и записи, особенно когда записи происходят в разные сегменты карты. Она менее подходит, если нужна абсолютная консистентность итератора или если операции требуют атомарности на уровне всей коллекции (например, перемещение всех элементов).