zoukankan      html  css  js  c++  java
  • ThreadLocal源码浅析

    首先,ThreadLocal 不是用来解决共享对象的多线程访问问题的,一般情况下,通过ThreadLocal.set() 到线程中的对象是该线程自己使用的对象,其他线程是不需要访问的,也访问不到的。各个线程中访问的是不同的对象。 

    另外,说ThreadLocal使得各线程能够保持各自独立的一个对象,并不是通过ThreadLocal.set()来实现的,而是通过每个线程中的new 对象 的操作来创建的对象,每个线程创建一个,不是什么对象的拷贝或副本。通过ThreadLocal.set()将这个新创建的对象的引用保存到各线程的自己的一个map中,每个线程都有这样一个map,执行ThreadLocal.get()时,各线程从自己的map中取出放进去的对象,因此取出来的是各自自己线程中的对象,ThreadLocal实例是作为map的key来使用的。 

    如果ThreadLocal.set()进去的东西本来就是多个线程共享的同一个对象,那么多个线程的ThreadLocal.get()取得的还是这个共享对象本身,还是有并发访问问题。 


    总之,ThreadLocal不是用来解决对象共享访问问题的,而主要是提供了保持对象的方法和避免参数传递的方便的对象访问方式。归纳了两点: 
    1。每个线程中都有一个自己的ThreadLocalMap类对象,可以将线程自己的对象保持到其中,各管各的,线程可以正确的访问到自己的对象。 
    2。将一个共用的ThreadLocal静态实例作为key,将不同对象的引用保存到不同线程的ThreadLocalMap中,然后在线程执行的各处通过这个静态ThreadLocal实例的get()方法取得自己线程保存的那个对象,避免了将这个对象作为参数传递的麻烦。 

    当然如果要把本来线程共享的对象通过ThreadLocal.set()放到线程中也可以,可以实现避免参数传递的访问方式,但是要注意get()到的是那同一个共享对象,并发访问问题要靠其他手段来解决。但一般来说线程共享的对象通过设置为某类的静态变量就可以实现方便的访问了,似乎没必要放到线程中。 

    ThreadLocal的应用场合,我觉得最适合的是按线程多实例(每个线程对应一个实例)的对象的访问,并且这个对象很多地方都要用到。 

    简单的测试: 

    package com.lzq.test;
    
    public class TestThreadLocal implements Runnable {
    
    	public TestThreadLocal(String s) {
    		this.localString = s;
    	}
    
    	String localString;
    	ThreadLocal<String> threadLocal = new ThreadLocal<String>() {
    		@Override
    		protected String initialValue() {
    			return "default String";
    		}
    	};
    
    	@Override
    	public void run() {
    		System.out.println(threadLocal.get());
    		threadLocal.set(localString);
    		System.out.println(threadLocal.get());
    	}
    
    	public static void main(String[] args) {
    		Thread t1 = new Thread(new TestThreadLocal("localString1"));
    		Thread t2 = new Thread(new TestThreadLocal("localString2"));
    
    		t1.run();
    		t2.run();
    	}
    }
    

    结果:

    default String
    localString1
    default String
    localString2

    ThreadLocal的实现原理(jdk1.5源码) 

    Java代码  收藏代码
    1. public class ThreadLocal<T> {  
    2.     /** 
    3.      * ThreadLocals rely on per-thread hash maps attached to each thread 
    4.      * (Thread.threadLocals and inheritableThreadLocals).  The ThreadLocal 
    5.      * objects act as keys, searched via threadLocalHashCode.  This is a 
    6.      * custom hash code (useful only within ThreadLocalMaps) that eliminates 
    7.      * collisions in the common case where consecutively constructed 
    8.      * ThreadLocals are used by the same threads, while remaining well-behaved 
    9.      * in less common cases. 
    10.      */  
    11.     private final int threadLocalHashCode = nextHashCode();  
    12.   
    13.     /** 
    14.      * The next hash code to be given out. Accessed only by like-named method. 
    15.      */  
    16.     private static int nextHashCode = 0;  
    17.   
    18.     /** 
    19.      * The difference between successively generated hash codes - turns 
    20.      * implicit sequential thread-local IDs into near-optimally spread 
    21.      * multiplicative hash values for power-of-two-sized tables. 
    22.      */  
    23.     private static final int HASH_INCREMENT = 0x61c88647;  
    24.   
    25.     /** 
    26.      * Compute the next hash code. The static synchronization used here 
    27.      * should not be a performance bottleneck. When ThreadLocals are 
    28.      * generated in different threads at a fast enough rate to regularly 
    29.      * contend on this lock, memory contention is by far a more serious 
    30.      * problem than lock contention. 
    31.      */  
    32.     private static synchronized int nextHashCode() {  
    33.         int h = nextHashCode;  
    34.         nextHashCode = h + HASH_INCREMENT;  
    35.         return h;  
    36.     }  
    37.   
    38.     /** 
    39.      * Creates a thread local variable. 
    40.      */  
    41.     public ThreadLocal() {  
    42.     }  
    43.   
    44.     /** 
    45.      * Returns the value in the current thread's copy of this thread-local 
    46.      * variable.  Creates and initializes the copy if this is the first time 
    47.      * the thread has called this method. 
    48.      * 
    49.      * @return the current thread's value of this thread-local 
    50.      */  
    51.     public T get() {  
    52.         Thread t = Thread.currentThread();  
    53.         ThreadLocalMap map = getMap(t);  
    54.         if (map != null)  
    55.             return (T)map.get(this);  
    56.   
    57.         // Maps are constructed lazily.  if the map for this thread  
    58.         // doesn't exist, create it, with this ThreadLocal and its  
    59.         // initial value as its only entry.  
    60.         T value = initialValue();  
    61.         createMap(t, value);  
    62.         return value;  
    63.     }  
    64.   
    65.     /** 
    66.      * Sets the current thread's copy of this thread-local variable 
    67.      * to the specified value.  Many applications will have no need for 
    68.      * this functionality, relying solely on the {@link #initialValue} 
    69.      * method to set the values of thread-locals. 
    70.      * 
    71.      * @param value the value to be stored in the current threads' copy of 
    72.      *        this thread-local. 
    73.      */  
    74.     public void set(T value) {  
    75.         Thread t = Thread.currentThread();  
    76.         ThreadLocalMap map = getMap(t);  
    77.         if (map != null)  
    78.             map.set(this, value);  
    79.         else  
    80.             createMap(t, value);  
    81.     }  
    82.   
    83.     /** 
    84.      * Get the map associated with a ThreadLocal. Overridden in 
    85.      * InheritableThreadLocal. 
    86.      * 
    87.      * @param  t the current thread 
    88.      * @return the map 
    89.      */  
    90.     ThreadLocalMap getMap(Thread t) {  
    91.         return t.threadLocals;  
    92.     }  
    93.   
    94.     /** 
    95.      * Create the map associated with a ThreadLocal. Overridden in 
    96.      * InheritableThreadLocal. 
    97.      * 
    98.      * @param t the current thread 
    99.      * @param firstValue value for the initial entry of the map 
    100.      * @param map the map to store. 
    101.      */  
    102.     void createMap(Thread t, T firstValue) {  
    103.         t.threadLocals = new ThreadLocalMap(this, firstValue);  
    104.     }  
    105.   
    106.     .......  
    107.   
    108.     /** 
    109.      * ThreadLocalMap is a customized hash map suitable only for 
    110.      * maintaining thread local values. No operations are exported 
    111.      * outside of the ThreadLocal class. The class is package private to 
    112.      * allow declaration of fields in class Thread.  To help deal with 
    113.      * very large and long-lived usages, the hash table entries use 
    114.      * WeakReferences for keys. However, since reference queues are not 
    115.      * used, stale entries are guaranteed to be removed only when 
    116.      * the table starts running out of space. 
    117.      */  
    118.     static class ThreadLocalMap {  
    119.   
    120.     ........  
    121.   
    122.     }  
    123.   
    124. }  



    ThreadLocal.set()进去的对象是放在哪儿的呢? 


    看一下上面的set()方法,两句合并一下成为 

    Java代码  收藏代码
    1. ThreadLocalMap map = Thread.currentThread().threadLocals;  


    这个ThreadLocalMap 类是ThreadLocal中定义的内部类,但是它的实例却用在Thread类中: 

    Java代码  收藏代码
    1. public class Thread implements Runnable {  
    2.     ......  
    3.   
    4.     /* ThreadLocal values pertaining to this thread. This map is maintained 
    5.      * by the ThreadLocal class. */  
    6.     ThreadLocal.ThreadLocalMap threadLocals = null;    
    7.     ......  
    8. }  



    再看这句: 

    Java代码  收藏代码
    1. if (map != null)  
    2.     map.set(this, value);  


    也就是将该ThreadLocal实例作为key,要保持的对象作为值,设置到当前线程的ThreadLocalMap 中,get()方法同样大家看了代码也就明白了,ThreadLocalMap 类的代码太多了,我就不帖了,自己去看源码吧。

    原文地址:http://www.iteye.com/topic/103804

  • 相关阅读:
    编写一个截取字符串的函数,输入为一个字符串和字节数,输出为按字节截取的字符串。 但是要保证汉字不被截半个,如“我ABC”4,应该截为“我AB”,输入“我ABC汉DEF”,6,应该输出为“我ABC”而不是“我ABC+汉的半个”。
    Java基础——数据类型之间的转换
    Spring 事物机制总结
    Spring 3.0 注解注入详解
    Spring 注解 @Resource和@Autowired
    从jsp向servlet传送数据的两种方式
    文本输入框,只能显示内容而不能修改
    myeclipse 中项目名出现红色感叹号解决方法
    在servlet中使用split()截取以反斜杠‘’分割的字符串
    jsp页面跳转方式
  • 原文地址:https://www.cnblogs.com/leeqq/p/3965236.html
Copyright © 2011-2022 走看看