javaでマップの並列安全性問題を解決する方法

2年 ago
蓮, 翼
1 minute

JavaではConcurrentHashMapを使ってMapのマルチスレッド化ができます。

ConcurrentHashMapは、Javaコレクションフレームワーク内、複数のスレッドからの同時読み込みを外部同期メカニズムなしで可能とするスレッドセーフなハッシュ表実装です。ハッシュ表全体が、各セグメントに専用のロックを持つ複数の小さなセグメントに分割されているため、並行読み込み操作を実現しています。

ConcurrentHashMapを使うときは以下の注意が必要です。
1. HashMapの代わりにConcurrentHashMapを使うこと。HashMapで使うオブジェクトをConcurrentHashMapのオブジェクトに置き換えることで、Mapの操作をスレッドセーフにすることができます。
2. 新しいキーバリューペアを追加するにはputIfAbsent()メソッドを使うこと。putIfAbsent()メソッドは新しいキーバリューペアを追加する場合、キーが存在しないときのみ追加するため、スレッドセーフを保証できます。
3. put()メソッドとremove()メソッドを使うときは注意が必要です。ConcurrentHashMapは並行読み取りのスレッドセーフを保証していますが、put()メソッドとremove()メソッドを使うときは、スレッドセーフを保証するために適切な同期メカニズムを採用する必要があります。

非同期マップを使用する例です

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class ThreadSafeMapExample {
    public static void main(String[] args) {
        // 创建一个线程安全的Map对象
        Map<String, String> map = new ConcurrentHashMap<>();

        // 添加键值对
        map.put("key1", "value1");
        map.put("key2", "value2");
        map.put("key3", "value3");

        // 输出当前Map的内容
        System.out.println("Map: " + map);

        // 使用putIfAbsent()方法添加新的键值对
        map.putIfAbsent("key4", "value4");

        // 输出当前Map的内容
        System.out.println("Map: " + map);

        // 使用put()方法修改已存在的键值对
        map.put("key1", "value5");

        // 输出当前Map的内容
        System.out.println("Map: " + map);

        // 使用remove()方法删除指定的键值对
        map.remove("key2");

        // 输出当前Map的内容
        System.out.println("Map: " + map);
    }
}

ConcurrentHashMap を利用することで、Map の同時操作をスレッドセーフに保証できます。

bannerAds