Освоение ConcurrentMap в Java: потокобезопасные карты разъяснены

Интерфейс Java ConcurrentMap

Узнайте, как ConcurrentMap в Java обеспечивает потокобезопасные операции с картами, его основные методы и практический пример с ConcurrentHashMap.

Интерфейс ConcurrentMap расширяет java.util.Map и предоставляет высокопараллельную, потокобезопасную реализацию карты. Он гарантирует, что несколько потоков могут одновременно выполнять операции чтения, записи и обновления без повреждения внутреннего состояния карты.

Поскольку ConcurrentMap — интерфейс, его нельзя инстанцировать напрямую. Наиболее распространенная реализация — java.util.concurrent.ConcurrentHashMap, предлагающая бесшовные чтения и детально-гранулярные блокировки для обновлений.

Классы, реализующие ConcurrentMap

Хотя ConcurrentMap сам по себе не может быть инстанцирован, можно создать конкретную карту, используя одну из его реализаций. Де-факто стандарт — ConcurrentHashMap, но существуют альтернативы, такие как ConcurrentSkipListMap для требований отсортированной карты.

Использование ConcurrentMap

Сначала импортируйте интерфейс:

import java.util.concurrent.ConcurrentMap;

Затем создайте экземпляр ConcurrentHashMap:

ConcurrentMap<String, Integer> numbers = new ConcurrentHashMap<>();

В этом примере numbers — потокобезопасная карта, где каждый ключ String парен с значением Integer.

Ключевые концепции:

• Key — уникальный идентификатор, отображающийся на значение.
• Value — данные, ассоциированные с ключом.

Ключевые методы ConcurrentMap

Помимо всех стандартных операций Map, ConcurrentMap вводит несколько атомарных, бесшовных методов:

• putIfAbsent(K key, V value) — добавляет пару ключ/значение только если ключ ещё не присутствует.
• compute(K key, BiFunction) — атомарно обновляет значение для указанного ключа на основе его текущего значения.
• computeIfAbsent(K key, Function) — генерирует значение для отсутствующего ключа с использованием предоставленной функции.
• computeIfPresent(K key, BiFunction) — атомарно обновляет значение существующего ключа.
• forEach(BiConsumer) — выполняет заданное действие для каждой записи.
• merge(K key, V value, BiFunction) — комбинирует новое значение с существующим с использованием предоставленной функции.

Для глубокого справочника см. официальную документацию Java.

Использование ConcurrentHashMap с ConcurrentMap

import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ConcurrentHashMap;
public class Main {
    public static void main(String[] args) {
        // Создание потокобезопасной карты
        ConcurrentMap<String, Integer> numbers = new ConcurrentHashMap<>();
        // Вставка элементов
        numbers.put("Two", 2);
        numbers.put("One", 1);
        numbers.put("Three", 3);
        System.out.println("ConcurrentMap: " + numbers);
        // Получение значения
        int value = numbers.get("One");
        System.out.println("Accessed Value: " + value);
        // Удаление пары ключ/значение
        int removed = numbers.remove("Two");
        System.out.println("Removed Value: " + removed);
    }
}

Вывод

ConcurrentMap: {One=1, Two=2, Three=3} Accessed Value: 1 Removed Value: 2

Для более продвинутого использования обратитесь к документации ConcurrentHashMap.