TransmittableThreadLocal
TTL是阿里巴巴开源的专门解决InheritableThreadLocal的局限性,实现线程本地变量在线程池的执行过程中,能正常的访问父线程设置的线程变量。
TransmittableThreadLocal简称TTL,InheritableThreadLocal简称ITL
它的官网是:https://github.com/alibaba/transmittable-thread-local
功能介绍我已截图至此:
GAV:
<dependency> <groupId>com.alibaba</groupId> <artifactId>transmittable-thread-local</artifactId> <version>2.11.4</version> </dependency>
那么使用它就能解决如上示例的问题吗?正所谓试验是检验真理的唯一标准,来一把:
针对示例1,仅仅做出如下改动(其它均不变):
// 实现类使用TTL的实现 private static final ThreadLocal<Person> THREAD_LOCAL = new TransmittableThreadLocal<>(); // 线程池使用TTL包装一把 private static final ExecutorService THREAD_POOL = TtlExecutors.getTtlExecutorService
再次运行程序,控制台打印:
get数据,线程名:pool-1-thread-1,数据为:TestThreadLocal.Person(age=18) get数据,线程名:pool-1-thread-1,数据为:TestThreadLocal.Person(age=100)
bingo!看线程名仍旧还是同一个线程(因为线程池大小为1嘛),但是结果已经是最新的了,这才是合理的嘛,不禁想感叹一句:太它xxxxx了!
说明:这里线程池必须使用TtlExecutors处理一下,而且得使用TransmittableThreadLocal作为数据传递的实现,缺一不可哦~
如何实现?
TransmittableThreadLocal继承于InheritableThreadLocal,并拥有了 InheritableThreadLocal对子线程传递上下文的特性,只需解决线程池上下文传递问题。它使用TtlRunnable包装了任务的运行,被包装的run方法执行异步任务之前,会使用replay进行设置父线程里的本地变量给当前子线程,任务执行完毕,会调用restore恢复该子线程原生的本地变量,当然重点还是稍显复杂的上下文管理部分。
本文并不涉及到它详细的原理,建议有兴趣者可以上它官网看看(不算很复杂),全中文的也好理解,并且还附有其执行时序图。
说明:它还支持javaagent完全零侵入方式接入,可以说是非常强大和好用的一个基础工具,值得使用明白,对中间件团队能提供良好的支持。
使用场景
官方流出了其四大使用场景:
- 分布式跟踪系统(链路追踪)
- 日志收集记录系统上下文(MDC)
- Session级Cache
- 应用容器或上层框架跨应用代码给下层SDK传递信息
其中场景1和场景2在全链路压测平台打造的时候都会触及到,所以基于TTL来解决这些问题不失外一个非常好的选择。
总结
ThreadLocal的一步步的进化,最终来到了TransmittableThreadLocal,它能够满足我们对线程间数据传递的几乎一切遐想,这对我们做类似于全链路压测这种平台的时候非常有帮助,期待成效。