InheritableThreadLocal 继承自ThreadLocal,重写了childValue、getMap、createMap 方法,主要作用是子线程能够读取父线程的变量
看下这个类
public class InheritableThreadLocal<T> extends ThreadLocal<T> {
protected T childValue(T parentValue) {
return parentValue;
}
//返回的是Thread类的inheritableThreadLocals,而ThreadLocal使用的是threadLocals变量
ThreadLocalMap getMap(Thread t) {
return t.inheritableThreadLocals;
}
void createMap(Thread t, T firstValue) {
t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
}
}
示例:
public class InheritableThreadLocalTest {
private static final InheritableThreadLocal<String> threadLocal = new InheritableThreadLocal<String> ();
public static void main(String [] args) throws InterruptedException {
threadLocal.set("hello world");
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//threadLocal.set("son thread");
System.out.println("thread:" + threadLocal.get());
}
});
thread.start();
thread.join();
System.out.println("main:" + threadLocal.get());
}
}
输出:
thread:hello world
main:hello world
这里如果我在子线程中set了一个新值,那结果会怎么样?
发现父线程的值没有改变
thread:son thread
main:hello world
源码剖析
- 首先从新建子线程开始分析,这里主要就是将父线程的值copy到子线程中
//构造函数
public Thread(Runnable target) {
init(null, target, "Thread-" + nextThreadNum(), 0);
}
//直接跳到,最终的init方法
private void init(ThreadGroup g, Runnable target, String name,
long stackSize, AccessControlContext acc,
boolean inheritThreadLocals) {
if (name == null) {
throw new NullPointerException("name cannot be null");
}
this.name = name;
Thread parent = currentThread();
SecurityManager security = System.getSecurityManager();
//....省略中间部分,看主要的
//获取父线程的inheritableThreadLocals变量,如果不为空就copy父线程中的变量到子线程
if (inheritThreadLocals && parent.inheritableThreadLocals != null)
this.inheritableThreadLocals =
ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
/* Stash the specified stack size in case the VM cares */
this.stackSize = stackSize;
/* Set thread ID */
tid = nextThreadID();
}
//ThreadLocal.createInheritedMap方法
static ThreadLocalMap createInheritedMap(ThreadLocalMap parentMap) {
return new ThreadLocalMap(parentMap);
}
//ThreadLocalMap(parentMap) 方法
private ThreadLocalMap(ThreadLocalMap parentMap) {
Entry[] parentTable = parentMap.table;
int len = parentTable.length;
setThreshold(len);
//新建一个Entry数组,Entry继承了WeakReference,key为ThreadLocal类型
//这是为了在大数据量的时候,方便GC来回收已经失效的数据
table = new Entry[len];
for (int j = 0; j < len; j++) {
Entry e = parentTable[j];
if (e != null) {
@SuppressWarnings("unchecked")
ThreadLocal<Object> key = (ThreadLocal<Object>) e.get();
if (key != null) {
//InheritableThreadLocal 重写了childValue,返回value值
Object value = key.childValue(e.value);
Entry c = new Entry(key, value);
//计算数组索引位置,使用"线性探测法"
int h = key.threadLocalHashCode & (len - 1);
//如果当前位置有值,指针需要移到下一个位置,直到找到不为null的位置
while (table[h] != null)
h = nextIndex(h, len);
table[h] = c;
size++;
}
}
}
}
- 子线程获取父线程值分析,看ThreadLocal的get方法
public T get() {
Thread t = Thread.currentThread();
//实际调用InheritableThreadLocal类getMap方法,getMap返回的是当前线程的inheritableThreadLocals变量
//每个线程都有,是Thread类的局部变量
ThreadLocalMap map = getMap(t);
//如果是null会初始化一个value为null的ThreadLocalMap
if (map != null) {
//this就是InheritableThreadLocal类,看下getEntry方法
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
@SuppressWarnings("unchecked")
T result = (T)e.value;
return result;
}
}
return setInitialValue();
}
//这里就是从table数组中去获取索引对应的值,这个table已经在new Thread的时候copy了父线程的数据
private Entry getEntry(ThreadLocal<?> key) {
int i = key.threadLocalHashCode & (table.length - 1);
Entry e = table[i];
if (e != null && e.get() == key)
return e;
else
//如果条件不成立,会循环整个table,并处理key失效的数据
//如果遍历完还没找到,就返回null
return getEntryAfterMiss(key, i, e);
}
总结
- 子线程能够读取父线程数据,实际原因是新建子线程的时候,会从父线程copy数据
- InheritableThreadLocal 继承了ThreadLocal,并重写childValue、getMap、createMap,对该类的操作实际上是对线程ThreadLocalMap的操作
其他文章阅读:
ThreadLocal源码分析
转载于:https://my.oschina.net/itsaysay/blog/3095843
分享到:
相关推荐
《InheritableThreadLocal & ThreadLocal 深度解析》 在Java编程中,线程局部变量(ThreadLocal)和可继承线程局部变量(InheritableThreadLocal)是两种非常重要的工具,它们允许我们在多线程环境中创建独立于线程...
ThreadLocal、InheritableThreadLocal详解 多线程访问同一个共享变量时,容易出现并发冲突,为了保证线程的安全,一般使用者在访问共享变量时,需要进行适量的同步。而ThreadLocal提供了线程的私有变量,每个线程都...
Java 多线程编程之 InheritableThreadLocal Java 多线程编程之 InheritableThreadLocal 是一种特殊的 ThreadLocal 类,它允许子线程继承父线程中的值,从而实现了父子线程之间的值传递。 InheritableThreadLocal ...
Java_为frameworkmiddleware提供了一个增强的InheritableThreadLocal,即使使
本文将深入解析这两个概念以及它们在Android环境下的工作原理。 **ThreadLocal** 是一个线程局部变量,它为每个线程提供独立的副本。这意味着每个线程都拥有ThreadLocal变量的私有实例,它们之间互不干扰。在...
InheritableThreadLocal跟ThreadLocal差不多,关键点在Thread#init方法中会对Thread中的实例变量inheritableThreadLocals进行赋值操作,将父线程的本地变量复制到子线程中 首先通过ServiceLoader.load方法生成一个...
2 InheritableThreadLocal 的局限性:InheritableThreadLocal 仅限于父线程给子线程来传递数据,不能解决跨线程池之间的数据传递问题。 3 TransmittableThreadLocal 的实现原理:TransmittableThreadLocal 是基于...
:pushpin: TransmittableThreadLocal(TTL) :pushpin: | :open_book:中文文档 :wrench:功能 :backhand_index_pointing_right:在使用线程池等会池化复用线程的执行组件情况下,提供ThreadLocal值的...
5. InheritableThreadLocal作用和实现方式 ? 6. InheritableThreadLocal所带来的问题? 7. 如何解决线程池异步值传递问题 ( transmittable-thread-local)? HashMap ConcurrentHashMap相关 9. HashMap为什么线程...
InheritableThreadLocal<String> context = new InheritableThreadLocal(); context.set("contextValue"); ``` 使用Spring的scoped beans传递上下文信息 Spring的scoped beans是一个基于作用域的bean,它可以在不同...
Scoped Value 解决了在线程之间共享变量的问题,ThreadLocal 和 InheritableThreadLocal 都有其缺陷。ThreadLocal 需要手动清理,且变量不能被子线程继承;InheritableThreadLocal 可以共享信息,但是数据会拷贝多份...
`Thread`, `Compiler`, `Process`, `ThreadGroup`, `Double`, `Runtime`, `ThreadLocal`, `Float`, `RuntimePermission`, `Throwable`, `InheritableThreadLocal`, `SecurityManager`, 和 `Void`。这些类不仅提供了...
**其他并发工具类与锁原理**:这部分内容涉及ThreadLocal的工作原理、InheritableThreadLocal如何传递线程局部变量、CyclicBarrier和CountDownLatch的区别与用法、Semaphore信号量机制、CopyOnWriteArrayList如何...
`RequestZoneLabelContext`使用`InheritableThreadLocal`来保存线程上下文,这样即使在请求处理过程中产生了新的线程,这些线程也能继承到标签信息。当请求结束时,会清除`RequestZoneLabelContext`中的信息,防止...
`SecurityContextHolder` 类提供了获取和设置安全上下文的方法,通常通过 `SecurityContextHolder.MODE_INHERITABLETHREADLOCAL` 模式在多线程环境中传播。 **6. ** **用户详情服务(UserDetailsService)** 用户...
5. **启动安全上下文**:在Spring的初始化代码中,调用`SecurityContextHolder.setStrategyName(SecurityContextHolder.MODE_INHERITABLETHREADLOCAL);`来激活安全上下文。 6. **测试和调试**:使用模拟用户或真实...
2. **配置SecurityContextHolder策略**:设置SecurityContextHolder的策略为`MODE_INHERITABLETHREADLOCAL`,使得当前线程中的安全上下文可以在子线程中继承。 3. **配置Spring Security核心组件**:创建一个名为`...