文章目录
- 前置
- ConcurrentHashMap
- CopyOnWriteArrayList/CopyOnWriteArraySet
前置
常规的集合类,比如 ArrayList,HashMap 当作为多线程下共享的变量时候,操作它们时会涉及线程安全的问题
ConcurrentHashMap
适合:需要频繁读写的线程安全的场景
典型应用:存储热点数据,避免重复计算;分布式锁的管理;统计计数器
// putIfAbsent(K key, V value):仅在键不存在时插入
ConcurrentHashMap<String, Integer> cache = new ConcurrentHashMap<>();
cache.putIfAbsent("user:1001", 1); // 确保键不存在时插入
Integer count = cache.get("user:1001");
cache.compute("user:1001", (k, v) -> v == null ? 1 : v + 1); // 原子更新
// remove(K key, V value):仅在键值匹配时删除
// replace(K key, V oldValue, V newValue):原子替换值
CopyOnWriteArrayList/CopyOnWriteArraySet
适合:读多写少的场景(因为写操作时复制底层数组,读操作无需加锁)
// add(E e):添加元素(写时复制)
CopyOnWriteArrayList<String> listeners = new CopyOnWriteArrayList<>();
listeners.add("listener1");
// 多线程读取
Thread t1 = new Thread(() -> {
for (String listener : listeners) {
System.out.println(listener);
}
});
// 多线程写入
Thread t2 = new Thread(() -> {
listeners.add("listener2");
});
t1.start();
t2.start();
// get(int index):读取元素(无锁)
// iterator():返回弱一致的迭代器(不反映最新修改)