两种场景,殊途同归
- ThreadLocalMap類,也就是Thread.threadLocals
- ThreadLocalMap類是每個線程Thread類里面的變量,里面最重要的是一個鍵值對數組Entry[] table,可以認為是一個Map,鍵值對:
- 鍵:這個ThreadLocal
- 值:實際需要的成員變量,比如User或者SimpleDateFormat
ThreadLocalMap雖然類似HashMap但是處理處理Hash沖突略有不同
ThreadLocalMap采用的是線性探測法,也就是如果發生Hash沖突,就繼續尋找下一個空位,而不是采用鏈表拉鏈
ThreadLocal兩種使用場景殊途同歸
- 通過源碼分析可以看出,setInitialValue和直接set最后都是利用map.set()方法來設置值
- 也就是說,最后都會對應到ThreadLocalMap的一個Entry,只是起點和入口不一樣
Thread類:
public class Thread implements Runnable{/**聲明ThreadLocalMap類對象,它可以存儲多個ThreadLocal靜態常量的哈希標記* 而一個ThreadLocal靜態常量可以維護一個線程內變量* 即一個ThreadLocalMap類對象可以存儲多個線程內變量,而這些變量的key就是它們各自的維護者:ThreadLocal靜態常量的哈希標記* **/ThreadLocal.ThreadLocalMap threadLocals =null;/**返回對當前執行的線程對象的引用,“native”表示該方法是由c語言編寫的底層方法*/public static native Thread currentThread();@Overridepublic void run() {//省略} }ThreadLocal類:
import java.util.HashMap; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; /**原理,類似于訪問者模式,ThreadLocal是訪問者,Thread是被訪問者。* ThreadLocal訪問的是Thread的局部變量ThreadLocalMap* 當使用ThreadLocal維護變量時,ThreadLocal為每個【使用該變量的線程】提供獨立的變量副本,* 所以每個線程都可以獨立地改變自己的副本,而不會影響其它線程所對應的副本. **/ public class ThreadLocal<T> {//線程的內部變量ThreadLocalMap對象 對ThreadLocal對象所維護的 線程內變量 的一種哈希標記private final int threadLocalHashCode = new AtomicInteger().getAndAdd(0x61c88647);//定義ThreadLocalMap內部類static class ThreadLocalMap{//源碼邏輯是一種哈希映射,這里暫時用Map替代//以當前ThreadLocal對象的標記 作為keyMap<Integer,Object> m = new HashMap<Integer,Object>();public ThreadLocalMap(ThreadLocal threadLocal, Object firstObj) {//--省略}void set(ThreadLocal threadLocal, Object value){m.put(threadLocal.threadLocalHashCode, value);}Object get(ThreadLocal threadLocal){return m.get(threadLocal.threadLocalHashCode);}void remove(){}}//訪問的是Thread的局部變量ThreadLocalMap,并為其注入值public void set(T t){//獲取當前線程,然后獲取到當前線程里面的ThreadLocalMap引用ThreadLocalMap map = Thread.currentThread().threadLocals;//以當前ThreadLocal對象為參數map.set(this,t);}//訪問的是Thread的局部變量ThreadLocalMap,并獲取其值public T get(){ThreadLocalMap map = Thread.currentThread().threadLocals;if(null!=map){return (T) map.get(this);}//如果為空,則初始化(創建并設置對象副本)return setInitialValue();}private T setInitialValue(){Thread thread = Thread.currentThread();ThreadLocalMap map = thread.threadLocals;if (map != null)map.set(this, null);elsemap = new ThreadLocalMap(this, null);return null;} }?
總結
- 上一篇: 重要方法的源码分析
- 下一篇: 收不回来的value