[Java] ThreadLocal的使用规则和源码分析

简介:

目录(?)[+]

ThreadLocal是什么?

  线程局部变量,访问某个变量的每个线程都有自己的局部变量,它独立于变量的初始化副本。   
 
它的功用非常简单,就是为每一个使用该变量的线程都提供一个变量值的副本,是每一个线程都可以独立地改变自己的副本,而不会和其它线程的副本冲突。从线程的角度看,就好像每一个线程都完全拥有该变量。  
 
ThreadLocal 实例通常是类中的 private static 字段,它们希望将状态与某一个线程(例如,用户 ID 或事务 ID)相关联。每个线程都保持对其线程局部变量副本的隐式引用,只要线程是活动的并且 ThreadLocal 实例是可访问的;在线程消失之后,其线程局部实例的所有副本都会被垃圾回收(除非存在对这些副本的其他引用)。 

ThreadLocal的接口方法

  • protected T initialValue() :返回此线程局部变量的初始值

      线程第一次使用 get() 方法访问变量时将调用此方法,但如果线程之前调用了 set(T) 方法,则不会对该线程再调用 initialValue 方法。通常,此方法对每个线程最多调用一次,但如果在调用 get() 后又调用了 remove(),则可能再次调用此方法。 
    该实现返回 null;如果程序员希望线程局部变量具有 null 以外的值,则必须为 ThreadLocal 创建子类,并重写此方法。通常将使用匿名内部类完成此操作。

  • public T get() :返回此线程局部变量的当前线程的值

      如果变量没有用于当前线程的值,则先将其初始化为调用 initialValue() 方法返回的值。

  • public void set(T value) :将此线程局部变量的当前线程副本中的值设置为指定值

      大部分子类不需要重写此方法,它们只依靠 initialValue() 方法来设置线程局部变量的值。

  • public void remove() :移除此线程局部变量当前线程的值

      如果此线程局部变量随后被当前线程 读取,且这期间当前线程没有 设置其值,则将调用其 initialValue() 方法重新初始化其值。这将导致在当前线程多次调用 initialValue 方法。

     如果希望线程局部变量初始化其它值,那么需要自己实现ThreadLocal的子类并重写该方法,通常使用一个内部类对ThreadLocal进行实例化。 
    比如下面的例子,SerialNum类为每一个类分配一个序号:  

public class SerialNum {
    // The next serial number to be assigned
    private static int nextSerialNum = 0;

    private static ThreadLocal serialNum = new ThreadLocal() {
        protected synchronized Object initialValue() {
            return new Integer(nextSerialNum++);
        }
    }

    public static int get() {
        return ((Integer) (serialNum.get())).intValue();
    }
}

ThreadLocal的内部实现

  先看看ThreadLocal类的部分源码:

 public class ThreadLocal<T> {
   
//省略...

126    protected T initialValue() {
127        return null;
128    }


159    public T get() {
160        Thread t = Thread.currentThread();
           //当前线程为key存入ThreadLocalMap 中
161        ThreadLocalMap map = getMap(t);
162        if (map != null) {
163            ThreadLocalMap.Entry e = map.getEntry(this);
164            if (e != null) {
165                @SuppressWarnings("unchecked")
166                T result = (T)e.value;
167                return result;
168            }
169        }
170        return setInitialValue();
171    }

199    public void set(T value) {
200        Thread t = Thread.currentThread();
201        ThreadLocalMap map = getMap(t);
202        if (map != null)
203            map.set(this, value);
204        else
205            createMap(t, value);
206    }

219     public void remove() {
220         ThreadLocalMap m = getMap(Thread.currentThread());
221         if (m != null)
222             m.remove(this);
223     }


}

  我们可以很明显的看出ThreadLocal把线程和线程局部变量存在ThreadLocalMap中,而ThreadLocalMap是ThreadLocal的静态类部类,我们来看看ThreadLocalMap 的部分源码:

308        static class Entry extends      WeakReference<ThreadLocal<?>> {

309
310            Object value;
311
312           Entry(ThreadLocal<?> k, Object v) {
313                super(k);
314                value = v;
315            }
316        }

  这个Map的key是ThreadLocal对象的弱引用,当要抛弃掉ThreadLocal对象时,垃圾收集器会忽略这个key的引用而清理掉ThreadLocal对象 。

  那么到底是ThreadLocal还是Thread持有ThreadLocalMap对象的引用呢?

我们在Thread源码中发现:

180     /* ThreadLocal values pertaining to this thread. This map is maintained
181      * by the ThreadLocal class. */
182     ThreadLocal.ThreadLocalMap threadLocals = null;

  ThreadLocalMap变量属于Thread的内部属性,不同的Thread拥有完全不同的ThreadLocalMap变量.  
 
Thread中的ThreadLocalMap变量的值是在ThreadLocal对象进行set或者get操作时创建的.  
 
在创建ThreadLocalMap之前,会首先检查当前Thread中的ThreadLocalMap变量是否已经存在,如果不存在则创建一个;如果已经存在,则使用当前Thread已创建的ThreadLocalMap.  

ThreadLocal如何做到线程安全

  从上面的分析我们可以得出:

  • 因为每个Thread在进行对象访问时,访问的都是各自线程自己的ThreadLocalMap,所以保证了Thread与Thread之间的数据访问隔离。 

  • 不同的ThreadLocal实例操作同一Thread时,ThreadLocalMap在存储时采用当前ThreadLocal的实例作为key来保证数据访问隔离(上面源码Entry处可以看出)。 

举个例子说明:

public class Test
{
    static ThreadLocal<Integer> local=new ThreadLocal<Integer>(){
        protected synchronized Integer initialValue(){  
            return 0;  
        }
    };  
    public static void main( String args[]){
         testRun t = new testRun();
         new Thread(t).start();
         new Thread(t).start();
    }
    public static  class testRun implements Runnable{
    @Override
    public void run() {
        // TODO Auto-generated method stub
        for(int i=5 ;i>0;i--){
            try {  
                Thread.sleep(1000);  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }
            System.out.println(Thread.currentThread().getName()+"::"+local.get());

             int localValue=local.get();  
             local.set(++localValue);  
                } 
        }
    }   
   }


输出结果为:

Thread-0::0
Thread-1::0
Thread-0::1
Thread-1::1
Thread-1::2
Thread-0::2
Thread-1::3
Thread-0::3
Thread-0::4
Thread-1::4


TheadLocal模式与同步机制的区别

  • 同步机制采用了“以时间换空间”的方式,提供一份变量,让不同的线程排队访问.而ThreadLocal采用了“以空间换时间”的方式,为每一个线程都提供一份变量的副本,从而实现同时访问而互不影响。 

  • Java中的synchronized是一个保留字,它依靠JVM的锁机制来实现临界区的函数或者变量的访问中的原子性.在同步机制中,通过对象的锁机制保证同一时间只有一个线程访问变量.此时,被用作“锁机制”的变量是多个线程共享的; 
    而ThreadLocal会为每一个线程维护一个和该线程绑定的变量的副本,从而隔离了多个线程的数据,每一个线程都拥有自己的变量副本,从而也就没有必要对该变量进行同步了。  

  • 同步机制是为了同步多个线程对相同资源的并发访问,是为了多个线程之间进行通信的有效方式。 
    而ThreadLocal是隔离多个线程的数据共享,从根本上就不在多个线程之间共享资源(变量),这样当然不需要对多个线程进行同步了。 
    所以,如果你需要进行多个线程之间进行通信,则使用同步机制。如果需要隔离多个线程之间的共享冲突,可以使用ThreadLocal。








