【Java基础】解锁多线程安全的秘密武器:探索ThreadLocal的神奇力量!

简介: ThreadLocal是Java中的一个类,用于在多线程环境下,为**每个线程**提供**独立的变量副本**。每个线程都可以独立地访问自己的变量副本,因为该独立变量属于**当前线程**,对其他线程而言是隔离的,不会与其他线程的副本产生冲突。

关于作者:CSDN内容合伙人、技术专家, 从零开始做日活千万级APP。
专注于分享各领域原创系列文章 ,擅长java后端、移动开发、人工智能等,希望大家多多支持。

@TOC

一、导读

我们继续总结学习Java基础知识,温故知新。

二、概览

背景:当多线程访问共享可变数据时,涉及到线程间同步的问题,并不是所有时候,都要用到共享数据,所以就需要线程封闭出场了。
数据都被封闭在各自的线程之中,就不需要同步,这种通过将数据封闭在线程中而避免使用同步的技术称为线程封闭。

而ThreadLocal就提供了这样的功能。

ThreadLocal是Java中的一个类,用于在多线程环境下,为每个线程提供独立的变量副本。每个线程都可以独立地访问自己的变量副本,因为该独立变量属于当前线程,对其他线程而言是隔离的,不会与其他线程的副本产生冲突。

使用ThreadLocal可以解决多线程环境下共享变量的线程安全问题。通过将变量声明为ThreadLocal类型,在每个线程中独立创建变量的副本,从而保证了线程间的隔离

三、使用场景

3.1 使用

可以用到的场景比较多,我们列举一些场景:
1、线程间数据隔离:通过将变量声明为ThreadLocal类型,每个线程都可以独立地操作自己的变量副本,避免了线程间的竞争和冲突。
2、上下文传递:使用ThreadLocal可以在不显式传递参数的情况下,在同一线程中共享数据。典型的应用场景包括数据库连接、用户身份验证等。
3、Web应用请求处理:使用ThreadLocal可以在请求处理过程中,方便地共享请求相关的数据,如用户信息、请求参数等。
4、时间格式化:在多线程环境下,日期时间格式化可能存在线程安全问题,为每个线程创建独立的日期时间格式化对象,确保线程安全的同时提高性能。

使用方式如下:


    private static final ThreadLocal<Long> iLong = new ThreadLocal<>();

    long l = iLong.get();
    iLong.set(10L);

3.2 缺点

需要注意的是,尽管ThreadLocal可以解决一些线程安全问题,但滥用ThreadLocal也可能导致内存泄漏和隐含的资源占用问题。

  • 内存泄漏:当使用ThreadLocal的线程结束后,如果没有显式地调用ThreadLocal的remove()方法来清除对应的线程变量副本,那么这个副本将会一直存在于内存中,而不会被垃圾回收。如果此线程长时间存在或频繁创建销毁,那么就可能导致大量的无用副本占用内存,从而引发内存泄漏问题。

  • 隐含的资源占用:由于ThreadLocal的变量副本与线程绑定,当使用ThreadLocal的线程长时间存在或频繁创建销毁时,每个线程都会持有自己的副本,这可能占用大量的资源,尤其是对于大对象或者大数据集的情况。如果没有及时清理和释放这些副本,可能会导致隐含的资源占用问题,降低系统的性能和可用性。

ThreadLocal针对一个线程只能记录一个变量,但是一个线程内可以通过多个ThreadLocal来记录多个变量。

四、原理解析

原理:
ThreadLocal利用每个线程独立持有自己的ThreadLocalMap对象的特性,实现了线程共享变量的隔离,ThreadLocalMap是 ThreadLocal 的静态内部类,用来存储线程所要保存的变量副本及对应的值,每个ThreadLocalMap是一个初始值为16的数组,里面每个数组的值是一个ThreadLocal的软引用,听起来有点绕,我们看2张图。

