ConcurrentHashMap通过CAS与synchronized实现高效线程安全,JDK 8采用数组+链表/红黑树结构,读无锁、写锁单节点,支持高并发操作。
在高并发场景下,HashMap不是线程安全的,而使用Hashtable或Collections.synchronizedMap虽然能保证同步,但性能较差。ConcurrentHashMap是Java中为高并发设计的线程安全Map实现,它通过分段锁(JDK 7)或CAS + synchronized(JDK 8及以后)机制,在保证线程安全的同时大幅提升并发性能。
从JDK 8开始,ConcurrentHashMap摒弃了分段锁的设计,转而采用Node数组 + 链表/红黑树的结构,类似于优化后的HashMap。每个桶位的写操作通过synchronized关键字锁定当前节点,读操作则几乎无锁,利用volatile保证可见性。
这种设计使得多个线程可以在不同桶位上同时进行写操作,大大提升了并发吞吐量。
ConcurrentHashMap的使用方式和普通Map类似,但所有操作都是线程安全的,无需额外同步。
示例代码:
ConcurrentHashMap
map.put("key1", 100);
Integer value = map.get("key1");
map.remove("key1");
推荐使用原子性操作方法提升并发安全性:
value, BiFunction remappingFunction):合并已有值与新值,适合计数器场景尽管ConcurrentHashMap是线程安全的,但复合操作仍需注意原子性问题。
以下写法存在并发风险:
// 错误示例:非原子操作
if (!map.containsKey("key")) {
map.put("key", value);
}
应改用putIfAbsent或computeIfAbsent来保证原子性。
另外,遍历操作(如forEach、keySet().iterator())返回的是弱一致性视图,不抛出ConcurrentModificationException,但可能反映部分更新状态,适合大多数并发场景,但不能保证实时一致性。
合理设置初始容量和并发级别有助于提升性能,尤其是在已知数据规模时。