Javajava算法
ThreadLocal 核心原理、使用场景与内存泄漏解析
ThreadLocal 核心原理、使用场景与内存泄漏解析 一、核心原理 数据存储结构 关键设计 **线程隔离**：每个线程拥有独立的 ThreadLocalMap 副本。 **哈希表结构**：使用开放寻址法（线性探测）解决哈希冲突。 **弱引用键**：Entry 的 Key（ThreadLocal 实例）为弱引用。 **延迟清理**：在调用 set() / get() 时自动清理过期条目。 二、源…
ThreadLocal 核心原理、使用场景与内存泄漏解析 一、核心原理 数据存储结构 关键设计 **线程隔离**：每个线程拥有独立的 ThreadLocalMap 副本。 **哈希表结构**：使用开放寻址法（线性探测）解决哈希冲突。 **弱引用键**：Entry 的 Key（ThreadLocal 实例）为弱引用。 **延迟清理**：在调用 set() / get() 时自动清理过期条目。 二、源…
// 每个 Thread 对象内部都有一个 ThreadLocalMap
ThreadLocal.ThreadLocalMap threadLocals = null;
// ThreadLocalMap 内部使用 Entry 数组，Entry 继承自 WeakReference<ThreadLocal<?>>
static class Entry extends WeakReference<ThreadLocal<?>> {
Object value;
Entry(ThreadLocal<?> k, Object v) {
super(k); // 弱引用指向 ThreadLocal 实例
value = v; // 强引用指向实际存储的值
}
}
ThreadLocalMap 副本。Entry 的 Key（ThreadLocal 实例）为弱引用。set() / get() 时自动清理过期条目。set() 方法流程public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null) {
map.set(this, value); // this 指当前 ThreadLocal 实例
} else {
createMap(t, value);
}
}
private void set(ThreadLocal<?> key, Object value) {
Entry[] tab = table;
int len = tab.length;
int i = key.threadLocalHashCode & (len - 1);
// 遍历查找合适的位置
for (Entry e = tab[i]; e != null; e = tab[i = nextIndex(i, len)]) {
ThreadLocal<?> k = e.get();
// 找到相同的 key，直接替换 value
if (k == key) {
e.value = value;
return;
}
// key 已被回收，替换过期条目
if (k == null) {
replaceStaleEntry(key, value, i);
return;
}
}
tab[i] = new Entry(key, value);
int sz = ++size;
// 清理并判断是否需要扩容
if (!cleanSomeSlots(i, sz) && sz >= threshold) {
rehash();
}
}
get() 方法流程public T get() {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null) {
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
@SuppressWarnings("unchecked")
T result = (T) e.value;
return result;
}
}
return setInitialValue(); // 返回初始值
}
// 场景1：线程上下文信息传递（如 Spring 的 RequestContextHolder）
public class RequestContextHolder {
private static final ThreadLocal<HttpServletRequest> requestHolder = new ThreadLocal<>();
public static void setRequest(HttpServletRequest request) { requestHolder.set(request); }
public static HttpServletRequest getRequest() { return requestHolder.get(); }
}
// 场景2：数据库连接管理
public class ConnectionManager {
private static final ThreadLocal<Connection> connectionHolder =
ThreadLocal.withInitial(() -> DriverManager.getConnection(url));
public static Connection getConnection() { return connectionHolder.get(); }
}
// 场景3：用户会话信息
public class UserContext {
private static final ThreadLocal<UserInfo> userHolder = new ThreadLocal<>();
public static void setUser(UserInfo user) { userHolder.set(user); }
public static UserInfo getUser() { userHolder.get(); }
}
private static final，避免重复创建实例。ThreadLocal.withInitial() 提供初始值，避免空指针。finally 块中调用 remove() 清理资源。Thread → ThreadLocalMap → Entry[] → Entry → value（强引用）Entry → key（弱引用指向 ThreadLocal）ThreadLocal 实例被外部置为 null 或失去强引用，触发 GC 后 key 被回收，变为 null。value 仍被 Entry 强引用。value 无法被回收，导致内存泄漏。remove()（推荐）：使用完毕后显式清理，彻底切断强引用链。InheritableThreadLocal：支持父子线程值传递，但在线程池场景下可能失效或引发数据污染。FastThreadLocal（Netty 优化版）：通过数组索引替代哈希计算，避免哈希冲突，适用于高并发场景。public class SafeThreadLocalExample {
// 1. 使用 static final 修饰
private static final ThreadLocal<SimpleDateFormat> DATE_FORMAT =
ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd"));
// 2. 包装为工具类
public static Date parse(String dateStr) throws ParseException {
SimpleDateFormat sdf = DATE_FORMAT.get();
try {
return sdf.parse(dateStr);
} finally {
// 注意：若需复用 SimpleDateFormat 实例，此处通常不调用 remove；
// 若为用完即弃的场景，应调用 remove()。
}
}
// 3. 线程池场景必须清理
public void executeInThreadPool() {
ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10; i++) {
executor.submit(() -> {
try {
UserContext.setUser(new UserInfo());
// ... 业务处理
} finally {
UserContext.remove(); // 关键！防止线程复用导致数据污染与内存泄漏
}
});
}
}
}
ThreadLocal，需使用 InheritableThreadLocal 或 TransmittableThreadLocal。get() 可能返回 null，需结合 withInitial() 或判空逻辑处理。| 方案 | 适用场景 | 优点 | 缺点 |
|---|---|---|---|
ThreadLocal | 线程隔离数据 | 简单高效 | 存在内存泄漏风险 |
InheritableThreadLocal | 父子线程传递 | 自动继承上下文 | 在线程池中易失效或污染 |
TransmittableThreadLocal | 线程池上下文传递 | 线程池友好，支持异步传递 | 需引入第三方依赖 |
| 显式参数传递 | 简单/短链路场景 | 无副作用，逻辑清晰 | 方法签名冗长，代码冗余 |
可通过反射查看当前线程的 ThreadLocalMap 内容（仅限调试）：
public static void dumpThreadLocalMap(Thread thread) throws Exception {
Field field = Thread.class.getDeclaredField("threadLocals");
field.setAccessible(true);
Object map = field.get(thread);
if (map != null) {
Field tableField = map.getClass().getDeclaredField("table");
tableField.setAccessible(true);
Object[] table = (Object[]) tableField.get(map);
for (Object entry : table) {
if (entry != null) {
Field valueField = entry.getClass().getDeclaredField("value");
valueField.setAccessible(true);
System.out.println("Key: " + ((WeakReference<?>) entry).get() +
", Value: " + valueField.get(entry));
}
}
}
}
ThreadLocal 是线程级别的变量隔离工具。其底层为每个 Thread 对象维护了一个独立的 ThreadLocalMap。调用 set(value) 时，以当前 ThreadLocal 实例为 Key，将值存入当前线程的 Map 中；调用 get() 时同理。不同线程即使共享同一个 ThreadLocal 实例，操作的也是各自线程内部的 Map，从而实现数据隔离。
SimpleDateFormat 或数据库连接。通过为每个线程分配独立实例，既避免加锁带来的性能损耗，又保证线程安全。ThreadLocalMap 的 Key 为弱引用，Value 为强引用。当 ThreadLocal 实例被回收后，Key 变为 null，但 Value 仍被强引用。若线程长期存活（如线程池），Value 无法被 GC，导致泄漏。finally 块中调用 remove()，彻底移除 Entry。ThreadLocal 在 set()/get() 时会尝试清理 Key 为 null 的过期 Entry，但不可完全依赖。ThreadLocal 声明为 static final，延长其生命周期，减少 Key 被意外回收的概率，但仍需配合 remove() 使用。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
使用加密算法（如AES、TripleDES、Rabbit或RC4）加密和解密文本明文。 在线工具，加密/解密文本在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online