重新認(rèn)識Java中的ThreadLocal
說來也慚愧,這個 ThreadLocal 其實一直都是一知半解,而且看了一下之后還發(fā)現(xiàn)記錯了,所以還是記錄下原先記憶里的都是反過來,一個 ThreadLocal 是里面按照 thread 作為 key,存儲線程內(nèi)容的,真的是半解都米有,完全是錯的,這樣就得用 concurrentHashMap 這種去存儲并且要鎖定線程了,然后內(nèi)容也只能存一個了,想想簡直智障
究竟是啥結(jié)構(gòu)比如我們在代碼中 new 一個 ThreadLocal,
public static void main(String[] args) {ThreadLocal<Man> tl = new ThreadLocal<>();new Thread(() -> { try {TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) {e.printStackTrace(); } System.out.println(tl.get());}).start();new Thread(() -> { try {TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) {e.printStackTrace(); } tl.set(new Man());}).start(); } static class Man {String name = 'nick'; }
這里構(gòu)造了兩個線程,一個先往里設(shè)值,一個后從里取,運行看下結(jié)果,
知道這個用法的話肯定知道是取不到值的,只是具體的原理原來搞錯了,我們來看下設(shè)值 set 方法
public void set(T value) { Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null)map.set(this, value); elsecreateMap(t, value);}
寫博客這會我才明白我原來咋會錯得這么離譜,看到第一行代碼 t 就是當(dāng)前線程,然后第二行就是用這個線程去getMap,然后我是把這個當(dāng)成從 map 里取值了,其實這里是
ThreadLocalMap getMap(Thread t) { return t.threadLocals;}
獲取 t 的 threadLocals 成員變量,那這個 threadLocals 又是啥呢
它其實是線程 Thread 中的一個類型是java.lang.ThreadLocal.ThreadLocalMap的成員變量這是 ThreadLocal 的一個靜態(tài)成員變量
static class ThreadLocalMap {/** * The entries in this hash map extend WeakReference, using * its main ref field as the key (which is always a * ThreadLocal object). Note that null keys (i.e. entry.get() * == null) mean that the key is no longer referenced, so the * entry can be expunged from table. Such entries are referred to * as 'stale entries' in the code that follows. */static class Entry extends WeakReference<ThreadLocal<?>> { /** The value associated with this ThreadLocal. */ Object value; Entry(ThreadLocal<?> k, Object v) {super(k);value = v; }} }
全部代碼有點長,只截取了一小部分,然后我們再回頭來分析前面說的 set 過程,再 copy 下代碼
public void set(T value) { Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null)map.set(this, value); elsecreateMap(t, value);}
獲取到 map 以后呢,如果 map 不為空,就往 map 里 set,這里注意 key 是啥,其實是當(dāng)前這個 ThreadLocal,這里就比較明白了究竟是啥結(jié)構(gòu),每個線程都會維護(hù)自身的 ThreadLocalMap,它是線程的一個成員變量,當(dāng)創(chuàng)建 ThreadLocal 的時候,進(jìn)行設(shè)值的時候其實是往這個 map 里以 ThreadLocal 作為 key,往里設(shè) value。
內(nèi)存泄漏是什么鬼這里又要看下前面的 ThreadLocalMap 結(jié)構(gòu)了,類似 HashMap,它有個 Entry 結(jié)構(gòu),在設(shè)置的時候會先包裝成一個 Entry
private void set(ThreadLocal<?> key, Object value) {// We don’t use a fast path as with get() because it is at// least as common to use set() to create new entries as// it is to replace existing ones, in which case, a fast// path would fail more often than not.Entry[] tab = table;int len = tab.length;int i = key.threadLocalHashCode & (len-1);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; }}tab[i] = new Entry(key, value);int sz = ++size;if (!cleanSomeSlots(i, sz) && sz >= threshold) rehash();}
這里其實比較重要的就是前面的 Entry 的構(gòu)造方法,Entry 是個 WeakReference 的子類,然后在構(gòu)造方法里可以看到 key 會被包裝成一個弱引用,這里為什么使用弱引用,其實是方便這個 key 被回收,如果前面的 ThreadLocal tl實例被設(shè)置成 null 了,如果這里是直接的強(qiáng)引用的話,就只能等到線程整個回收了,但是其實是弱引用也會有問題,主要是因為這個 value,如果在 ThreadLocal tl 被設(shè)置成 null 了,那么其實這個 value 就會沒法被訪問到,所以最好的操作還是在使用完了就 remove 掉
以上就是詳解Java中的ThreadLocal的詳細(xì)內(nèi)容,更多關(guān)于Java ThreadLocal的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. ASP中解決“對象關(guān)閉時,不允許操作。”的詭異問題……2. Gitlab CI-CD自動化部署SpringBoot項目的方法步驟3. Java封裝數(shù)組實現(xiàn)包含、搜索和刪除元素操作詳解4. JAVA上加密算法的實現(xiàn)用例5. python基于socket模擬實現(xiàn)ssh遠(yuǎn)程執(zhí)行命令6. 淺談SpringMVC jsp前臺獲取參數(shù)的方式 EL表達(dá)式7. ASP刪除img標(biāo)簽的style屬性只保留src的正則函數(shù)8. Django:使用filter的pk進(jìn)行多值查詢操作9. 使用Python和百度語音識別生成視頻字幕的實現(xiàn)10. idea打開多個窗口的操作方法
