并发编程-Threadlocal-CFANZ编程社区

上一篇 <<<Fork/Join框架
下一篇 >>>Disruptor框架

Threadlocal： 各个线程独有的局部变量，相互之间不受影响。
它主要有四个方法initialValue()、get()、set()和remove(),底层采用了map集合形式进行存放，key为当前线程ID。

ThreadLocal的优势

ThreadLocal的应用场景

Spring中使用的request对象、session对象

HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder
        .getRequestAttributes()).getRequest();

private static final ThreadLocal<RequestAttributes> requestAttributesHolder =
      new NamedThreadLocal<>("Request attributes");

private static final ThreadLocal<RequestAttributes> inheritableRequestAttributesHolder =
      new NamedInheritableThreadLocal<>("Request context");

Spring中使用的事务传播行为：事务标识、jdbc链接等都放在ThreadLocal中

ThreadLocal内部结构

ThreadLocal内存泄露问题

ThreadLocal自身的清理过程

如何避免内存泄露

1. 可以自己调用remove方法将不要的数据移除避免内存泄漏的问题
1. 每次在做set方法的时候会清除之前 key为null
3.使用java反射机制获取当前线程对应的ThreadLocalMap ，手动移除

为什么线程中的ThreadLocal采用弱引用而不是强引用

如果key是为强引用：

如果key是为弱引用：

不管是用强引用还是弱引用都是会发生内存泄漏的问题。弱引用中不会发生ThreadLocal内存泄漏的问题。
但是最终根本的原因Threadlocal内存泄漏的问题，产生于ThreadLocalMap与我们当前线程的生命周期一样，如果没有手动的删除的情况下，就有可能会发生内存泄漏的问题。

为什么线程中的ThreadLocalMap 底层数组Entry实现

ThreadLocal的缺陷

1.父线程不会传递给子线程

private static ThreadLocal threadLocal = new ThreadLocal();

public static void main(String[] args) {
    threadLocal.set("123456");
    System.out.println("父线程的值:"+threadLocal.get());
    new Thread(()->{
        System.out.println("子线程的值:"+threadLocal.get());
    }).start();
}

打印：
父线程的值:123456
子线程的值:null

private static ThreadLocal threadLocal = new InheritableThreadLocal();
public static void main(String[] args) {
    threadLocal.set("123456");
    System.out.println("父线程的值:"+threadLocal.get());
    new Thread(()->{
        System.out.println("子线程的值:"+threadLocal.get());
    }).start();
}
打印：
父线程的值:123456
子线程的值: 123456

2.线程池传递问题

private static ThreadLocal threadLocal = new InheritableThreadLocal();
private static ExecutorService service = Executors.newFixedThreadPool(1);
public static void main(String[] args) {
    threadLocal.set("123456");
    System.out.println("父线程首次的值:"+threadLocal.get());
    Thread thread = new Thread(() -> {
        System.out.println("子线程的值:" + threadLocal.get());
    });
    service.submit(thread);
    threadLocal.set("7890j");
    System.out.println("父线程修改后的值:"+threadLocal.get());
    service.submit(thread);
}

打印：
父线程首次的值:123456
父线程修改后的值:7890j
子线程的值:123456
子线程的值:123456

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>transmittable-thread-local</artifactId>
    <version>2.10.2</version>
</dependency>

private final static ExecutorService execute = Executors.newFixedThreadPool(1);
private static final ThreadLocal<String> threadLocal = new TransmittableThreadLocal<>();

public static void main(String[] args) throws InterruptedException {
    //第一次设置值为1
    threadLocal.set("1");
    execute.submit(TtlRunnable.get(() ->
            System.out.println(Thread.currentThread().getName()
                    + " 第一次打印ThreadLocal值:" + threadLocal.get())
    ));
    Thread.sleep(1000);
    //第二次设置值为2
    threadLocal.set("2");
    execute.submit(TtlRunnable.get(() ->
            System.out.println(Thread.currentThread().getName()
                    + " 第二次打印ThreadLocal值:" + threadLocal.get())
    ));
    Thread.sleep(1000);
    execute.shutdown();
}
打印：
pool-1-thread-1 第一次打印ThreadLocal值:1
pool-1-thread-1 第二次打印ThreadLocal值:2

Threadlocal 与Synchronized

相关文章链接：
<<<多线程基础
<<<线程安全与解决方案
<<<锁的深入化
<<<锁的优化
<<<Java内存模型(JMM)
<<<Volatile解决JMM的可见性问题
<<<Volatile的伪共享和重排序
<<<CAS无锁模式及ABA问题
<<<Synchronized锁
<<<Lock锁
<<<AQS同步器
<<<Condition
<<<CountDownLatch同步计数器
<<<Semaphore信号量
<<<CyclicBarrier屏障
<<<线程池
<<<并发队列
<<<Callable与Future模式
<<<Fork/Join框架
<<<Disruptor框架
<<<如何优化多线程总结