SkyWalking如何实现跨线程Trace传递
一、概述
SkyWalking 的中构建 Trace 信息时会借助 ThreadLocal来存储一些上下文信息,当遇到跨线程的时候,如果 Trace 的上下文信息没有传递到新线程的ThreadLocal 中,那么链路就断开了。那么SkyWalking是如何解决这个问题的呢?
二、实现原理
通过对 Callable、Runnable、Supplier 这3种接口的实现者进行增强拦截,将 Trace 的上下文信息传递到子线程中,实现了异步链路追踪。
三、内部原理
线程A
- 调用ContextManager.capture()将 Trace 的上下文信息保存到一个ContextSnapshot的实例中。
- ContextSnapshot则被附加到任务对象的SkyWalking-DynamicField属性中,那么当线程B接触到任务对象时,便能感知到ContextSnapshot。
线程B
- 线程B中,在任务对象的任务方法被执行前,从任务对象的SkyWalking-DynamicField属性中获取ContextSnapshot对象,从中解析出 Trace 的信息后,存储到线程B的线程上下文中。