子线程是会继承父线程的数据的。。。。但是记住,该类是会有,线程池中线程的复用问题的,,所以在一定情况下还是需要代码使用者自己将东西卸载掉,这种还是使用阿里巴巴的TTL作为替换吧,这个ttl不存在线程池的复用问题,不过线程池需要额外包装一下
public class InheritableThreadLocalDemo {static ThreadLocal<String> local = new ThreadLocal<>();static ThreadLocal<String> local2 = new InheritableThreadLocal<>();@Testpublic void test1() {local.set("haode");local2.set("haode");MyThread myThread = new MyThread();myThread.start();MyThread2 myThread2 = new MyThread2();myThread2.start();local.set("xxxx");local2.set("xxx");}static class MyThread extends Thread {public void run() {System.out.println(local.get());}}static class MyThread2 extends Thread {@Overridepublic void run() {System.out.println(local2.get());}}}
ttl
代码有部分是参考网上,如下情况,只有线程池被包装,然后采用TTL方式,才能够解决所有的问题
private static ExecutorService executorService = TtlExecutors.getTtlExecutorService(Executors.newFixedThreadPool(2));private static ExecutorService executorService1 = TtlExecutors.getTtlExecutorService(Executors.newFixedThreadPool(2));// private static ThreadLocal tl = new InheritableThreadLocal(); //这里采用TTL的实现private static ThreadLocal tl = new TransmittableThreadLocal(); //这里采用TTL的实现public static void main(String[] args) {new Thread(() -> {String mainThreadName = "main_01";tl.set(1);executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(1), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(1), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(1), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});sleep(1L); //确保上面的会在tl.set执行之前执行tl.set(2); // 等上面的线程池第一次启用完了,父线程再给自己赋值executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(2), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(2), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(2), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});System.out.println(String.format("线程名称-%s, 变量值=%s", Thread.currentThread().getName(), tl.get()));}).start();new Thread(() -> {String mainThreadName = "main_02";tl.set(3);executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(3), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(3), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(3), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});sleep(1L); //确保上面的会在tl.set执行之前执行tl.set(4); // 等上面的线程池第一次启用完了,父线程再给自己赋值executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(4), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(4), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});executorService.execute(() -> {sleep(1L);executorService1.execute(() -> {sleep(1L);System.out.println(String.format("本地变量改变之前(4), 父线程名称-%s, 子线程名称-%s, 变量值=%s", mainThreadName, Thread.currentThread().getName(), tl.get()));});});System.out.println(String.format("线程名称-%s, 变量值=%s", Thread.currentThread().getName(), tl.get()));}).start();}private static void sleep(long time) {try {Thread.sleep(time);} catch (InterruptedException e) {e.printStackTrace();}}
