首页 / JAVA / Java并发编程：深入剖析ThreadLocal

Java并发编程：深入剖析ThreadLocal

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java并发编程：深入剖析ThreadLocal，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8590字，纯文字阅读大概需要13分钟。

内容图文

引用：http://www.cnblogs.com/dolphin0520/

　想必很多朋友对ThreadLocal并不陌生，今天我们就来一起探讨下ThreadLocal的使用方法和实现原理。首先，本文先谈一下对ThreadLocal的理解，然后根据ThreadLocal类的源码分析了其实现原理和使用需要注意的地方，最后给出了两个应用场景。

　　以下是本文目录大纲：

　　一.对ThreadLocal的理解

　　二.深入解析ThreadLocal类

　　三.ThreadLocal的应用场景

　　若有不正之处请多多谅解，并欢迎批评指正。

　　请尊重作者劳动成果，转载请标明原文链接：

　　http://www.cnblogs.com/dolphin0520/p/3920407.html

一.对ThreadLocal的理解

　　ThreadLocal，很多地方叫做线程本地变量，也有些地方叫做线程本地存储，其实意思差不多。可能很多朋友都知道ThreadLocal为变量在每个线程中都创建了一个副本，那么每个线程可以访问自己内部的副本变量。

　　这句话从字面上看起来很容易理解，但是真正理解并不是那么容易。

　　我们还是先来看一个例子：