在这里插入图片描述
将数据在拆解一下,是这样的,一个thread 包含一个threadlocalmap, 每个map存储 threadlocal及value
在这里插入图片描述

4.1 为每个线程创建变量副本

我们知道每个Thread内部都有一个ThreadLocalMap对象,threadLocals 默认是空值,
threadLocals赋值的时机是当我们调用ThreadLocal的get、set时,我们看源码:

    public class Thread implements Runnable {
   
        /* ThreadLocal values pertaining to this thread. This map is maintained
         * by the ThreadLocal class. */
        ThreadLocal.ThreadLocalMap threadLocals = null;
    }

    //createMap
    void createMap(Thread t, T firstValue) {
   
        //实例化一个新的ThreadLocalMap,并赋值给当前线程的成员变量threadLocals
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

4.2 源码

ThreadLocal.java

    // 返回当前线程所对应的线程局部变量
    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();
    }

    public void set(T value) {
   
      //获取当前线程
      Thread t = Thread.currentThread();
      //实际存储的数据结构类型
      ThreadLocalMap map = getMap(t);
      //如果存在map就直接set,没有则创建map并set
      if (map != null)
          map.set(this, value);
      else
          createMap(t, value);
   }

    //getMap方法
    ThreadLocalMap getMap(Thread t) {
   
       //thred中维护了一个ThreadLocalMap
       return t.threadLocals;
    }

    //createMap
    void createMap(Thread t, T firstValue) {
   
        //实例化一个新的ThreadLocalMap,并赋值给线程的成员变量threadLocals
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

static class ThreadLocalMap


    ThreadLocalMap(ThreadLocal<?> firstKey, Object firstValue) {
   
        初始化一个容量为16的Entry数组
        table = new Entry[INITIAL_CAPACITY];

        用key即thradLocal对象的hash值计算存储在数组中的索引位置
        int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1);

        接着创建一个Entry对象,将key和value作为构造参数传入
        table[i] = new Entry(firstKey, firstValue);

        size = 1;
        计算扩容因子,即当数组内元素达到数组大小的2/3时,会对数组进行扩容
        setThreshold(INITIAL_CAPACITY);
    }

    通过hash计算索引时会存在hash冲突的问题,当数组容量较大时,hash冲突的概率降低
    虽然他不是以hashmap的形式存储,但是Entry对象里面也是设计成key/value的形式解决hash冲突的。
    所以你可以想象成ThreadLocalMap是个数组,而存储在数组里面的各个对象是以key/value形式
    的Entry对象

    static class Entry extends WeakReference<ThreadLocal<?>> {
   
        /** The value associated with this ThreadLocal. */
        Object value;
        Entry(ThreadLocal<?> k, Object v) {
   
            super(k);
            value = v;
        }
    }

    private void set(ThreadLocal<?> key, Object value) {
   
        目的就是为了解决hash冲突,寻找数组插入下标的
        int i = key.threadLocalHashCode & (len-1);

        再往下是个for循环,里面是寻找可插入的位置,直到可以插入为止。
        for (Entry e = tab[i];
             e != null;
             e = tab[i = nextIndex(i, len)]) {
   
            ThreadLocal<?> k = e.get();
            if (k == key) {
   
                e.value = value;
                return;
            }
            if (k == null) {
   
                replaceStaleEntry(key, value, i);
                return;
            }
        }
    }

ThreadLocalMap设计成数组,是因为线程里面可以有多个ThreadLocal对象,可能会初始化多个,这样存储的时候就需要数组了。

key如果不是WeakReference弱引用,则如果某个线程死循环,则ThreadLocalMap一直存在,引用住了ThreadLocal,导致ThreadLocal无法释放,同时导致value无法释放;当是WeakReference弱引用时,即使线程死循环,当创建ThreadLocal的地方释放了,ThreadLocalMap的key会同样被被释放,在调用getEntry时,会判断如果key为null,则会释放value,内存泄露则不存在。当然ThreadLocalMap类也提供remove方法,该方法会帮我们把当前ThreadLocal对应的Entry对象清除

