Java ConcurrentMap完全マスター：スレッドセーフマップの解説

Java ConcurrentMapインターフェース

JavaのConcurrentMapがいかにスレッドセーフなマップ操作を提供し、その主要メソッドと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("アクセスされた値: " + value);
        // キー/値ペアを削除
        int removed = numbers.remove("Two");
        System.out.println("削除された値: " + removed);
    }
}

出力

ConcurrentMap: {One=1, Two=2, Three=3}
アクセスされた値: 1
削除された値: 2

より高度な使用法についてはConcurrentHashMapドキュメントを参照してください。