ThreadLocal
什么是ThreadLocal?
通常情况下,我们创建的变量可以被任何一个线程访问和修改。这在多线程环境中可能导致数据竞争和线程安全问题。
ThreadLocal 是 Java 中一个用于实现线程局部变量的工具类。它为每个使用该变量的线程提供一个独立的变量副本,使得每个线程都可以操作自己的副本而不会影响其他线程,从而实现了线程间的数据隔离。
当你创建一个 ThreadLocal 变量时,每个访问该变量的线程都会拥有一个独立的副本。这也是 ThreadLocal 名称的由来。线程可以通过
get() 方法获取自己线程的本地副本,或通过 set() 方法修改该副本的值,从而避免了线程安全问题。
ThreadLocal存储原理
- 数据存储机制
ThreadLocal本身并不存储数据,它仅仅是一个访问工具。真正的数据存储在每个线程对象(Thread)内部的threadLocals变量中,其类型为
ThreadLocalMap。当你调用threadLocal.set(value)
时,ThreadLocal会获取当前线程的ThreadLocalMap,然后以当前ThreadLocal实例自身作为Key,将要存储的值作为Value,放入这个Map中。因此,每个线程都拥有自己独立的变量副本,互不干扰。
public class Thread implements Runnable {
ThreadLocal.ThreadLocalMap threadLocals = null;
}
ThreadLocal类的set()方法
public void set(T value) {
//获取当前请求的线程
Thread t = Thread.currentThread();
//取出 Thread 类内部的 threadLocals 变量(哈希表结构)
ThreadLocalMap map = getMap(t);
if (map != null)
// 将需要存储的值放入到这个哈希表中
map.set(this, value);
else
createMap(t, value);
}
ThreadLocalMap getMap(Thread t) {
return t.threadLocals;
}
通过上面这些内容,我们足以通过猜测得出结论:最终的变量是放在了当前线程的 ThreadLocalMap中,并不是存在 ThreadLocal 上,ThreadLocal 可以理解为只是 ThreadLocalMap 的封装,传递了变量值。ThrealLocal 类中可以通过Thread.currentThread()获取到当前线程对象后,直接通过getMap(Thread t)可以访问到该线程的ThreadLocalMap对象。
每个Thread中都具备一个ThreadLocalMap,而ThreadLocalMap可以存储以ThreadLocal为 key ,Object 对象为 value 的键值对。
ThreadLocalMap(ThreadLocal<?> firstKey, Object firstValue) {
//......
}
比如我们在同一个线程中声明了两个 ThreadLocal 对象的话, Thread内部都是使用仅有的那个ThreadLocalMap 存放数据的,ThreadLocalMap的 key 就是 ThreadLocal对象,value 就是 ThreadLocal 对象调用set方法设置的值。
ThreadLocal 数据结构如下图所示:

