Java跨线程传递数据

应用场景

  　  对于单服务来说&＃xff0c;比如一个普通的商城的服务&＃xff0c;有一个接口返回商品的信息&＃xff0c;针对不同的国家/地区可能有不同的搜索结果&＃xff0c;需要根据入参识别所属国家&＃xff0c;并将这个国家信息传递到下游接口使用&＃xff0c;我们首先会想到用Java中提供的threadlocal类来存储线程私有的变量&＃xff0c;在入口处识别国家信息放入threadlocal&＃xff0c;在后续的使用中直接从threadlocal中获取即可。&＃xff08;本质上是通过线程持有的threadlocalMap来区分不同的线程&＃xff09;&＃xff1b;
　  　  此外&＃xff0c;对于公司级别的链路追踪系统一般通过提供jar包的方式&＃xff0c;使用方可以通过jar包中的方法来向上下文中放置数据&＃xff0c;在应用内部和应用中进行传递。

  　  上述两个场景都面临同一个问题&＃xff1a;如果处理过程中&＃xff0c;使用了线程池/或者新建了子线程&＃xff0c;threadlocal就不好用了。因为新建的子线程的threadlocalMap中并没有存储对应的值&＃xff0c;当我们把一些参数存储在threadlocal中时&＃xff0c;应用内部使用线程池执行任务或者重新创建线程的时候&＃xff0c;新的线程就无法访问到原有线程持有的threadlocal数据&＃xff0c;threadlocal变量中存储的内容会丢失&＃xff0c;(也就是上下文信息需要从创建任务的时刻传递到run这个线程的时刻&＃xff09;。

解决思路

  　  线程之间的通信方式主要有两大类&＃xff0c;一种是通过消息的方式通信&＃xff0c;另一种是共享数据来通信。

  　  上面两种方法&＃xff0c;无非是在创建新的线程/线程池进行调度的时候&＃xff0c;想办法把threadlocal变量传递过去&＃xff0c;既然是在服务内部&＃xff0c;共享数据的方式更为合理。

也就是说在创建新的线程/线程池进行调度这两个时候&＃xff0c;需要调用者将threadlcoal变量存储一下&＃xff0c;同时被调用者需要读一下。

代码分析

JVM中工具

首先&＃xff0c;JVM中提供了InheritableThreadLocal来解决父线程和子线程之间共享threadlocal变量的问题。类的注释如下&＃xff1a;

This class extends <tt>ThreadLocal</tt> to provide inheritance of values
* from parent thread to child thread: when a child thread is created, the
* child receives initial values for all inheritable thread-local variables
* for which the parent has values. Normally the child&＃39;s values will be
* identical to the parent&＃39;s; however, the child&＃39;s value can be made an
* arbitrary function of the parent&＃39;s by overriding the <tt>childValue</tt>
* method in this class.


也就是说&＃xff0c;如果变量声明为InheritableThreadLocal类型&＃xff0c;保证在创建子线程的时候&＃xff0c;就会将父线程的这些变量copy一下。
InheritableThreadLocal 继承自Threadlocal类&＃xff0c;主要重写了三个方法&＃xff0c;与threadlocal类中的createInheritedMap方法配合使用&＃xff0c;在thread创建的时候判断父线程是不是有InheritableThreadLocal类型的变量&＃xff0c;有的话则copy到子线程。

Thread 类中的init方法部分节选&＃xff1a;

注意&＃xff0c;InheritableThreadLocal 跨线程只适用于父线程/子线程之间的数据传递&＃xff0c;对于线程池还是无能为力&＃xff0c;还是需要封装出自己的runnable

阿里开源

阿里提供了一个开源的解决办法
https://github.com/alibaba/transmittable-thread-local
主要思想是&＃xff1a;

Mythread thread &＃61; new Mythread(runs,CopyThreadLocalToContext);## Run 的时候
Object backup&＃61; setConextAndGetBackUp();
Run;
setBackup(backup);


除了这种对线程池进行显式包装的方式&＃xff0c;还可以用java agent来对线程池进行增强&＃xff0c;对代码没有入侵性

https://www.jianshu.com/p/a8f252d50d88