如何在Java中实现线程安全的缓存

使用ConcurrentHashMap实现线程安全缓存，结合过期机制与Future防止击穿，或选用Caffeine等成熟库以提升性能与可靠性。

在Java中实现线程安全的缓存，关键在于确保多个线程同时访问缓存时不会出现数据不一致或竞态条件。最常见的方式是使用线程安全的数据结构和同步机制。以下是几种实用且高效的实现方法。

使用ConcurrentHashMap作为缓存存储

ConcurrentHashMap是Java并发包中提供的线程安全Map实现，适合高并发读写场景。

它内部采用分段锁（JDK 1.8后优化为CAS + synchronized）机制，相比Hashtable或synchronized Map性能更好。

示例：

立即学习“Java免费学习笔记（深入）”；

private final ConcurrentHashMap cache = new ConcurrentHashMap();public Object get(String key) {    return cache.get(key);}public void put(String key, Object value) {    cache.put(key, value);}

这个实现天然支持多线程并发访问，get操作几乎无锁，put操作只锁定局部桶位，效率高。

结合过期机制与原子操作

实际缓存通常需要支持自动过期。可以将值封装成包含时间戳的对象，并配合原子操作保证更新一致性。

例如：

class CacheValue {    final Object value;    final long expireAt;    CacheValue(Object value, long ttlMillis) {        this.value = value;        this.expireAt = System.currentTimeMillis() + ttlMillis;    }    boolean isExpired() {        return System.currentTimeMillis() > expireAt;    }}

获取时判断是否过期，若过期则移除：

public Object get(String key) {    CacheValue cv = cache.get(key);    if (cv == null) return null;    if (cv.isExpired()) {        cache.remove(key);        return null;    }    return cv.value;}

put操作直接覆盖，利用ConcurrentHashMap的原子性保证线程安全。

使用Future防止缓存击穿

对于计算耗时的加载逻辑，多个线程同时请求同一key可能导致重复加载。可用Future+Callable避免。

思路：缓存中存放Future，首次请求执行加载，后续请求直接get等待结果。

private final ConcurrentHashMap<String, Future