`

ThreadLocal及InheritableThreadLocal的原理剖析

阅读更多

我们知道,线程的不安全问题,主要是由于多线程并发读取一个变量而引起的,那么有没有一种办法可以让一个变量是线程独有的呢,这样不就可以解决线程安全问题了么。其实JDK已经为我们提供了ThreadLocal这个东西。


ThreadLocal基本使用

当使用ThreadLocal维护变量时,ThreadLocal为每个使用该变量的线程提供独立的变量副本,所以每一个线程都可以独立地改变自己的副本,而不会影响其它线程所对应的副本。
ThreadLocal 的主要方法有这么几个:

1
2
3
4
initialValue 初始化
set 赋值
get 取值
remove 清空

下面来看一个简单的使用代码示例:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public class ThreadLocalDemo {
    private static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>() {
        @Override
        public Integer initialValue() {
            return 0;
        }
    };
    static class ThreadDemo implements Runnable {
        @Override
        public void run() {
            for (int i = 0; i < 1000; i++) {
                threadLocal.set(threadLocal.get() + 1);
            }
            System.out.println("thread :" + Thread.currentThread().getId() + " is" + threadLocal.get());
        }
    }
    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            new Thread(new ThreadDemo()).start();
        }
    }
}

上方代码使用了10个线程循环对一个threadLocal的值进行一千次的加法,如果我们不知道ThreadLocal的原理的话我们可能会觉得最后打印的值一定是1000、2000、3000。。10000或者是线程不安全的值。
但是如果你执行这段代码你会发现最后打印的都是1000。


ThreadLocal原理剖析

现在我们来看一下ThreadLocal是如何实现为每个线程单独维护一个变量的呢。
先来看一下初始化方法。

1
2
3
protected T initialValue() {
        return null;
    }

initialValue 默认是返回空的,所以为了避免空指针问题重写了这个方法设置了默认返回值为0,但是呢,虽然这个方法好像是设置默认值的,但是还没有生效,具体请接着往下看。

1
2
3
4
5
6
7
8
public void set(T value) {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
    }

我们可以看到set方法首先会获取当前线程,然后通过一个getMap方法获取了ThreadLocalMap,接着来看一下这个map是怎么来的呢。

1
2
3
ThreadLocalMap getMap(Thread t) {
       return t.threadLocals;
   }

这个map是在Thread类维护的一个map,下方是Thread类维护的此变量。默认这个map是空的。

1
ThreadLocal.ThreadLocalMap threadLocals = null;

接着往下看代码,如果获取的时候map不为空,则通过set方法把Thread类的threadLocals变量更新。如果是第一次创建的时候则初始化Thread的threadLocals变量。
下方是createMap的代码:

1
2
3
void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

接下来看个get方法就比较容易理解了。

1
2
3
4
5
6
7
8
9
10
11
12
13
public T get() {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        return setInitialValue();
    }

注意关注最后的一个return,看到调用的这个方法名我们就可以发现这个ThreadLocal的初始化原来是当第一调用get方法时如果还没有被set的时候才会去获取initialValue 方法的返回值。

1
2
3
4
5
6
7
8
9
10
private T setInitialValue() {
        T value = initialValue();
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
        return value;
    }


使用ThreadLocal最应该注意的事项

首先来看一下线程退出的办法:

1
2
3
4
5
6
7
8
9
10
11
12
private void exit() {
        if (group != null) {
            group.threadTerminated(this);
            group = null;
        }
        target = null;
        threadLocals = null;
        inheritableThreadLocals = null;
        inheritedAccessControlContext = null;
        blocker = null;
        uncaughtExceptionHandler = null;
    }

我们看到当线程结束的时候上方第7行会把ThreadLocal的值制为空,这个东西本身是没问题的。但是,如果你是使用的线程池,这个问题可就大了!!!
要知道线程池里的线程执行完一个任务之后紧接着下一个,这中间线程可不会结束,下一个任务获得Thread的值可是上一个任务的遗留数据。
下面是这个问题的示例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
private static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>() {
        @Override
        public Integer initialValue() {
            return 0;
        }
    };
    static class ThreadDemo implements Runnable {
        @Override
        public void run() {
            for (int i = 0; i < 1000; i++) {
                threadLocal.set(threadLocal.get() + 1);
            }
            System.out.println("thread :" + Thread.currentThread().getId() + " is" + threadLocal.get());
            //threadLocal.remove();
        }
    }
    public static void main(String[] args) {
        ExecutorService executorService= Executors.newFixedThreadPool(5);
        for (int i = 0; i < 10; i++) {
            executorService.submit(new Thread(new ThreadDemo()));
        }
    }

执行这段代码你就会发现同样的操作在线程池里已经得不到一样的结果了。想要解决这种问题也很简单,只需要把ThreadLocal的值在线程执行完清空就可以了。把第14行注释的代码放开再执行以下你就明白了。


InheritableThreadLocal

其实ThreadLocal还有一个比较强大的子类InheritableThreadLocal,它呢可以把父线程生成的变量传递给子线程。
下面来看一下代码示例:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class InheritableThreadLocalDemo {
    private static  InheritableThreadLocal<Integer> inheritableThreadLocal = new  InheritableThreadLocal<Integer>();
    static class ThreadDemo implements Runnable {
        @Override
        public void run() {
            for (int i = 0; i < 1000; i++) {
                inheritableThreadLocal.set(inheritableThreadLocal.get() + 1);
            }
            System.out.println("thread :" + Thread.currentThread().getId() + " is" + inheritableThreadLocal.get());
        }
    }
    public static void main(String[] args) {
        inheritableThreadLocal.set(24);
        for (int i = 0; i < 10; i++) {
            new Thread(new ThreadDemo()).start();
        }
    }
}

执行代码会发现程序输出全是1024,这就是因为InheritableThreadLocal吧在主线程设置的值24传递到了那10个子线程中。


InheritableThreadLocal原理剖析

接下来我们来看一下InheritableThreadLocal为什么可以实现这种功能呢。
InheritableThreadLocal是ThreadLocal的子类,
与ThreadLocal相同的set方法

1
2
3
4
5
6
7
8
public void set(T value) {
       Thread t = Thread.currentThread();
       ThreadLocalMap map = getMap(t);
       if (map != null)
           map.set(this, value);
       else
           createMap(t, value);
   }

不同点是InheritableThreadLocal重写了createMap方法,将值赋值给了线程的inheritableThreadLocals变量。

1
2
3
void createMap(Thread t, T firstValue) {
        t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
    }

再跟进去Thread类的源码看inheritableThreadLocals变量你会发现:我去,这不是跟Threadlocal一样么,同样初始值为null,线程退出的时候清空。没错,就是这样的。也就是说它其实也是一个线程私有的变量,ThreadLocal的功能它是都有的。

那么它又是怎么把父线程的变量传递到子线程的呢?
接着看Thread的构造方法

1
2
3
public Thread() {
    init(null, null, "Thread-" + nextThreadNum(), 0);
}

一路追踪init方法你会看见这段代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
private void init(ThreadGroup g, Runnable target, String name,
                      long stackSize, AccessControlContext acc) {
        if (name == null) {
            throw new NullPointerException("name cannot be null");
        }
        this.name = name;
        Thread parent = currentThread();
        SecurityManager security = System.getSecurityManager();
        if (g == null) {
            if (security != null) {
                g = security.getThreadGroup();
            }
            if (g == null) {
                g = parent.getThreadGroup();
            }
        }
        g.checkAccess();
        if (security != null) {
            if (isCCLOverridden(getClass())) {
                security.checkPermission(SUBCLASS_IMPLEMENTATION_PERMISSION);
            }
        }
        g.addUnstarted();
        this.group = g;
        this.daemon = parent.isDaemon();
        this.priority = parent.getPriority();
        if (security == null || isCCLOverridden(parent.getClass()))
            this.contextClassLoader = parent.getContextClassLoader();
        else
            this.contextClassLoader = parent.contextClassLoader;
        this.inheritedAccessControlContext =
                acc != null ? acc : AccessController.getContext();
        this.target = target;
        setPriority(priority);
        if (parent.inheritableThreadLocals != null)
            this.inheritableThreadLocals =
                ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
        this.stackSize = stackSize;
        tid = nextThreadID();
    }

仔细观察倒数第5行到倒数第二行你就明白了。

本文所有源码https://github.com/shiyujun/syj-study-demo

 

 



 

  • 大小: 171.6 KB
0
0
分享到:
评论

相关推荐

    java多线程编程之InheritableThreadLocal

    * InheritableThreadLocal 的实现原理和源码分析 * InheritableThreadLocal 与 ThreadLocal 的区别 * 使用 InheritableThreadLocal 需要注意的线程安全问题 * InheritableThreadLocal 在多线程编程中的应用场景和...

    JAVA面试题.docx

    **其他并发工具类与锁原理**:这部分内容涉及ThreadLocal的工作原理、InheritableThreadLocal如何传递线程局部变量、CyclicBarrier和CountDownLatch的区别与用法、Semaphore信号量机制、CopyOnWriteArrayList如何...

    Java进阶知识点汇总.pdf

    ### Java进阶知识点详解 #### 第一章:基本语法 ##### 关键字 - **static**:用于定义...以上是对Java进阶知识点的详细解析,覆盖了基本语法、JDK源码分析等多个方面,有助于深入理解Java语言的核心机制及高级特性。

    金煤婚恋 92版本, 去授权,仅供学习,商业使用请支持正版

    金煤婚恋 92版本, 去授权,仅供学习,商业使用请支持正版

    基于springboot框架的小区团购管理系统平台的设计与实现(Java项目编程实战+完整源码+毕设文档+sql文件+学习练手好项目).zip

    传统办法管理信息首先需要花费的时间比较多,其次数据出错率比较高,而且对错误的数据进行更改也比较困难,最后,检索数据费事费力。因此,在计算机上安装小区团购管理软件来发挥其高效地信息处理的作用,可以规范信息管理流程,让管理工作可以系统化和程序化,同时,小区团购管理的有效运用可以帮助管理人员准确快速地处理信息。 小区团购管理在对开发工具的选择上也很慎重,为了便于开发实现,选择的开发工具为Eclipse,选择的数据库工具为Mysql。以此搭建开发环境实现小区团购管理的功能。其中管理员管理用户,新闻公告。 小区团购管理是一款运用软件开发技术设计实现的应用系统,在信息处理上可以达到快速的目的,不管是针对数据添加,数据维护和统计,以及数据查询等处理要求,小区团购管理都可以轻松应对。 关键词:小区团购管理;SSM框架,系统分析,数据库设计

    机器学习(预测模型):初创企业失败(案例/情况等)数据集

    数据集是一个关于初创企业失败案例的详细数据集,由Daglox Kankwanda于2025年2月27日发布在Kaggle上。该数据集包含483家初创企业的失败信息,数据来源于CB Insights的“初创企业失败后分析”汇编。 数据集涵盖了多个行业的初创企业,提供了丰富的字段信息,包括公司名称、行业领域、失败原因、资金筹集情况、运营时长、地理位置等。这些字段为研究者提供了多维度的视角,可以深入分析初创企业失败的共性和差异。 通过该数据集,研究者可以探索不同行业初创企业的失败模式,例如,某些行业可能因市场竞争激烈而失败,而另一些行业可能因技术瓶颈或资金不足而终止。此外,数据集还提供了失败原因的详细分类,如产品市场契合度不足、团队问题、资金链断裂等,为创业者和投资者提供了宝贵的经验教训。 该数据集不仅适用于商业分析和研究,还可以用于机器学习模型的训练,例如预测初创企业的成功概率或识别潜在的失败风险因素。对于希望深入了解创业生态和风险的研究者、创业者以及投资者来说,“Startup Failures”数据集是一个极具价值的资源。

    Swift-Button封装

    Swift-Button封装

    汽车嵌入式系统中AUTOSAR TcpIp模块的技术解析及应用场景

    内容概要:本文档详尽介绍了AUTOSAR TcpIp模块的功能与设计,作为AUTOSAR通信栈的核心部分,它提供了完整的TCP/IP协议栈解决方案,包括TCP和UDP在内的多种协议以及IPv4和IPv6的支持。文档涵盖模块的总体架构设计,详细描绘其状态管理和数据传输机制,并阐述与其它相关模块之间的交互协作。同时,对初始化流程、Socket操作以及数据发送接收的具体过程进行了逐步拆解与解释。还介绍了针对可能出现故障时的错误处理措施。 适合人群:汽车电子工程师、嵌入式系统开发者、研究AUTOSAR规范及其网络协议栈实现的专业人士。 使用场景及目标:本文件主要用于深入了解和支持汽车行业内基于AUTOSAR平台的网络协议部署情况;为设计符合工业标准的车载信息系统打下坚实的基础;对于提升产品性能和安全性具有重要的指导价值。 其他说明:作者提供了一个详细的参考资料链接,感兴趣的读者可以进一步访问获取更多信息。此外,在实际工作中遇到的问题也可以参考文中所提到的各种处理方法来进行有效的排查和解决。

    Thinkpad T480s的BIOS升级软件 【版本n22uj39w】

    Thinkpad T480s的BIOS升级软件 【版本n22uj39w】

    特易通国产对讲机TYT-T3 v1.0中英写频软件

    特易通国产对讲机TYT-T3 v1.0中英写频软件

    Swift-ViewController+SP

    Swift-ViewController+SP

    Swift-PDFImage

    Swift-PDFImage

    VMware-Workstation-Full-17.6.2-24409262.x86-64.rar

    VMware-Workstation-Full-17.6.2-24409262.x86_64.rar Linux版本 Vmware是一款领先的虚拟化软件,为用户提供强大的虚拟机平台。通过使用Vmware,用户可以在一台物理计算机上同时运行多个虚拟操作系统,实现资源的高效利用和隔离。它提供了灵活的配置选项、快速的性能和可靠的安全性,适用于个人用户、企业和数据中心。无论是开发测试、应用部署还是服务器管理,Vmware都是一个强大而可靠的工具,为用户提供了简单且可扩展的虚拟化解决方案。

    电子电气架构下智能座舱与车载基础软件的发展现状与趋势

    内容概要:本文首先介绍了智能座舱的概念及其组成结构,详细解释了硬件、软件及交互三个部分的功能,并阐述了智能座舱从电子座舱到智能移动空间的不同发展阶段,重点讨论了语音交互和AR-HUD两大核心技术的发展路径及未来发展方向。接下来介绍车载基础软件的重要性及其分类,强调其在智能汽车发展中扮演的角色。文中指出,在软件定义汽车的趋势下,车载基础软件成为衔接硬件和应用软件的核心枢纽,特别是在软硬件分层解耦背景下,其作用日益凸显。最后探讨了当前国内车载基础软件行业的竞争情况与发展趋势。文章还分析了行业发展面临的高技术壁垒、高转换成本和高退出壁垒等问题,指出了车载基础软件对未来汽车产业变革的意义。 适用人群:从事汽车电子产品设计的研发人员、相关专业在校学生以及对汽车行业新技术感兴趣的爱好者。 使用场景及目标:该文档适合用作学习资料或研究参考资料,旨在帮助读者深入了解智能座舱的构成要素和技术演进,掌握车载基础软件的架构特点,洞悉该领域的市场动向。 其他说明:文中部分内容带有作者个人感悟和思考,但这并不影响其专业价值,反而增加了人文气息,有助于激发工程师的人文关怀和社会责任感。

    JAVA面试基础篇章-I/O流

    JAVA面试最新最有效的全网顶级资料,免费提供,码字不易,你的关注就是博主最大的动力。

    Swift-String-Extension

    Swift-String-Extension

    基于springboot框架的物流管理系统的设计与实现(Java项目编程实战+完整源码+毕设文档+sql文件+学习练手好项目).zip

    社会发展日新月异,用计算机应用实现数据管理功能已经算是很完善的了,但是随着移动互联网的到来,处理信息不再受制于地理位置的限制,处理信息及时高效,备受人们的喜爱。本次开发一套物流管理系统有管理员和用户两个角色。管理员功能有个人中心,用户管理,车辆信息管理,公告信息管理,司机管理,物流信息管理,运单信息管理,车辆类型管理,车辆状态管理,公告类型管理,物流状态管理,运单状态管理。用户可以注册登录,查看公告信息,查看物流信息,可以添加运单信息。物流管理系统服务端用Java开发,用Spring Boot框架开发的网站后台,数据库用到了MySQL数据库作为数据的存储。这样就让用户用着方便快捷,都通过同一个后台进行业务处理,而后台又可以根据并发量做好部署,用硬件和软件进行协作,满足于数据的交互式处理,让用户的数据存储更安全,得到数据更方便。 关键字:物流管理系统;Spring Boot框架;Java;MySQL

    线性表_单链表_创建不重复字母_学习示例_1741871934.zip

    数据结构学习

    KaihongOS-System-Component 4.1.2.17(RT00E000C000M68A).part2.rar

    KaihongOS_System_Component 4.1.2.17(RT00E000C000M68A).part2.rar 请勿下载,请联系对应销售获取。

    数据结构_算法_硬核递归_学习资源包_1741867700.zip

    数据结构学习

Global site tag (gtag.js) - Google Analytics