相关文章
|
8天前
|
Java 程序员
java基础(5)标识符命名规则和命名规范
Java标识符命名规则包括只能使用数字、字母、下划线\_、$,且数字不能开头,不能使用关键字命名,且严格区分大小写。命名规范建议类名、接口名首字母大写,变量名、方法名首字母小写,常量名全大写。
20 2
|
21天前
|
Java
Java源文件声明规则详解
Java源文件的声明规则是编写清晰、可读且符合语法规范的Java程序的基础。这些规则包括文件名必须与公共类名相同、包声明位于文件顶部、导入声明紧跟其后、类声明需明确访问级别,并允许使用注释增强代码可读性。一个源文件可包含多个类,但只能有一个公共类。遵循这些规则有助于提升代码质量和维护性。
|
8天前
|
算法 安全 Java
JAVA并发编程系列(12)ThreadLocal就是这么简单|建议收藏
很多人都以为TreadLocal很难很深奥,尤其被问到ThreadLocal数据结构、以及如何发生的内存泄漏问题,候选人容易谈虎色变。 日常大家用这个的很少,甚至很多近10年资深研发人员,都没有用过ThreadLocal。本文由浅入深、并且才有通俗易懂方式全面分析ThreadLocal的应用场景、数据结构、内存泄漏问题。降低大家学习啃骨头的心理压力,希望可以帮助大家彻底掌握并应用这个核心技术到工作当中。
|
2月前
|
存储 安全 Java
Java 中的 ThreadLocal 变量
【8月更文挑战第22天】
35 4
|
2月前
|
网络协议 Java 应用服务中间件
Tomcat源码分析 (一)----- 手撕Java Web服务器需要准备哪些工作
本文探讨了后端开发中Web服务器的重要性,特别是Tomcat框架的地位与作用。通过解析Tomcat的内部机制,文章引导读者理解其复杂性,并提出了一种实践方式——手工构建简易Web服务器,以此加深对Web服务器运作原理的认识。文章还详细介绍了HTTP协议的工作流程,包括请求与响应的具体格式,并通过Socket编程在Java中的应用实例,展示了客户端与服务器间的数据交换过程。最后,通过一个简单的Java Web服务器实现案例,说明了如何处理HTTP请求及响应,强调虽然构建基本的Web服务器相对直接,但诸如Tomcat这样的成熟框架提供了更为丰富和必要的功能。
|
2月前
|
存储 缓存 安全
深度剖析Java HashMap:源码分析、线程安全与最佳实践
深度剖析Java HashMap:源码分析、线程安全与最佳实践
|
3月前
|
存储 SQL Java
(七)全面剖析Java并发编程之线程变量副本ThreadLocal原理分析
在之前的文章:彻底理解Java并发编程之Synchronized关键字实现原理剖析中我们曾初次谈到线程安全问题引发的"三要素":多线程、共享资源/临界资源、非原子性操作,简而言之:在同一时刻,多条线程同时对临界资源进行非原子性操作则有可能产生线程安全问题。
|
3月前
|
Java 开发者
Java实现基于清除后分配规则的垃圾回收器及其实现原理
通过上述简化模型的实现,我们可以理解基于清除后分配规则的垃圾回收器的基本工作原理。实际上,现代JVM中的垃圾回收器比这个例子复杂得多,它们可能包括更多阶段、优化策略,以及不同类型的垃圾回收器协同工作。然而,理解这一基本概念对于深入理解垃圾回收机制和内存管理非常有帮助。
20 3
|
4月前
|
存储 Java 测试技术
滚雪球学Java(66):Java之HashMap详解:深入剖析其底层实现与源码分析
【6月更文挑战第20天】🏆本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
40 3
滚雪球学Java(66):Java之HashMap详解:深入剖析其底层实现与源码分析
|
3月前
|
缓存 监控 Java
(十)深入理解Java并发编程之线程池、工作原理、复用原理及源码分析
深入理解Java并发编程之线程池、工作原理、复用原理及源码分析
下一篇
无影云桌面