点击上方“方志朋”，选择“设为星标”

回复”666“获取新整理的面试资料

作者：鲁毅

juejin.im/post/5e0d8765f265da5d332cde44

1.ThreadLocal的使用场景

1.1 场景1

每个线程需要一个独享对象（通常是工具类，典型需要使用的类有SimpleDateFormat和Random）

每个Thread内有自己的实例副本，不共享

比喻：教材只有一本，一起做笔记有线程安全问题。复印后没有问题，使用ThradLocal相当于复印了教材。

1.2 场景2

每个线程内需要保存全局变量（例如在拦截器中获取用户信息），可以让不同方法直接使用，避免参数传递的麻烦

2.对以上场景的实践

2.1 实践场景1

/*** 两个线程打印日期*/
public class ThreadLocalNormalUsage00 {public static void main(String[] args) throws InterruptedException {new Thread(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage00().date(10);System.out.println(date);}}).start();new Thread(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage00().date(104707);System.out.println(date);}}).start();}public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");return dateFormat.format(date);}
}

运行结果

因为中国位于东八区，所以时间从1970年1月1日的8点开始计算的

/*** 三十个线程打印日期*/
public class ThreadLocalNormalUsage01 {public static void main(String[] args) throws InterruptedException {for (int i = 0; i < 30; i++) {int finalI = i;new Thread(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage01().date(finalI);System.out.println(date);}}).start();//线程启动后，休眠100msThread.sleep(100);}}public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");return dateFormat.format(date);}
}

运行结果

多个线程打印自己的时间（如果线程超级多就会产生性能问题），所以要使用线程池。

/*** 1000个线程打印日期，用线程池来执行*/
public class ThreadLocalNormalUsage02 {public static ExecutorService threadPool = Executors.newFixedThreadPool(10);public static void main(String[] args) throws InterruptedException {for (int i = 0; i < 1000; i++) {int finalI = i;//提交任务threadPool.submit(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage02().date(finalI);System.out.println(date);}});}threadPool.shutdown();}public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");return dateFormat.format(date);}
}

运行结果

但是使用线程池时就会发现每个线程都有一个自己的SimpleDateFormat对象，没有必要，所以将SimpleDateFormat声明为静态，保证只有一个

/*** 1000个线程打印日期，用线程池来执行，出现线程安全问题*/
public class ThreadLocalNormalUsage03 {public static ExecutorService threadPool = Executors.newFixedThreadPool(10);//只创建一次 SimpleDateFormat 对象，避免不必要的资源消耗static SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");public static void main(String[] args) throws InterruptedException {for (int i = 0; i < 1000; i++) {int finalI = i;//提交任务threadPool.submit(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage03().date(finalI);System.out.println(date);}});}threadPool.shutdown();}public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);return dateFormat.format(date);}
}

运行结果

出现了秒数相同的打印结果，这显然是不正确的。

出现问题的原因

多个线程的task指向了同一个SimpleDateFormat对象，SimpleDateFormat是非线程安全的。

解决问题的方案

方案1：加锁

格式化代码是在最后一句return dateFormat.format(date);,所以可以为最后一句代码添加synchronized锁

public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);String s;synchronized (ThreadLocalNormalUsage04.class) {s = dateFormat.format(date);}return s;
}

运行结果

运行结果中没有发现相同的时间，达到了线程安全的目的

缺点：因为添加了synchronized，所以会保证同一时间只有一条线程可以执行，这在高并发场景下肯定不是一个好的选择，所以看看其他方案吧。

方案2：使用ThreadLocal