class ConnectionManager {

private static Connection connect = null;

public static Connection openConnection() {

if (connect == null ){

connect = DriverManager.getConnection();

}

return connect;

}

public static void closeConnection() {

if (connect!= null )

connect.close();

}

　　假设有这样一个数据库链接管理类，这段代码在单线程中使用是没有任何问题的，但是如果在多线程中使用呢？很显然，在多线程中使用会存在线程安全问题：第一，这里面的2个方法都没有进行同步，很可能在openConnection方法中会多次创建connect；第二，由于connect是共享变量，那么必然在调用connect的地方需要使用到同步来保障线程安全，因为很可能一个线程在使用connect进行数据库操作，而另外一个线程调用closeConnection关闭链接。

　　所以出于线程安全的考虑，必须将这段代码的两个方法进行同步处理，并且在调用connect的地方需要进行同步处理。

　　这样将会大大影响程序执行效率，因为一个线程在使用connect进行数据库操作的时候，其他线程只有等待。

　　那么大家来仔细分析一下这个问题，这地方到底需不需要将connect变量进行共享？事实上，是不需要的。假如每个线程中都有一个connect变量，各个线程之间对connect变量的访问实际上是没有依赖关系的，即一个线程不需要关心其他线程是否对这个connect进行了修改的。

　　到这里，可能会有朋友想到，既然不需要在线程之间共享这个变量，可以直接这样处理，在每个需要使用数据库连接的方法中具体使用时才创建数据库链接，然后在方法调用完毕再释放这个连接。比如下面这样：

class ConnectionManager {

private Connection connect = null;

public Connection openConnection() {

if (connect == null ){

connect = DriverManager.getConnection();

}

return connect;

}

public void closeConnection() {

if (connect!= null )

connect.close();

}

class Dao{

public void insert() {

ConnectionManager connectionManager = new ConnectionManager();

Connection connection = connectionManager.openConnection();

//使用connection进行操作

connectionManager.closeConnection();

}

　　这样处理确实也没有任何问题，由于每次都是在方法内部创建的连接，那么线程之间自然不存在线程安全问题。但是这样会有一个致命的影响：导致服务器压力非常大，并且严重影响程序执行性能。由于在方法中需要频繁地开启和关闭数据库连接，这样不尽严重影响程序执行效率，还可能导致服务器压力巨大。

　　那么这种情况下使用ThreadLocal是再适合不过的了，因为ThreadLocal在每个线程中对该变量会创建一个副本，即每个线程内部都会有一个该变量，且在线程内部任何地方都可以使用，线程之间互不影响，这样一来就不存在线程安全问题，也不会严重影响程序执行性能。

　　但是要注意，虽然ThreadLocal能够解决上面说的问题，但是由于在每个线程中都创建了副本，所以要考虑它对资源的消耗，比如内存的占用会比不使用ThreadLocal要大。

二.深入解析ThreadLocal类

　　在上面谈到了对ThreadLocal的一些理解，那我们下面来看一下具体ThreadLocal是如何实现的。

　　先了解一下ThreadLocal类提供的几个方法：

public T get() { }

public void set(T value) { }

public void remove() { }

protected T initialValue() { }

　　get()方法是用来获取ThreadLocal在当前线程中保存的变量副本，set()用来设置当前线程中变量的副本，remove()用来移除当前线程中变量的副本，initialValue()是一个protected方法，一般是用来在使用时进行重写的，它是一个延迟加载方法，下面会详细说明。

　　首先我们来看一下ThreadLocal类是如何为每个线程创建一个变量的副本的。

　　先看下get方法的实现：

技术分享图片

　　第一句是取得当前线程，然后通过getMap(t)方法获取到一个map，map的类型为ThreadLocalMap。然后接着下面获取到<key,value>键值对，注意这里获取键值对传进去的是 this，而不是当前线程t。

　　如果获取成功，则返回value值。

　　如果map为空，则调用setInitialValue方法返回value。

　　我们上面的每一句来仔细分析：

　　首先看一下getMap方法中做了什么：

技术分享图片

　　可能大家没有想到的是，在getMap中，是调用当期线程t，返回当前线程t中的一个成员变量threadLocals。

　　那么我们继续取Thread类中取看一下成员变量threadLocals是什么：

技术分享图片

　　实际上就是一个ThreadLocalMap，这个类型是ThreadLocal类的一个内部类，我们继续取看ThreadLocalMap的实现：

技术分享图片

　　可以看到ThreadLocalMap的Entry继承了WeakReference，并且使用ThreadLocal作为键值。

　　然后再继续看setInitialValue方法的具体实现：

技术分享图片

　　很容易了解，就是如果map不为空，就设置键值对，为空，再创建Map，看一下createMap的实现：

技术分享图片

　　至此，可能大部分朋友已经明白了ThreadLocal是如何为每个线程创建变量的副本的：

　　首先，在每个线程Thread内部有一个ThreadLocal.ThreadLocalMap类型的成员变量threadLocals，这个threadLocals就是用来存储实际的变量副本的，键值为当前ThreadLocal变量，value为变量副本（即T类型的变量）。

　　初始时，在Thread里面，threadLocals为空，当通过ThreadLocal变量调用get()方法或者set()方法，就会对Thread类中的threadLocals进行初始化，并且以当前ThreadLocal变量为键值，以ThreadLocal要保存的副本变量为value，存到threadLocals。

　　然后在当前线程里面，如果要使用副本变量，就可以通过get方法在threadLocals里面查找。

　　下面通过一个例子来证明通过ThreadLocal能达到在每个线程中创建变量副本的效果：

public class Test {

ThreadLocal<Long> longLocal = new ThreadLocal<Long>();

ThreadLocal<String> stringLocal = new ThreadLocal<String>();

public void set() {

longLocal.set(Thread.currentThread().getId());

stringLocal.set(Thread.currentThread().getName());

}

public long getLong() {

return longLocal.get();

}

public String getString() {

return stringLocal.get();

}

public static void main(String[] args) throws InterruptedException {

final Test test = new Test();

test.set();

System.out.println(test.getLong());

System.out.println(test.getString());

Thread thread1 = new Thread(){

public void run() {

test.set();

System.out.println(test.getLong());

System.out.println(test.getString());

};

thread1.start();

thread1.join();

System.out.println(test.getLong());

System.out.println(test.getString());

}

　　这段代码的输出结果为：

技术分享图片

　　从这段代码的输出结果可以看出，在main线程中和thread1线程中，longLocal保存的副本值和stringLocal保存的副本值都不一样。最后一次在main线程再次打印副本值是为了证明在main线程中和thread1线程中的副本值确实是不同的。

　　总结一下：

　　1）实际的通过ThreadLocal创建的副本是存储在每个线程自己的threadLocals中的；

　　2）为何threadLocals的类型ThreadLocalMap的键值为ThreadLocal对象，因为每个线程中可有多个threadLocal变量，就像上面代码中的longLocal和stringLocal；

　　3）在进行get之前，必须先set，否则会报空指针异常；

　　如果想在get之前不需要调用set就能正常访问的话，必须重写initialValue()方法。

　　　因为在上面的代码分析过程中，我们发现如果没有先set的话，即在map中查找不到对应的存储，则会通过调用setInitialValue方法返回i，而在setInitialValue方法中，有一个语句是T value = initialValue()，而默认情况下，initialValue方法返回的是null。

技术分享图片

　　看下面这个例子：

public class Test {

ThreadLocal<Long> longLocal = new ThreadLocal<Long>();

ThreadLocal<String> stringLocal = new ThreadLocal<String>();

public void set() {

longLocal.set(Thread.currentThread().getId());

stringLocal.set(Thread.currentThread().getName());

}

public long getLong() {

return longLocal.get();

}

public String getString() {

return stringLocal.get();

}

public static void main(String[] args) throws InterruptedException {

final Test test = new Test();

System.out.println(test.getLong());

System.out.println(test.getString());

Thread thread1 = new Thread(){

public void run() {

test.set();

System.out.println(test.getLong());

System.out.println(test.getString());

};

thread1.start();

thread1.join();

System.out.println(test.getLong());

System.out.println(test.getString());

}

　　在main线程中，没有先set，直接get的话，运行时会报空指针异常。

　　但是如果改成下面这段代码，即重写了initialValue方法：

public class Test {

ThreadLocal<Long> longLocal = new ThreadLocal<Long>(){

protected Long initialValue() {

return Thread.currentThread().getId();

};

ThreadLocal<String> stringLocal = new ThreadLocal<String>(){;

protected String initialValue() {

return Thread.currentThread().getName();

};

public void set() {

longLocal.set(Thread.currentThread().getId());

stringLocal.set(Thread.currentThread().getName());

}

public long getLong() {

return longLocal.get();

}

public String getString() {

return stringLocal.get();

}

public static void main(String[] args) throws InterruptedException {

final Test test = new Test();

test.set();

System.out.println(test.getLong());

System.out.println(test.getString());

Thread thread1 = new Thread(){

public void run() {

test.set();

System.out.println(test.getLong());

System.out.println(test.getString());

};

thread1.start();

thread1.join();

System.out.println(test.getLong());

System.out.println(test.getString());

}

　　就可以直接不用先set而直接调用get了。

三.ThreadLocal的应用场景

　　最常见的ThreadLocal使用场景为用来解决数据库连接、Session管理、限流操作等。

　　如：

private static ThreadLocal<Connection> connectionHolder

= new ThreadLocal<Connection>() {

public Connection initialValue() {

return DriverManager.getConnection(DB_URL);

}

};

public static Connection getConnection() {

return connectionHolder.get();

}

　　下面这段代码摘自：

http://www.iteye.com/topic/103804

private static final ThreadLocal threadSession = new ThreadLocal();

public static Session getSession() throws InfrastructureException {

Session s = (Session) threadSession.get();

try {

if (s == null) {

s = getSessionFactory().openSession();

threadSession.set(s);

}

} catch (HibernateException ex) {

throw new InfrastructureException(ex);

}

return s;

}

　　参考资料：

　　《深入理解Java虚拟机》

　　《Java编程思想》

http://ifeve.com/thread-management-10/

http://www.ibm.com/developerworks/cn/java/j-threads/index3.html

http://www.iteye.com/topic/103804

http://www.iteye.com/topic/777716

http://www.iteye.com/topic/757478

http://blog.csdn.net/ghsau/article/details/15732053

http://ispring.iteye.com/blog/162982

http://blog.csdn.net/imzoer/article/details/8262101

http://www.blogjava.net/wumi9527/archive/2010/09/10/331654.html

http://bbs.csdn.net/topics/380049261

原文：https://www.cnblogs.com/xxj-bigshow/p/9166841.html

内容总结

以上是互联网集市为您收集整理的Java并发编程：深入剖析ThreadLocal全部内容，希望文章能够帮你解决Java并发编程：深入剖析ThreadLocal所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1322840.html

来源：【匿名】

【上一篇】MainActivity.java 【下一篇】JAVA/JSP学习系列之五

更多 ►

【Java并发编程：深入剖析ThreadLocal】教程文章相关的互联网学习教程文章

Java并发编程：深入剖析ThreadLocal【图】

引用：http://www.cnblogs.com/dolphin0520/　想必很多朋友对ThreadLocal并不陌生，今天我们就来一起探讨下ThreadLocal的使用方法和实现原理。首先，本文先谈一下对ThreadLocal的理解，然后根据ThreadLocal类的源码分析了其实现原理和使用需要注意的地方，最后给出了两个应用场景。　　以下是本文目录大纲：　　一.对ThreadLocal的理解　　二.深入解析ThreadLocal类　　三.ThreadLocal的应用场景　　若有不正之处请多多谅解，并欢迎...

java并发编程学习（一）：什么是线程安全

什么是线程安全？线程安全是指的是某个函数、函数库在并发环境中被调用时，能够正确地处理多个线程之间的共享变量，使程序功能正确完成。这里有几个要点：并发、多线程、共享变量并发并发与并行的关系这里我采用形象的术语来描述，尽量让非本专业的人也能理解并发是两个队伍交替使用一个机器，同一时刻只有某个队伍的某一个人可以使用，下一刻有可能是A队伍的人在使用，也有可能是B队伍的人在使用（看运气或者谁优先）。并...

深入理解java：2.3.3. 并发编程concurrent包之容器ConcurrentHashMap【图】

线程不安全的HashMap因为多线程环境下，使用Hashmap进行put操作会引起死循环，导致CPU利用率接近100%，所以在并发情况下不能使用HashMap。效率低下的HashTable容器HashTable容器使用synchronized来保证线程安全，但在线程竞争激烈的情况下HashTable的效率非常低下。因为当一个线程访问HashTable的同步方法时，其他线程访问HashTable的同步方法时，可能会进入阻塞或轮询状态。如线程1使用put进行添加元素，线程2不但不能使用put方法...

转：【Java并发编程】之十一：线程间通信中notify通知的遗漏（含代码）【图】

转载请注明出处：http://blog.csdn.net/ns_code/article/details/17228213 notify通知的遗漏很容易理解，即threadA还没开始wait的时候，threadB已经notify了，这样，threadB通知是没有任何响应的，当threadB退出synchronized代码块后，threadA再开始wait，便会一直阻塞等待，直到被别的线程打断。遗漏通知的代码下面给出一段代码演示通知是如何遗漏的，如下：[java] view plaincopypublic class MissedNotify extends Obj...

Java并发编程小记【代码】

1. Semaphore　　信号量是一种计数器，用来保护一个或者多个共享资源的访问。如果线程要访问一个共享资源，必须先获得信号量。若内部计数器大于0，则减1，若等于0，则线程进入休眠直至计数器大于等于0。Semaphore semaphore1 = new Semaphore(1); // 值为1的信号量 Semaphore semaphore2 = new Semaphore(1, true); // 公平模式，FIFO semaphore1.acquire(); // 获取资源，否则阻塞，且在阻塞过程中可以被中断 semaphore1.acquireU...

Java并发编程系列之二十八：CompletionService【代码】【图】

CompletionService简介CompletionService与ExecutorService类似都可以用来执行线程池的任务，ExecutorService继承了Executor接口，而CompletionService则是一个接口，那么为什么CompletionService不直接继承Executor接口呢？主要是Executor的特性决定的，Executor框架不能完全保证任务执行的异步性，那就是如果需要实现任务（task）的异步性，只要为每个task创建一个线程就实现了任务的异步性。代码往往包含new Thread(task).start...

Java并发编程之CountDownLatch

在java中为我们提供了一个同步的辅助类CountDownLatch，这个类用来干什么呢？下面来学习一下。 CountDownLatch 一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它运行一个或多个线程处于等待的操作。用给定的计数初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数...

最近在看java并发编程。值得一看。向爱好java的朋友强烈推荐【图】

《java7并发编程实战》650) this.width=650;" src="/upload/getfiles/default/2022/11/14/20221114121534262.jpg" title="QQ截图20150407000932.jpg" />原文：http://7385573.blog.51cto.com/7375573/1629399

【转】Java并发编程：volatile关键字解析【代码】【图】

Java并发编程：volatile关键字解析　　 volatile这个关键字可能很多朋友都听说过，或许也都用过。在Java 5之前，它是一个备受争议的关键字，因为在程序中使用它往往会导致出人意料的结果。在Java 5之后，volatile关键字才得以重获生机。　　volatile关键字虽然从字面上理解起来比较简单，但是要用好不是一件容易的事情。由于volatile关键字是与Java的内存模型有关的，因此在讲述volatile关键之前，我们先来了解一下与内存模型相关的...

转 Java并发编程：volatile关键字解析【代码】【图】

Java并发编程：volatile关键字解析（点击链接原文）　　 volatile这个关键字可能很多朋友都听说过，或许也都用过。在Java 5之前，它是一个备受争议的关键字，因为在程序中使用它往往会导致出人意料的结果。在Java 5之后，volatile关键字才得以重获生机。　　volatile关键字虽然从字面上理解起来比较简单，但是要用好不是一件容易的事情。由于volatile关键字是与Java的内存模型有关的，因此在讲述volatile关键之前，我们先来了解一...

java并发编程之美-阅读记录5【代码】

java并发包中的并发List5.1CopeOnWriteArrayList　　并发包中的并发List只有CopyOnWriteArrayList，该类是一个线程安全的arraylist，对其进行的修改操作都是在底层的一个复制数组上进行的，也就是使用了写时复制策略。　　该类的结构：publicclass CopyOnWriteArrayList<E>implements List<E>, RandomAccess, Cloneable, java.io.Serializable {privatestaticfinallong serialVersionUID = 8673264195747942595L;// 可重入的独占锁...

Java并发编程、多线程、线程池…

Java多线程干货系列（1）：Java多线程基础http://www.importnew.com/21136.html#comment-65114640个Java多线程问题总结http://www.importnew.com/18459.html#comment-651217Java线程面试题 Top 50http://www.importnew.com/12773.htmlJava并发编程：Thread类的使用http://www.cnblogs.com/dolphin0520/p/3920357.htmlJava并发编程：synchronizedhttp://www.cnblogs.com/dolphin0520/p/3923737.htmlJava并发编程：Lockhttp://www.cn...

转：【Java并发编程】之十四：图文讲述同步的另一个重要功能：内存可见性【图】

转载请注明出处：http://blog.csdn.net/ns_code/article/details/17288243 加锁（synchronized同步）的功能不仅仅局限于互斥行为，同时还存在另外一个重要的方面：内存可见性。我们不仅希望防止某个线程正在使用对象状态而另一个线程在同时修改该状态，而且还希望确保当一个线程修改了对象状态后，其他线程能够看到该变化。而线程的同步恰恰也能够实现这一点。内置锁可以用于确保某个线程以一种可预测的方式来查看另一个...

JAVA并发编程-线程创建（二）【图】

对于线程的创建及更加详细的信息可以参看博客《JAVA--线程》，下面是对线程创建的细化及简单再实现。在java中如果要创建线程的话，一般有两种方式：1）继承Thread类；2）实现Runnable接口。方式一：继承Thread类 MyThread:package com.tgb.hjy;public class MyThread extends Thread{private String name;public MyThread(String name){this.name=name;}@Overridepublic void run(){System.out.println("name:"+name+",子线程ID:"...

【Java并发编程】21、线程池ThreadPoolExecutor源码解析【代码】【图】

一、前言　　JUC这部分还有线程池这一块没有分析，需要抓紧时间分析，下面开始ThreadPoolExecutor，其是线程池的基础，分析完了这个类会简化之后的分析，线程池可以解决两个不同问题：由于减少了每个任务调用的开销，它们通常可以在执行大量异步任务时提供增强的性能，并且还可以提供绑定和管理资源（包括执行任务集时使用的线程）的方法。下面开始分析。二、ThreadPoolExecutor数据结构　　在ThreadPoolExecutor的内部，主要由Bl...

JAVA - 技术教程分类

Java 教程 Java 简介 Java 开发环境配置 Java 基础语法 Java 对象和类 Java 基本数据类型 Java 变量类型 Java 修饰符 Java 运算符 Java 循环结构 Java 条件语句 Java switch case Java Number & Math 类 Java Character 类 Java String 类 Java StringBuffer Java 数组 Java 日期时间 Java 方法 Java Stream、File、IO Java Scanner 类 Java 异常处理 Java 继承 Java Override/Overload Java 多态 Java 抽象类 Java 封装 Java 接口 Java 枚举 Java 包(package) Java 数据结构 Java 集合框架 Java ArrayList Java LinkedList Java HashSet Java HashMap Java Iterator Java Object Java 泛型 Java 序列化 Java 网络编程 Java 多线程编程 Java Applet 基础 Java 文档注释 Java 实例 Java 8 新特性 Java MySQL 连接 Java 9 新特性 Java 测验 java 全部

JAVA - 最热教程

Java在运行项目时候，点击右键的弹框，...nacos配置中心超时问题：java.net.Conn...Java的设计模式（7）— 生产者-消费者模...基于DOM4j和POI实现的XML文件转换为XLS...如何在Java中创建一些变量类型别名使用java8的Stream统计字符串数组中每一...idea插件篇之java内存分析工具(JProfil...cannot cast 'java.lang.Integer' to '...java – Bootstrap.properties中Spring...Java8利用stream流实现数字排序和中文排...

首页 / JAVA / Java并发编程：深入剖析ThreadLocal

Java并发编程：深入剖析ThreadLocal

内容导读

内容图文

一.对ThreadLocal的理解

二.深入解析ThreadLocal类

三.ThreadLocal的应用场景

内容总结

内容备注

内容手机端

【Java并发编程：深入剖析ThreadLocal】教程文章相关的互联网学习教程文章

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程