ThreadLocal 是 Java 中用于实现线程本地存储的类，它为每个线程提供独立的变量副本，确保线程间的数据隔离。然而，ThreadLocal 本身并不直接支持主子线程之间的数据同步。要实现主子线程之间的数据同步，可以结合 InheritableThreadLocal 或其他机制。
1. 使用 InheritableThreadLocal
InheritableThreadLocal 是 ThreadLocal 的子类，允许子线程继承父线程的 ThreadLocal 变量。当创建子线程时，子线程会自动继承父线程的 InheritableThreadLocal 变量。
java">public class InheritableThreadLocalExample {private static InheritableThreadLocal<String> inheritableThreadLocal = new InheritableThreadLocal<>();public static void main(String[] args) {inheritableThreadLocal.set("Parent Thread Value");Thread childThread = new Thread(() -> {System.out.println("Child Thread Value: " + inheritableThreadLocal.get());});childThread.start();}
}
在这个例子中，子线程会输出父线程设置的 InheritableThreadLocal 值。
2. 手动传递数据
如果 InheritableThreadLocal 不满足需求，可以手动将父线程的数据传递给子线程。例如，通过构造函数或方法参数传递数据。
java">public class ManualDataPassingExample {private static ThreadLocal<String> threadLocal = new ThreadLocal<>();public static void main(String[] args) {threadLocal.set("Parent Thread Value");String parentValue = threadLocal.get();Thread childThread = new Thread(() -> {threadLocal.set(parentValue);System.out.println("Child Thread Value: " + threadLocal.get());});childThread.start();}
}
3. 使用线程池时的注意事项
在使用线程池时，InheritableThreadLocal 可能无法正常工作，因为线程池中的线程是复用的。可以通过自定义 ThreadFactory 或使用 TransmittableThreadLocal（阿里巴巴的开源库）来解决。
4. 使用 TransmittableThreadLocal
TransmittableThreadLocal 是阿里巴巴开源的一个库，专门解决线程池环境下 InheritableThreadLocal 的局限性。
java">import com.alibaba.ttl.TransmittableThreadLocal;public class TransmittableThreadLocalExample {private static TransmittableThreadLocal<String> transmittableThreadLocal = new TransmittableThreadLocal<>();public static void main(String[] args) {transmittableThreadLocal.set("Parent Thread Value");Runnable task = () -> {System.out.println("Child Thread Value: " + transmittableThreadLocal.get());};ExecutorService executorService = Executors.newFixedThreadPool(1);executorService.submit(task);executorService.shutdown();}
}
总结
InheritableThreadLocal适用于简单的父子线程数据传递。- 手动传递数据适用于需要更复杂控制的场景。
- 在线程池环境下，考虑使用
TransmittableThreadLocal或其他机制来确保数据同步。