/*** 利用 ThreadLocal 给每个线程分配自己的 dateFormat 对象* 不但保证了线程安全，还高效的利用了内存*/
public class ThreadLocalNormalUsage05 {public static ExecutorService threadPool = Executors.newFixedThreadPool(10);public static void main(String[] args) throws InterruptedException {for (int i = 0; i < 1000; i++) {int finalI = i;//提交任务threadPool.submit(new Runnable() {@Overridepublic void run() {String date = new ThreadLocalNormalUsage05().date(finalI);System.out.println(date);}});}threadPool.shutdown();}public String date(int seconds) {//参数的单位是毫秒，从1970.1.1 00:00:00 GMT 开始计时Date date = new Date(1000 * seconds);//获取 SimpleDateFormat 对象SimpleDateFormat dateFormat = ThreadSafeFormatter.dateFormatThreadLocal.get();return dateFormat.format(date);}
}class ThreadSafeFormatter {public static ThreadLocal<SimpleDateFormat> dateFormatThreadLocal = newThreadLocal<SimpleDateFormat>(){//创建一份 SimpleDateFormat 对象@Overrideprotected SimpleDateFormat initialValue() {return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");}};
}

运行结果

使用了ThreadLocal后不同的线程不会有共享的 SimpleDateFormat 对象，所以也就不会有线程安全问题

2.2 实践场景2

当前用户信息需要被线程内的所有方法共享

方案1：传递参数

可以将user作为参数在每个方法中进行传递，

缺点：但是这样做会产生代码冗余问题，并且可维护性差。

方案2：使用Map

对此进行改进的方案是使用一个Map，在第一个方法中存储信息，后续需要使用直接get()即可，

缺点：如果在单线程环境下可以保证安全，但是在多线程环境下是不可以的。如果使用加锁和ConcurrentHashMap都会产生性能问题。

方案3：使用ThreadLocal，实现不同方法间的资源共享

使用 ThreadLocal 可以避免加锁产生的性能问题，也可以避免层层传递参数来实现业务需求，就可以实现不同线程中存储不同信息的要求。

/*** 演示 ThreadLocal 的用法2：避免参数传递的麻烦*/
public class ThreadLocalNormalUsage06 {public static void main(String[] args) {new Service1().process();}
}class Service1 {public void process() {User user = new User("鲁毅");//将User对象存储到 holder 中UserContextHolder.holder.set(user);new Service2().process();}
}class Service2 {public void process() {User user = UserContextHolder.holder.get();System.out.println("Service2拿到用户名: " + user.name);new Service3().process();}
}class Service3 {public void process() {User user = UserContextHolder.holder.get();System.out.println("Service3拿到用户名: " + user.name);}
}class UserContextHolder {public static ThreadLocal<User> holder = new ThreadLocal<>();
}class User {String name;public User(String name) {this.name = name;}
}

运行结果

3.对ThreadLocal的总结

  • 让某个需要用到的对象实现线程之间的隔离（每个线程都有自己独立的对象）

  • 可以在任何方法中轻松的获取到该对象

  • 根据共享对象生成的时机选择使用initialValue方法还是set方法

  • 对象初始化的时机由我们控制的时候使用initialValue 方式

  • 如果对象生成的时机不由我们控制的时候使用 set 方式

4.使用ThreadLocal的好处

  • 达到线程安全的目的

  • 不需要加锁，执行效率高

  • 更加节省内存，节省开销

  • 免去传参的繁琐，降低代码耦合度

5.ThreadLocal原理

  • Thread

  • ThreadLocal

  • ThreadLocalMap

在Thread类内部有有ThreadLocal.ThreadLocalMap threadLocals = null;这个变量，它用于存储ThreadLocal，因为在同一个线程当中可以有多个ThreadLocal，并且多次调用get()所以需要在内部维护一个ThreadLocalMap用来存储多个ThreadLocal

5.1 ThreadLocal相关方法

T initialValue()

该方法用于设置初始值，并且在调用get()方法时才会被触发，所以是懒加载。

但是如果在get()之前进行了set()操作，这样就不会调用initialValue()。

通常每个线程只能调用一次本方法，但是调用了remove()后就能再次调用

public T get() {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);//获取到了值直接返回resuleif (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}//没有获取到才会进行初始化return setInitialValue();
}private T setInitialValue() {//获取initialValue生成的值，并在后续操作中进行set，最后将值返回T value = initialValue();Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null)map.set(this, value);elsecreateMap(t, value);return value;
}public void remove() {ThreadLocalMap m = getMap(Thread.currentThread());if (m != null)m.remove(this);
}

void set(T t)

为这个线程设置一个新值

public void set(T value) {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null)map.set(this, value);elsecreateMap(t, value);
}

T get()

获取线程对应的value

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();
}

void remove()

删除对应这个线程的值

6.ThreadLocal注意点

6.1 内存泄漏

内存泄露；某个对象不会再被使用，但是该对象的内存却无法被收回

static class ThreadLocalMap {static class Entry extends WeakReference<ThreadLocal<?>> {/** The value associated with this ThreadLocal. */Object value;Entry(ThreadLocal<?> k, Object v) {//调用父类，父类是一个弱引用super(k);//强引用value = v;}}

强引用：当内存不足时触发GC，宁愿抛出OOM也不会回收强引用的内存

弱引用：触发GC后便会回收弱引用的内存

正常情况

当Thread运行结束后，ThreadLocal中的value会被回收，因为没有任何强引用了

非正常情况

当Thread一直在运行始终不结束，强引用就不会被回收，存在以下调用链 Thread-->ThreadLocalMap-->Entry(key为null)-->value因为调用链中的 value 和 Thread 存在强引用，所以value无法被回收，就有可能出现OOM。

JDK的设计已经考虑到了这个问题，所以在set()、remove()、resize()方法中会扫描到key为null的Entry，并且把对应的value设置为null，这样value对象就可以被回收。

private void resize() {Entry[] oldTab = table;int oldLen = oldTab.length;int newLen = oldLen * 2;Entry[] newTab = new Entry[newLen];int count = 0;for (int j = 0; j < oldLen; ++j) {Entry e = oldTab[j];if (e != null) {ThreadLocal<?> k = e.get();//当ThreadLocal为空时，将ThreadLocal对应的value也设置为nullif (k == null) {e.value = null; // Help the GC} else {int h = k.threadLocalHashCode & (newLen - 1);while (newTab[h] != null)h = nextIndex(h, newLen);newTab[h] = e;count++;}}}setThreshold(newLen);size = count;table = newTab;
}

但是只有在调用set()、remove()、resize()这些方法时才会进行这些操作，如果没有调用这些方法并且线程不停止，那么调用链就会一直存在，所以可能会发生内存泄漏。

6.2 如何避免内存泄漏（阿里规约）

调用remove()方法，就会删除对应的Entry对象，可以避免内存泄漏，所以使用完ThreadLocal后，要调用remove()方法。

class Service1 {public void process() {User user = new User("鲁毅");//将User对象存储到 holder 中UserContextHolder.holder.set(user);new Service2().process();}
}class Service2 {public void process() {User user = UserContextHolder.holder.get();System.out.println("Service2拿到用户名: " + user.name);new Service3().process();}
}class Service3 {public void process() {User user = UserContextHolder.holder.get();System.out.println("Service3拿到用户名: " + user.name);//手动释放内存，从而避免内存泄漏UserContextHolder.holder.remove();}
}

6.3 ThreadLocal的空指针异常问题

/*** ThreadLocal的空指针异常问题*/
public class ThreadLocalNPE {ThreadLocal<Long> longThreadLocal = new ThreadLocal<>();public void set() {longThreadLocal.set(Thread.currentThread().getId());}public Long get() {return longThreadLocal.get();}public static void main(String[] args) {ThreadLocalNPE threadLocalNPE = new ThreadLocalNPE();//如果get方法返回值为基本类型，则会报空指针异常，如果是包装类型就不会出错System.out.println(threadLocalNPE.get());Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {threadLocalNPE.set();System.out.println(threadLocalNPE.get());}});thread1.start();}
}

6.4 空指针异常问题的解决

如果get方法返回值为基本类型，则会报空指针异常，如果是包装类型就不会出错。这是因为基本类型和包装类型存在装箱和拆箱的关系，造成空指针问题的原因在于使用者。

6.5 共享对象问题

如果在每个线程中ThreadLocal.set()进去的东西本来就是多个线程共享的同一对象，比如static对象，那么多个线程调用ThreadLocal.get()获取的内容还是同一个对象，还是会发生线程安全问题。

6.6 可以不使用ThreadLocal就不要强行使用

如果在任务数很少的时候，在局部方法中创建对象就可以解决问题，这样就不需要使用ThreadLocal。

6.7 优先使用框架的支持，而不是自己创造

例如在Spring框架中，如果可以使用RequestContextHolder，那么就不需要自己维护ThreadLocal，因为自己可能会忘记调用remove()方法等，造成内存泄漏。

本文仅为自己学习时记下的笔记，参考自慕课：

https://coding.imooc.com/class/409.html

热门内容：

  • SpringBoot实现过滤器、拦截器与切片

  • 阿里面试官：分别说说微信和淘宝扫码登录背后的实现原理？

  • 腾讯万亿级 Elasticsearch 技术解密

  • 为什么很多SpringBoot开发者放弃了Tomcat，选择了Undertow

  • 天天用事务，但是你知道MySQL事务的实现原理吗？

  • fastjson这么快，为啥老外还是热衷 jackson?

  • 如何优雅的设计java异常

  • Spring MVC+Spring+Mybatis实现支付宝支付功能（图文详解+完整代码）

  • 互联网公司的中年人都去哪了？

  • Github 标星 11.5K！这可能是最好的 Java 博客系统

  • 大批 IDEA 激活码到期之后的乱象...

  • 全面了解 Nginx 主要应用场景

  • 为什么微服务一定要有网关？

  • 那些在一个公司死磕了5-10年的人，最后都怎么样了？

最近面试BAT，整理一份面试资料《Java面试BAT通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。

获取方式：点“在看”，关注公众号并回复 666 领取，更多内容陆续奉上。

明天见(｡･ω･｡)ﾉ♡

使用 ThreadLocal 一次解决老大难问题！相关推荐

  1. 使用 ThreadLocal 一次解决老大难问题

    1.ThreadLocal的使用场景 1.1 场景1 每个线程需要一个独享对象(通常是工具类,典型需要使用的类有SimpleDateFormat和Random) 每个Thread内有自己的实例副本,不 ...

  2. ThreadLocal一次性解决老大难问题

    提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 ThreadLocal Threadlocal使用场景 一.故事从两个线程开始 二.线程池来帮忙,却好心帮坏事 1. 10个线程打印日 ...

  3. ThreadLocal可以解决并发问题吗

    前言 到底什么是线程的不安全?为什么会存在线程的不安全?线程的不安全其实就是多个线程并发的去操作同一共享变量没用做同步所产生意料之外的结果.那是如何体现出来的呢?我们看下面的一个非常经典的例子:两个操 ...

  4. Java多线程学习三十一：ThreadLocal 是用来解决共享资源的多线程访问的问题吗？

    ThreadLocal 是不是用来解决共享资源的多线程访问的. 这是一个常见的面试问题,如果被问到了 ThreadLocal,则有可能在你介绍完它的作用.注意点等内容之后,再问你:ThreadLoca ...

  5. ThreadLocal可以解决并发问题吗?

    前言 到底什么是线程的不安全?为什么会存在线程的不安全?线程的不安全其实就是多个线程并发的去操作同一共享变量没用做同步所产生意料之外的结果.那是如何体现出来的呢?我们看下面的一个非常经典的例子:两个操 ...

  6. ThreadLocal 面试六连问，你能 Hold 住吗？

    点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 转自:码农沉思录 中高级阶段开发者出去面试,应该躲不开Thread ...

  7. 面试官：听说你精通并发编程，来说说你对ThreadLocal的理解

    ThreadLocal 简介 ThreadLocal 是一个解决多线程并发问题的工具类,ThreadLocal有的人可能理解为本地线程,这个并不是正确的理解.「ThreadLocal并不是一个线程,应 ...

  8. 「图解」ThreadLocal 在并发问题中的应用

    点击蓝色"程序猿DD"关注我 回复"资源"获取独家整理的学习资料! 前言 到底什么是线程的不安全?为什么会存在线程的不安全?线程的不安全其实就是多个线程并发的去 ...

  9. threadlocal内存泄露_ThreadLocal 简介

    本文转载于SegmentFault社区 作者:莫小点还有救 1. ThreadLocal简介 通常情况下,我们创建的变量是可以被任何一个线程访问并修改的.如果想实现每一个线程都有自己的专属本地变量该如 ...

最新文章

  1. 易企cms文章引用地址写法
  2. 深度学习模型之各种caffe版本（Linux和windows）的网址和配置
  3. 使用literal或者绑定变量执行SAP HANA SQL语句
  4. mysql第四章分页显示查询出租房屋信息_MYSQL必知必会读书笔记第四章之检索数据...
  5. 学用状态机模式，写的报销流程，请指教
  6. 大学计算机基础实训excel,大学计算机基础实训指导书
  7. C#开发WPF/Silverlight动画及游戏系列教程(Game Tutorial)：目录
  8. 信息学奥赛C++语言：趣味整数2（亲密数）
  9. c语言解析字符串报文,传递字符串数组报文和解析
  10. Windows 7密码重设盘的内部原理浅析
  11. 由项目浅谈JS中MVVM模式
  12. 京西古道，王平到圈门的穿越
  13. [设计模式之禅读书笔记]006_设计模式六大原则（六）：开闭原则
  14. spring data jpa 条件分页查询
  15. 使用Nmap扫描目标主机
  16. U盘系统安装步骤超级简单，弄懂ghost不管是windows7win10都不难
  17. win10微软账户无法连接服务器,Win10系统Microsoft微软帐户无法登陆的解决方法
  18. 阿里铁军幕后推手邓康明：核心团队是剩出来的，不是选出来的
  19. 如何在A4相纸上打印4张5寸相片
  20. android 如何开启相机LED闪光灯

热门文章

  1. 网格的铺设问题——骨牌
  2. Java学习笔记七——数组工具类Arrays
  3. hdu-5778 abs(暴力枚举)
  4. RequireJS学习笔记（转）
  5. 希尔排序——算法系列
  6. 安装SQL SERVER2000提示注册表文件被挂起的解决方案
  7. 学编程必看：逻辑思维测试
  8. 秦州：西瓜书 + 南瓜书 吃瓜系列 13. 降维与度量学习（上）
  9. 【怎样写代码】函数式编程 -- Lambda表达式（三）：LINQ初步
  10. 让浏览器开挂的插件，测评师教你如何选