ThreadLocal内存泄漏的原因
ThreadLocal 导致内存泄露的核心原因可以概括为:“弱引用 Key” + “强引用 Value” + “线程复用(线程池)”。
ThreadLocal 导致内存泄漏的根本原因在于其内部数据结构的设计和线程生命周期的管理。具体来说,主要有以下几个关键因素:
核心数据结构设计
ThreadLocal 的内部实现基于 ThreadLocalMap,这是一个存储在线程内部的哈希表。ThreadLocalMap 中的 Entry 类继承自 WeakReference<ThreadLocal<?>>
要理解泄露,首先要知道 ThreadLocal 是怎么存数据的。
- 每个
Thread对象内部都有一个名为threadLocals的成员变量,其类型是ThreadLocalMap。 ThreadLocalMap类似于一个 HashMap,内部是一个Entry数组。- 关键点:
Entry是ThreadLocalMap的内部类,它继承自WeakReference。- Key:是
ThreadLocal对象本身(弱引用)。 - Value:是我们存入的具体对象(强引用)。
- Key:是
引用链如下:
Thread->ThreadLocalMap->Entry->Key (ThreadLocal对象)&Value (业务对象)
public class Thread implements Runnable {
ThreadLocal.ThreadLocalMap threadLocals = null;
ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;
}
public class ThreadLocal {
static class ThreadLocalMap {
static class Entry extends WeakReference<ThreadLocal<?>> {
Object value; // 强引用
Entry(ThreadLocal<?> k, Object v) {
super(k); // 弱引用
value = v;
}
}
}
}
典型泄漏场景
1. 线程池环境
这是最常见的内存泄漏场景。线程池中的线程会被复用,而不是每次用完就销毁。如果在线程任务执行完毕后没有调用 remove() 方法:
- 线程执行任务 A,设置了 ThreadLocal 值
- 任务 A 结束,但 ThreadLocal 值仍然存在
- 线程被复用执行任务 B,可能访问到任务 A 的残留数据
- 如果存储的是大对象,会持续占用内存
2. 静态 ThreadLocal 变量
如果 ThreadLocal 被声明为 static,它的生命周期与类本身一致。即使业务逻辑不再需要这些数据,它们仍然会一直存在于内存中。
下面深入到底层原理,一步步为您解析:
内存泄露的发生过程
第一步:正常使用
当我们使用 threadLocal.set(new Object()) 时,会在当前线程的 Map 中插入一个 Entry,此时:
- 栈上的变量强引用着
ThreadLocal对象。 - Map 的 Key 弱引用着
ThreadLocal对象。 - Map 的 Value 强引用着
Object。
第二步:引用断开 (Key 被回收)
当业务代码执行完毕,或者方法出栈,栈上对 ThreadLocal 对象的强引用消失了。
此时,ThreadLocal 对象只剩下一个来自 Entry 的弱引用。
第三步:GC 发生
由于 Key 是弱引用,下一次 GC(垃圾回收)发生时,Key (ThreadLocal对象) 会被回收。
此时,Map 中的这个 Entry 就会变成 key 为 null,但 value 依然有值的情况:
Entry(null, ValueObject)
第四步:内存泄露 (Value 无法回收)
现在问题来了:
- 无法访问:因为 Key 变成了
null,我们再也无法通过代码访问到这个Value对象了。 - 无法释放:虽然 Key 没了,但这条引用链依然存在且是强引用:
Current Thread->ThreadLocalMap->Entry->Value - 线程不死:如果是在 Web 容器(如 Tomcat)或线程池中,线程在处理完任务后不会销毁,而是回到池中等待下一次任务。这意味着
Current Thread长期存在,导致Value对象一直被强引用,GC 无法回收它。
久而久之,内存中会积累大量无法回收的 Value 对象,最终导致内存泄露(OOM)。
为什么 Key 要设计成弱引用?
你可能会问,如果 Key 也是强引用,是不是就没问题了? 并不是。
- 如果是强引用:如果不手动
remove(),那么ThreadLocal对象本身和Value都会发生泄露。 - 设计为弱引用:是 JDK 团队的一种“补救”措施。即使你忘了清理,至少
ThreadLocal对象本身可以被回收。而且,ThreadLocalMap在调用set()、get()、remove()方法时,内部会探测 Key 为null的 Entry 并触发探测式清理(Expunge Stale Entries),尝试回收 Value。
但是,这种“探测式清理”是被动的。如果你不再调用 get/set,或者线程长时间不工作,泄露依然会发生。
解决方案
1. 显式调用 remove()
解决 ThreadLocal 内存泄露的唯一标准做法是:
在使用完 ThreadLocal 后,务必在 finally 代码块中显式调用 remove() 方法。
ThreadLocal<User> threadLocal = new ThreadLocal<>();
try {
threadLocal.set(new User());
// 执行业务逻辑
} finally {
// 必须清理,防止内存泄露,并防止线程复用导致的数据污染
threadLocal.remove();
}
2. 使用 try-with-resources 模式
class AutoCloseableThreadLocal<T> extends ThreadLocal<T> implements AutoCloseable {
@Override
public void close() {
remove();
}
}
try (AutoCloseableThreadLocal<String> threadLocal = new AutoCloseableThreadLocal<>()) {
threadLocal.set("value");
// 业务逻辑
} // 自动调用 remove()
3. 合理设计线程池
• 设置合理的线程存活时间
• 避免创建过大的线程池
• 考虑使用有界队列
总结
ThreadLocal 内存泄露是因为 ThreadLocalMap 的 Entry 中,Key 是弱引用,Value 是强引用。当 Key 被 GC 回收后,Value 依然被当前线程强引用,若线程长期存活(如线程池)且未手动 remove(),该 Value 将无法被回收,从而导致泄露。
如何跨线程传递 ThreadLocal 的值?
在Java中,ThreadLocal 设计之初就是为了线程隔离,默认情况下它的值无法自动传递给其他线程。 要实现跨线程传递(通常是从父线程传递给子线程),主要取决于你是直接创建新线程还是使用线程池。
在Java中,跨线程传递 ThreadLocal 的值主要有几种方式,它们分别适用于不同的场景。下面这个表格帮你快速了解核心方案的特点和适用场景。
| 方案 | 核心机制 | 适用场景 | 关键限制 |
|---|---|---|---|
| InheritableThreadLocal | 在创建新线程时,自动从父线程复制值到子线程。 | 简单的父子线程关系(通过 new Thread().start() 创建)。 | 线程池中线程复用会导致数据混乱(子线程修改值会影响后续任务)。 |
| TransmittableThreadLocal (TTL) | 通过包装 Runnable/Callable,在任务执行前“注入”父线程值,执行后“恢复”原始值。 | 线程池等会复用线程的并发组件。 | 需引入第三方库(阿里开源),并对任务进行包装。 |
| 手动传递 | 在父线程中显式获取值,通过参数、构造函数等方式传递给子线程任务。 | 所有场景,特别是值传递逻辑简单或不想引入额外依赖时。 | 增加代码复杂度,需手动管理数据生命周期。 |
下面我们具体看看每种方案的实现细节。
使用 InheritableThreadLocal
InheritableThreadLocal 是 ThreadLocal 的子类,也是JDK内置的解决方案。它的原理是,当父线程创建子线程时,如果父线程的 inheritableThreadLocals 属性不为空,JVM会在子线程初始化过程中将父线程的 InheritableThreadLocal 值复制一份给子线程。
代码示例:
// 声明为 InheritableThreadLocal 类型
static InheritableThreadLocal<String> context = new InheritableThreadLocal<>();
public static void main(String[] args) {
context.set("Value set in parent thread");
new Thread(() -> {
// 子线程可以获取到父线程设置的值
System.out.println("在子线程中获取值: " + context.get()); // 输出: Value set in parent thread
}).start();
}
主要局限:其数据复制发生在线程创建时。在线程池场景下,线程是预先创建好并被复用的,后续提交的任务使用的是之前创建好的线程,这些线程不会再次从提交任务的父线程复制 InheritableThreadLocal 的值,从而导致数据传递失败或错乱。
使用 TransmittableThreadLocal (TTL)
阿里巴巴开源的 TransmittableThreadLocal (TTL) 库专门解决了线程池等复用线程场景下的值传递问题。它继承自 InheritableThreadLocal,但其核心思想是在任务执行时进行值的传递和恢复,而非线程创建时。
使用方式主要有三种:
-
装饰 Runnable/Callable(推荐,显式且清晰):
// 1. 使用 TransmittableThreadLocal TransmittableThreadLocal<String> context = new TransmittableThreadLocal<>(); context.set("Value set in parent thread"); // 2. 创建原始任务 Runnable task = () -> { System.out.println("在线程池任务中获取值: " + context.get()); }; // 3. 使用 TtlRunnable 包装任务 ExecutorService executor = Executors.newCachedThreadPool(); executor.submit(TtlRunnable.get(task)); // 使用 TtlRunnable.get() 进行包装 -
装饰线程池(一次性设置,方便管理):
ExecutorService executorService = Executors.newFixedThreadPool(3); // 使用 TtlExecutors 包装整个线程池 ExecutorService ttlExecutorService = TtlExecutors.getTtlExecutorService(executorService); TransmittableThreadLocal<String> context = new TransmittableThreadLocal<>(); context.set("Value from parent"); // 提交任务时无需再次包装 ttlExecutorService.submit(() -> { System.out.println(context.get()); // 正确获取值 }); -
使用 Java Agent(无侵入,无需修改代码,适用于复杂系统)。
TTL 通过在任务执行前(replay 方法)将父线程的值设置到当前执行线程的 ThreadLocal 中,在任务执行后(restore 方法)再恢复执行线程原来的值,完美解决了线程池数据传递和隔离的问题。
手动传递值
对于简单的场景,手动传递值是最直接、最可控的方式。即在父线程中取出 ThreadLocal 的值,通过参数形式传递给子线程的任务。
代码示例:
static ThreadLocal<String> threadLocal = new ThreadLocal<>();
public static void main(String[] args) {
threadLocal.set("Data from parent");
// 在父线程中获取值
String parentValue = threadLocal.get();
ExecutorService executor = Executors.newSingleThreadExecutor();
// 将值作为参数传递给子线程任务
executor.submit(() -> {
// 在子线程中,可以选择使用一个新的ThreadLocal来存储,或者直接使用该值
System.out.println("子线程接收到的值: " + parentValue);
});
executor.shutdown();
}
这种方式虽然增加了方法参数,但逻辑清晰,没有魔法,也不会引入额外的依赖和潜在的内存泄漏风险。
方案选择与注意事项
- 简单父子线程:如果只是通过
new Thread()方式创建的一次性子线程,使用InheritableThreadLocal就够了。 - 线程池环境:强烈推荐使用
TransmittableThreadLocal (TTL),这是解决此类问题的标准方案。 - 轻量级或简单传递:如果传递的数据很简单,或者不希望引入第三方库,手动传递是很好的选择。
无论使用哪种方式,都要特别注意 内存泄漏 问题,尤其是在使用线程池时。务必在任务执行完毕后,及时调用 ThreadLocal 的 remove() 方法清理数据,避免残留值对后续任务造成干扰或引起内存泄漏。
InheritableThreadLocal 的原理是什么?
InheritableThreadLocal(简称 ITL)的核心原理可以用一句话概括:在创建子线程(new Thread)的那一刻,将父线程的 ITL Map 中的数据,“拷贝”一份给子线程。
这一过程完全依赖于 Thread 类源码中的特定逻辑。下面通过源码分析其具体实现机制。
1. Thread 类中的两个成员变量
首先,在 JDK 的 Thread 类源码中,存储 ThreadLocal 值的变量其实有两个,而不是一个:
public class Thread implements Runnable {
// 1. 普通 ThreadLocal 存储在这里
ThreadLocal.ThreadLocalMap threadLocals = null;
// 2. InheritableThreadLocal 存储在这里
// 这就是专门为了继承设计的 Map
ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;
// ... 其他代码
}
- 普通
ThreadLocal:读写都是操作threadLocals。 InheritableThreadLocal:读写操作的是inheritableThreadLocals。
这是通过 ITL 重写 getMap 和 createMap 方法实现的:
public class InheritableThreadLocal<T> extends ThreadLocal<T> {
// 重写:获取值时,找的是 inheritableThreadLocals 变量
@Override
ThreadLocalMap getMap(Thread t) {
return t.inheritableThreadLocals;
}
// 重写:设置值时,初始化的是 inheritableThreadLocals 变量
@Override
void createMap(Thread t, T firstValue) {
t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
}
}
2. 核心逻辑:线程创建时的“拷贝”
ITL 能跨线程传递的关键发生在 new Thread() 的时候。
当我们在父线程中调用 new Thread() 创建子线程时,最终会调用 Thread 类的 init 方法。让我们看看 init 方法做了什么(简化版源码):
// Thread 类的初始化方法
private void init(ThreadGroup g, Runnable target, String name, long stackSize, AccessControlContext acc, boolean inheritThreadLocals) {
// 获取当前的父线程(即调用 new Thread 的那个线程)
Thread parent = currentThread();
// ... 其他初始化代码 ...
// 【核心逻辑在这里】
// 如果父线程的 inheritableThreadLocals 不为空,且允许继承
if (inheritThreadLocals && parent.inheritableThreadLocals != null) {
// 创建子线程的 inheritableThreadLocals
// 并将父线程 Map 中的内容,"拷贝" 进去
this.inheritableThreadLocals =
ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
}
// ... 其他初始化代码 ...
}
解析:
- 系统判断“父线程”的
inheritableThreadLocals是否有值。 - 如果有,调用
createInheritedMap,这其实是一个浅拷贝过程。 - 子线程拥有了一个新的 Map,但 Map 里的 Key (ThreadLocal对象) 和 Value (数据对象) 都是引用自父线程的。
3. childValue 方法的作用
在拷贝过程中,JDK 提供了一个钩子方法 childValue。默认情况下,它直接返回父线程的值:
protected T childValue(T parentValue) {
return parentValue;
}
这意味着默认是引用传递。
- 如果传递的是
String(不可变),在子线程修改不会影响父线程。 - 如果传递的是
Map或List(可变对象),子线程修改内容,父线程也能看到,因为它们指向堆内存中同一个对象。
如果你希望子线程完全独立(深拷贝),需要自定义继承 ITL 并重写 childValue 方法。
4. 总结:原理流程图
- 父线程操作:
itl.set("value")-> 存入父线程的inheritableThreadLocals字段。 - 创建子线程:
new Thread()-> 触发init()方法。 - 数据复制:
init()检查父线程的inheritableThreadLocals不为空 -> 调用createInheritedMap-> 将引用复制给子线程的inheritableThreadLocals。 - 子线程读取:
itl.get()-> 读取自己inheritableThreadLocals中的值。
5. 再次强调:为什么线程池会失效?
看完原理就很容易理解为什么它在线程池中失效了:
- ITL 的复制动作仅且只发生在
new Thread()(线程创建)的那一刻。 - 线程池的本质是复用线程。核心线程创建后一直存在,不会反复销毁重建。
- 当你把任务提交给线程池时,执行任务的线程通常是早已创建好的“旧线程”。它的
inheritableThreadLocals还是它当年被创建时(或者上一次执行任务遗留)的数据,不会再次同步当前主线程的最新数据。
TransmittableThreadLocal 的原理
TransmittableThreadLocal(TTL)是阿里巴巴开源的一个用于解决 线程池等复用线程场景下线程间上下文传递 问题的强大工具。它通过巧妙的“捕获-重放-恢复”机制,实现了值的可靠传递与线程状态的洁净恢复。
下表概括了TTL的核心操作阶段及其作用,帮助你快速建立整体认知:
| 阶段 | 发生时机 | 核心作用 |
|---|---|---|
| 捕获 (Capture) | 任务提交时,在父线程中执行 | 获取提交任务时父线程中所有TTL变量的快照。 |
| 重放 (Replay) | 任务执行前,在线程池线程中执行 | 将捕获的快照设置到当前执行线程的TTL中,并备份执行线程的原始值。 |
| 恢复 (Restore) | 任务执行后,在线程池线程中执行 | 将执行线程的TTL状态恢复为执行任务前的备份,确保线程干净复用。 |
🔍 核心实现机制深度解析
1. 关键数据结构:全局 Holder
TTL 内部维护了一个静态的 holder 变量,其类型为 InheritableThreadLocal<WeakHashMap<TransmittableThreadLocal<Object>, ?>>。这个设计非常精妙:
- 作用:
holder作为一个注册中心,自动追踪所有在父线程中设置过值的TransmittableThreadLocal实例。当需要捕获快照时,只需遍历holder即可知道需要复制哪些 TTL 变量的值。 - 内存安全:使用
WeakHashMap且值设为null,使得holder对TransmittableThreadLocal实例是弱引用。这意味着当某个 TTL 实例不再被其他强引用指向时,它可以被垃圾回收,并从holder中自动移除,有效防止内存泄漏。
2. 任务的包装与执行流程
TTL 的核心逻辑体现在对 Runnable 或 Callable 的包装上,以 TtlRunnable 为例:
- 包装任务与捕获快照:当使用
TtlRunnable.get(runnable)包装原始任务时,会在父线程中立即执行Transmitter.capture()方法。此方法会遍历当前父线程的holder,获取所有注册的 TTL 变量及其值,生成一个快照(Snapshot)并保存在TtlRunnable实例中。 - 执行前重放上下文:当
TtlRunnable的run()方法在线程池线程中被调用时,它首先会执行replay(capturedSnapshot)。这个过程包括:- 备份:将当前线程(线程池中的工作线程)原有的 TTL 值进行备份。
- 注入:将之前捕获的快照值设置到当前线程的 TTL 变量中。
- 执行业务逻辑:随后,执行被包装的原始
runnable.run()。此时,业务代码就能正确获取到任务提交时父线程所设置的 TTL 值了。 - 执行后恢复现场:在
finally块中,调用restore(backup),将线程池线程的 TTL 状态恢复到任务执行前的备份状态。这一步至关重要,它清除了本次任务设置的上下文,避免了当前任务修改的 TTL 值污染后续执行不同任务的工作线程。
3. 源码级伪代码演示
为了便于理解,我们将 TTL 的复杂逻辑简化为以下伪代码:
public class TtlRunnable implements Runnable {
private final Runnable runnable; // 原始业务任务
private final Object capturedSnapshot; // 父线程的上下文快照
// 1. 【构造函数】:在父线程(提交线程)运行
public TtlRunnable(Runnable runnable) {
this.runnable = runnable;
// 【Capture】:抓取当前父线程所有 TTL 的值
this.capturedSnapshot = Transmitter.capture();
}
// 2. 【run方法】:在子线程(线程池)运行
@Override
public void run() {
// 【Replay】:将快照里的值赋值给当前线程,并返回当前线程原有的值作为备份
Object backup = Transmitter.replay(capturedSnapshot);
try {
// 执行真正的业务逻辑
runnable.run();
} finally {
// 【Restore】:恢复当前线程原来的值,避免污染
Transmitter.restore(backup);
}
}
}
4. 它是如何“入侵”线程池的?
你可能会问:“我必须每次都手动 new TtlRunnable(...) 吗?”
为了方便使用,TTL 提供了两种方式来自动完成上述的包装过程:
方式 A:修饰线程池(代码侵入)
也就是第一个回答中的 TtlExecutors.getTtlExecutorService(pool)。
它是一个装饰器,当你调用 pool.submit(task) 时,它内部自动帮你把 task 包装成了 TtlRunnable(task)。
方式 B:Java Agent(无侵入,最强模式)
在启动命令中加入 -javaagent:transmittable-thread-local-2.x.y.jar。
它利用 Java 的 Instrumentation 机制,在字节码加载阶段,修改 JDK 的 ThreadPoolExecutor 和 ForkJoinPool 等类的源码。
- 它会偷偷地在
execute或submit方法里,把传入的Runnable替换为TtlRunnable。 - 优点:业务代码完全不需要改动,连
TtlExecutors都不用写,直接用普通的ThreadLocal配合普通的线程池即可实现透传。
💡 如何使用TTL
TTL 提供了多种使用方式,以适应不同场景的需求:
-
修饰 Runnable/Callable(推荐):在每次提交任务时,手动包装任务对象。这是最基础、最清晰的方式。
TransmittableThreadLocal<String> context = new TransmittableThreadLocal<>(); context.set("value-set-in-parent"); Runnable task = () -> { System.out.println(context.get()); }; // 使用 TtlRunnable 包装 executorService.submit(TtlRunnable.get(task)); -
修饰线程池:利用
TtlExecutors工具类包装整个线程池,之后通过该包装后的线程池提交任务时,会自动进行包装,省去每次手动包装的麻烦。ExecutorService executorService = ...; // 包装线程池 ExecutorService ttlExecutorService = TtlExecutors.getTtlExecutorService(executorService); TransmittableThreadLocal<String> context = new TransmittableThreadLocal<>(); context.set("value-set-in-parent"); // 直接提交任务即可 ttlExecutorService.submit(() -> System.out.println(context.get())); -
Java Agent 方式(无侵入):在 JVM 启动参数中添加
-javaagent:path/to/transmittable-thread-local-x.x.x.jar,可以对 JDK 的线程池实现类进行字节码增强,从而实现代码零修改的上下文传递。这种方式对现有代码完全透明。
注意事项
- 性能影响:TTL 的
capture和replay操作时间复杂度为 O(n),n 是 TTL 变量的数量。应避免创建过多的 TTL 实例,以减少性能开销。 - 确保包装:必须使用上述方式对任务或线程池进行包装,否则上下文无法传递。
- 值序列化:TTL 默认是值的浅拷贝。如果需要在传递过程中进行深拷贝,可以重写
copyValue方法。
希望这份详细的原理解释能帮助你彻底理解 TransmittableThreadLocal 的工作机制。如果你对某个特定细节还有疑问,我们可以继续探讨。
TransmittableThreadLocal (TTL) 的核心原理可以概括为:“在任务提交时抓取上下文,在任务执行时回放上下文”。
它彻底改变了 JDK InheritableThreadLocal (ITL) 依赖“线程创建”的传递方式,而是采用了装饰器模式(Decorator Pattern)来控制 Runnable/Callable 的执行流程。
TTL 的实现主要依赖于两个核心要素:持有器 (Holder) 和 发射器 (Transmitter)。
以下是详细的原理拆解:
总结
TransmittableThreadLocal 的原理就是 “偷梁换柱”:
- Holder:记账,记录有哪些 TTL 需要传递。
- Capture:在主线程打包数据(快照)。
- Replay:在工作线程开始前,把数据刷进去,并备份旧数据。
- Restore:在工作线程结束后,把旧数据刷回来,清理现场。