相关文章
|
5天前
|
安全 Java 开发者
深入解读JAVA多线程:wait()、notify()、notifyAll()的奥秘
在Java多线程编程中,`wait()`、`notify()`和`notifyAll()`方法是实现线程间通信和同步的关键机制。这些方法定义在`java.lang.Object`类中,每个Java对象都可以作为线程间通信的媒介。本文将详细解析这三个方法的使用方法和最佳实践,帮助开发者更高效地进行多线程编程。 示例代码展示了如何在同步方法中使用这些方法,确保线程安全和高效的通信。
25 9
|
8天前
|
存储 安全 Java
Java多线程编程的艺术:从基础到实践####
本文深入探讨了Java多线程编程的核心概念、应用场景及其实现方式,旨在帮助开发者理解并掌握多线程编程的基本技能。文章首先概述了多线程的重要性和常见挑战,随后详细介绍了Java中创建和管理线程的两种主要方式:继承Thread类与实现Runnable接口。通过实例代码,本文展示了如何正确启动、运行及同步线程,以及如何处理线程间的通信与协作问题。最后,文章总结了多线程编程的最佳实践,为读者在实际项目中应用多线程技术提供了宝贵的参考。 ####
|
5天前
|
监控 安全 Java
Java中的多线程编程:从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式,本文将以一个简短的代码示例作为开篇,直接展示多线程的魅力,随后再详细解析其背后的原理与实现方式,旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例:创建两个线程,分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
|
8天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件满足时被唤醒,从而确保数据一致性和同步。相比其他通信方式,如忙等待,这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
22 3
|
7天前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全,提高了并发性能。
|
8天前
|
Java UED
Java中的多线程编程基础与实践
【10月更文挑战第35天】在Java的世界中,多线程是提升应用性能和响应性的利器。本文将深入浅出地介绍如何在Java中创建和管理线程,以及如何利用同步机制确保数据一致性。我们将从简单的“Hello, World!”线程示例出发,逐步探索线程池的高效使用,并讨论常见的多线程问题。无论你是Java新手还是希望深化理解,这篇文章都将为你打开多线程的大门。
|
9天前
|
安全 Java 编译器
Java多线程编程的陷阱与最佳实践####
【10月更文挑战第29天】 本文深入探讨了Java多线程编程中的常见陷阱,如竞态条件、死锁、内存一致性错误等,并通过实例分析揭示了这些陷阱的成因。同时,文章也分享了一系列最佳实践,包括使用volatile关键字、原子类、线程安全集合以及并发框架(如java.util.concurrent包下的工具类),帮助开发者有效避免多线程编程中的问题,提升应用的稳定性和性能。 ####
36 1
|
12天前
|
存储 设计模式 分布式计算
Java中的多线程编程:并发与并行的深度解析####
在当今软件开发领域,多线程编程已成为提升应用性能、响应速度及资源利用率的关键手段之一。本文将深入探讨Java平台上的多线程机制,从基础概念到高级应用,全面解析并发与并行编程的核心理念、实现方式及其在实际项目中的应用策略。不同于常规摘要的简洁概述,本文旨在通过详尽的技术剖析,为读者构建一个系统化的多线程知识框架,辅以生动实例,让抽象概念具体化,复杂问题简单化。 ####
|
13天前
|
Java 开发者
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
41 4
|
13天前
|
消息中间件 供应链 Java
掌握Java多线程编程的艺术
【10月更文挑战第29天】 在当今软件开发领域,多线程编程已成为提升应用性能和响应速度的关键手段之一。本文旨在深入探讨Java多线程编程的核心技术、常见问题以及最佳实践,通过实际案例分析,帮助读者理解并掌握如何在Java应用中高效地使用多线程。不同于常规的技术总结,本文将结合作者多年的实践经验,以故事化的方式讲述多线程编程的魅力与挑战,旨在为读者提供一种全新的学习视角。
42 3