java

juc之五: ThreadLocal

2020-01-30  本文已影响0人  suxin1932

1. ThreadLocal (JDK版本)

1.1 ThreadLocal 概述

ThreadLocal方法及内部类.png

1.2 Thread-ThreadLocal-ThreadLocalMap 关系

Thread类有成员变量threadLocals (类型是ThreadLocal.ThreadLocalMap),
也就是说每个线程有一个自己的ThreadLocalMap ,
所以每个线程往这个ThreadLocal中读写隔离的,并且是互相不会影响的。

一个ThreadLocal只能存储一个Object对象,
如果需要存储多个Object对象那么就需要多个ThreadLocal!
Thread-ThreadLocal-ThreadLocalMap.jpg

1.2.1 ThreadLocalMap

java对象的引用包括 :
强引用,软引用,弱引用,虚引用 。

因为这里涉及到弱引用,简单说明下:
弱引用也是用来描述非必需对象的,当JVM进行垃圾回收时,
无论内存是否充足,该对象仅仅被弱引用关联,那么就会被回收。

当仅有ThreadLocalMap中的Entry的key指向ThreadLocal的时候,ThreadLocal会进行回收的!

ThreadLocal被垃圾回收后,在ThreadLocalMap里对应的Entry的键值会变成null,
但是Entry是强引用,那么Entry里面存储的Object,并没有办法进行回收,
所以ThreadLocalMap 做了一些额外的回收工作。
!!!虽然做了但是也会存在内存泄漏风险
ThreadLocalMap.png ThreadLocal防止内存泄漏做的工作-->不够.jpg

1.3 ThreadLocal的最佳实践(可以参考阿里巴巴java规范)

ThreadLocal被垃圾回收后,在ThreadLocalMap里对应的Entry的键值会变成null,
但是Entry是强引用,那么Entry里面存储的Object,并没有办法进行回收,所以ThreadLocalMap 做了一些额外的回收工作。
#备注:
很多时候,我们都是用在线程池的场景,程序不停止,线程基本不会销毁!!!

由于线程的生命周期很长,如果我们往ThreadLocal里面set了很大很大的Object对象,
虽然set、get等等方法在特定的条件会调用进行额外的清理,
但是ThreadLocal被垃圾回收后,在ThreadLocalMap里对应的Entry的键值会变成null,
但是后续再也没有操作set、get等方法了。

#所以最佳实践
应该在我们不使用的时候,主动调用remove方法进行清理。
try {
    // 其它业务逻辑
} finally {
    threadLocal对象.remove();
}
ThreadLocal最佳实践.jpg

1.4 ThreadLocal用在什么地方?

#应用场景概述
>> 保存线程上下文信息,在任意需要的地方可以获取!!!
>> 线程安全的,避免某些情况需要考虑线程安全必须同步带来的性能损失!

#例如
由于ThreadLocal的特性,同一线程在某地方进行设置,在随后的任意地方都可以获取到。
从而可以用来保存线程上下文信息。

常用的比如每个请求怎么把一串后续关联起来,就可以用ThreadLocal进行set,
在后续的任意需要记录日志的方法里面进行get获取到请求id,从而把整个请求串起来。

还有比如Spring的事务管理,用ThreadLocal存储Connection,
从而各个DAO可以获取同一Connection,可以进行事务回滚,提交等操作。

1.5 ThreadLocal应用示例

1.5.1 用于存储线程信息

package com.zy.tools.undefined.concurrent.threadlocal;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadLocalDemo01 {
    private static final ExecutorService executor = Executors.newCachedThreadPool();
    private static ThreadLocal<String> threadLocal = new ThreadLocal<>();
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(4);
        for (int i = 1; i < 5; i++) {
            int finalI = i;
            executor.submit(() -> {
                try {
                    threadLocal.set(Thread.currentThread().getName() + " ---> " + finalI);
                    System.out.println(threadLocal.get());
                    countDownLatch.countDown();
                } finally {
                    threadLocal.remove();
                }
            });
        }
        countDownLatch.await(5L, TimeUnit.SECONDS);
        executor.shutdown();
    }
}

2. FastThreadLocal (Netty版本)

参考资源
https://mp.weixin.qq.com/s/yBLIbWs7bA0rjYj3Ypxd9g (JDK ThreadLocal)

上一篇下一篇

猜你喜欢

热点阅读