搜尋
首頁Javajava教程如何使用Java中的ThreadLocal類別?

如何使用Java中的ThreadLocal類別?

May 08, 2023 pm 11:49 PM
javathreadlocal

    Threadlocal有什麼用:

    簡單的說就是,一個ThreadLocal在一個執行緒中是共享的,在不同執行緒之間又是隔離的(每個線程都只能看到自己線程的值)。如下圖:

    如何使用Java中的ThreadLocal類別?

    ThreadLocal使用實例

    API介紹

    在使用Threadlocal之前我們先看以下它的API:

    如何使用Java中的ThreadLocal類別?

    ThreadLocal類別的API非常的簡單,在這裡比較重要的就是get()、set()、remove(),set用於賦值操作,get用於取得變數的值,remove就是刪除目前變數的值.需要注意的是initialValue方法會在第一次呼叫時被觸發,用於初始化當前變數值,預設是initialValue回傳的是null。

    ThreadLocal的使用

    說完了ThreadLocal類別的API了,那我們就來動手實踐一下了,來理解前面的那句話:一個ThreadLocal在一個線程中是共享的,在不同線程之間又是隔離的(每個線程都只能看到自己線程的值)

    public class ThreadLocalTest {
    
        private static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>() {
    	// 重写这个方法,可以修改“线程变量”的初始值,默认是null
            @Override
            protected Integer initialValue() {
                return 0;
            }
        };
    
        public static void main(String[] args) throws InterruptedException {
    
            //一号线程
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("一号线程set前:" + threadLocal.get());
                    threadLocal.set(1);
                    System.out.println("一号线程set后:" + threadLocal.get());
                }
            }).start();
    
            //二号线程
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("二号线程set前:" + threadLocal.get());
                    threadLocal.set(2);
                    System.out.println("二号线程set后:" + threadLocal.get());
    
                }
            }).start();
    
            //主线程睡1s
            Thread.sleep(1000);
    
            //主线程
            System.out.println("主线程的threadlocal值:" + threadLocal.get());
    
        }
    
    }

    稍微解釋一下上面的程式碼:

    每一個ThreadLocal實例就類似於一個變數名,不同的ThreadLocal實例就是不同的變數名,它們內部會存有一個值(暫時如此理解)在後面的描述中所說的「ThreadLocal變數或是執行緒變數」代表的就是ThreadLocal類別的實例。

    在類別中建立了一個靜態的 “ThreadLocal變數”,在主線程中建立兩個線程,在這兩個線程中分別設定ThreadLocal變數為1和2。然後等待一號和二號線程執行完畢後,在主線程中查看ThreadLocal變數的值。

    程式結果及分析⌛

    如何使用Java中的ThreadLocal類別?

    程式結果重點看的是主執行緒輸出的是0,如果是一個普通變量,在一號執行緒和二號線程中將普通變量設為1和2,那麼在一二號線程執行完畢後在打印這個變量,輸出的值肯定是1或者2(到底輸出哪一個由操作系統的線程調度邏輯有關)。但使用ThreadLocal變數經由兩個執行緒賦值後,在主執行緒程中輸出的卻是初始值0。在這也就是為什麼“一個ThreadLocal在一個線程中是共享的,在不同線程之間又是隔離的”,每個線程都只能看到自己線程的值,這也就是ThreadLocal的核心作用:實現線程範圍的局部變數。

    Threadlocal 的原始碼分析

    原理

    每個Thread物件都有一個ThreadLocalMap,當建立一個ThreadLocal的時候,就會將該ThreadLocal物件加入到該Map中,其中鍵就是ThreadLocal,值可以是任意型別。這句話剛看可能不是很懂,下面我們一起看完原始碼就懂了。

    前面我們的理解是所有的常數值或是引用型別的引用都是保存在ThreadLocal實例中的,但實際上不是的,這種說法只是讓我們更好的理解ThreadLocal變數這個概念。在ThreadLocal存入一個值,實際上是存入一個值線程物件中的ThreadLocalMap,ThreadLocalMap我們可以簡單的理解成一個Map,而儲存到這個Map值的key就是ThreadLocal實例本身。

    原始碼

    如何使用Java中的ThreadLocal類別?

    ????也就是說,想要存入的ThreadLocal中的資料其實並沒有存到ThreadLocal物件中去,而是以這個ThreadLocal實例作為key存到了當前線程中的一個Map中去了,而取得ThreadLocal的值時同樣也是這個道理。這就是為什麼ThreadLocal可以實現線程之間隔離的原因了。

    內部類別ThreadLocalMap

    ThreadLocalMap是ThreadLocal的內部類,實作了一套自己的Map結構✨

    ThreadLocalMap屬性:

    static class Entry extends WeakReference<ThreadLocal<?>> {
                Object value;
                Entry(ThreadLocal<?> k, Object v) {
                    super(k);
                    value = v;
                }
            }
            //初始容量16
            private static final int INITIAL_CAPACITY = 16;
            //散列表
            private Entry[] table;
            //entry 有效数量 
            private int size = 0;
            //负载因子
            private int threshold;

    ThreadLocalMap設定ThreadLocal變數

    private void set(ThreadLocal<?> key, Object value) {
                Entry[] tab = table;
                int len = tab.length;
                
                //与运算  & (len-1) 这就是为什么 要求数组len 要求2的n次幂 
                //因为len减一后最后一个bit是1 与运算计算出来的数值下标 能保证全覆盖 
                //否者数组有效位会减半 
                //如果是hashmap 计算完下标后 会增加链表 或红黑树的查找计算量 
                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;
                    }
                    //槽点被GC掉 重设状态 
                    if (k == null) {
                        replaceStaleEntry(key, value, i);
                        return;
                    }
                }
    			//槽点为空 设置value
                tab[i] = new Entry(key, value);
                //设置ThreadLocal数量
                int sz = ++size;
    			
    			//没有可清理的槽点 并且数量大于负载因子 rehash
                if (!cleanSomeSlots(i, sz) && sz >= threshold)
                    rehash();
            }

    ThreadLocalMap屬性介紹????:

    • #和普通Hashmap類似儲存在一個陣列內,但與hashmap使用的拉鍊法解決散列衝突不同的是ThreadLocalMap使用開放位址法

    • 陣列初始容量16,負載因子2/3

    • node節點的key封裝了WeakReference 用於回收

    ThreadLocalMap儲存位置

    儲存在Thread中,有兩個ThreadLocalMap變數

    如何使用Java中的ThreadLocal類別?

    #threadLocals 在ThreadLocal在物件方法set中去創建也由ThreadLocal來維護

    public void set(T value) {
            Thread t = Thread.currentThread();
            ThreadLocalMap map = getMap(t);
            if (map != null)
                map.set(this, value);
            else
                createMap(t, value);
        }
    
        void createMap(Thread t, T firstValue) {
            t.threadLocals = new ThreadLocalMap(this, firstValue);
        }

    inheritableThreadLocals 和ThreadLocal類似InheritableThreadLocal重寫了createMap方法

    void createMap(Thread t, T firstValue) {
            t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
        }

    inheritableThreadLocals 作用是将ThreadLocalMap传递给子线程

    如何使用Java中的ThreadLocal類別?

    init方法中 条件满足后直接为子线程创建ThreadLocalMap

    如何使用Java中的ThreadLocal類別?

    注意:

    • 仅在初始化子线程的时候会传递 中途改变副线程的inheritableThreadLocals 变量 不会将影响结果传递到子线程 。

    • 使用线程池要注意 线程不回收 尽量避免使用父线程的inheritableThreadLocals 导致错误

    Key的弱引用问题

    为什么要用弱引用,官方是这样回答的

    To help deal with very large and long-lived usages, the hash table entries use WeakReferences for keys.

    为了处理非常大和生命周期非常长的线程,哈希表使用弱引用作为 key。

    生命周期长的线程可以理解为:线程池的核心线程

    ThreadLocal在没有外部对象强引用时如Thread,发生GC时弱引用Key会被回收,而Value是强引用不会回收,如果创建ThreadLocal的线程一直持续运行如线程池中的线程,那么这个Entry对象中的value就有可能一直得不到回收,发生内存泄露。

    • key 使用强引用????: 引用的ThreadLocal的对象被回收了,但是ThreadLocalMap还持有ThreadLocal的强引用,如果没有手动删除,ThreadLocal不会被回收,导致Entry内存泄漏。

    • key 使用弱引用????: 引用的ThreadLocal的对象被回收了,由于ThreadLocalMap持有ThreadLocal的弱引用,即使没有手动删除,ThreadLocal也会被回收。value在下一次ThreadLocalMap调用set,get,remove的时候会被清除。

    Java8中已经做了一些优化如,在ThreadLocal的get()、set()、remove()方法调用的时候会清除掉线程ThreadLocalMap中所有Entry中Key为null的Value,并将整个Entry设置为null,利于下次内存回收。

    java中的四种引用

    • 强引用????: 如果一个对象具有强引用,它就不会被垃圾回收器回收。即使当前内存空间不足,JVM也不会回收它,而是抛出 OutOfMemoryError 错误,使程序异常终止。如果想中断强引用和某个对象之间的关联,可以显式地将引用赋值为null,这样一来的话,JVM在合适的时间就会回收该对象

    • 软引用????: 在使用软引用时,如果内存的空间足够,软引用就能继续被使用,而不会被垃圾回收器回收,只有在内存不足时,软引用才会被垃圾回收器回收。(软引用可用来实现内存敏感的高速缓存,比如网页缓存、图片缓存等。使用软引用能防止内存泄露,增强程序的健壮性)

    • 弱引用????: 具有弱引用的对象拥有的生命周期更短暂。因为当 JVM 进行垃圾回收,一旦发现弱引用对象,无论当前内存空间是否充足,都会将弱引用回收。不过由于垃圾回收器是一个优先级较低的线程,所以并不一定能迅速发现弱引用对象

    • 虚引用????: 虚引用并不会决定对象的生命周期。如果一个对象仅持有虚引用,那么它就和没有任何引用一样,在任何时候都可能被垃圾回收器回收。虚引用必须和引用队列(ReferenceQueue)联合使用。当垃圾回收器准备回收一个对象时,如果发现它还有虚引用,就会在回收对象的内存之前,把这个虚引用加入到与之关联的引用队列中。(注意哦,其它引用是被JVM回收后才被传入ReferenceQueue中的。由于这个机制,所以虚引用大多被用于引用销毁前的处理工作。可以使用在对象销毁前的一些操作,比如说资源释放等。)

    通常ThreadLocalMap的生命周期跟Thread(注意线程池中的Thread)一样长,如果没有手动删除对应key(线程使用结束归还给线程池了,其中的KV不再被使用但又不会GC回收,可认为是内存泄漏),一定会导致内存泄漏,但是使用弱引用可以多一层保障:弱引用ThreadLocal会被GC回收,不会内存泄漏,对应的value在下一次ThreadLocalMap调用set,get,remove的时候会被清除,Java8已经做了上面的代码优化。

    以上是如何使用Java中的ThreadLocal類別?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

    陳述
    本文轉載於:亿速云。如有侵權,請聯絡admin@php.cn刪除
    如何將Maven或Gradle用於高級Java項目管理,構建自動化和依賴性解決方案?如何將Maven或Gradle用於高級Java項目管理,構建自動化和依賴性解決方案?Mar 17, 2025 pm 05:46 PM

    本文討論了使用Maven和Gradle進行Java項目管理,構建自動化和依賴性解決方案,以比較其方法和優化策略。

    如何使用適當的版本控制和依賴項管理創建和使用自定義Java庫(JAR文件)?如何使用適當的版本控制和依賴項管理創建和使用自定義Java庫(JAR文件)?Mar 17, 2025 pm 05:45 PM

    本文使用Maven和Gradle之類的工具討論了具有適當的版本控制和依賴關係管理的自定義Java庫(JAR文件)的創建和使用。

    如何使用咖啡因或Guava Cache等庫在Java應用程序中實現多層緩存?如何使用咖啡因或Guava Cache等庫在Java應用程序中實現多層緩存?Mar 17, 2025 pm 05:44 PM

    本文討論了使用咖啡因和Guava緩存在Java中實施多層緩存以提高應用程序性能。它涵蓋設置,集成和績效優勢,以及配置和驅逐政策管理最佳PRA

    如何將JPA(Java持久性API)用於具有高級功能(例如緩存和懶惰加載)的對象相關映射?如何將JPA(Java持久性API)用於具有高級功能(例如緩存和懶惰加載)的對象相關映射?Mar 17, 2025 pm 05:43 PM

    本文討論了使用JPA進行對象相關映射,並具有高級功能,例如緩存和懶惰加載。它涵蓋了設置,實體映射和優化性能的最佳實踐,同時突出潛在的陷阱。[159個字符]

    Java的類負載機制如何起作用,包括不同的類載荷及其委託模型?Java的類負載機制如何起作用,包括不同的類載荷及其委託模型?Mar 17, 2025 pm 05:35 PM

    Java的類上載涉及使用帶有引導,擴展程序和應用程序類負載器的分層系統加載,鏈接和初始化類。父代授權模型確保首先加載核心類別,從而影響自定義類LOA

    See all articles

    熱AI工具

    Undresser.AI Undress

    Undresser.AI Undress

    人工智慧驅動的應用程序,用於創建逼真的裸體照片

    AI Clothes Remover

    AI Clothes Remover

    用於從照片中去除衣服的線上人工智慧工具。

    Undress AI Tool

    Undress AI Tool

    免費脫衣圖片

    Clothoff.io

    Clothoff.io

    AI脫衣器

    AI Hentai Generator

    AI Hentai Generator

    免費產生 AI 無盡。

    熱門文章

    R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
    4 週前By尊渡假赌尊渡假赌尊渡假赌
    R.E.P.O.最佳圖形設置
    4 週前By尊渡假赌尊渡假赌尊渡假赌
    R.E.P.O.如果您聽不到任何人,如何修復音頻
    4 週前By尊渡假赌尊渡假赌尊渡假赌
    R.E.P.O.聊天命令以及如何使用它們
    4 週前By尊渡假赌尊渡假赌尊渡假赌

    熱工具

    mPDF

    mPDF

    mPDF是一個PHP庫,可以從UTF-8編碼的HTML產生PDF檔案。原作者Ian Back編寫mPDF以從他的網站上「即時」輸出PDF文件,並處理不同的語言。與原始腳本如HTML2FPDF相比,它的速度較慢,並且在使用Unicode字體時產生的檔案較大,但支援CSS樣式等,並進行了大量增強。支援幾乎所有語言,包括RTL(阿拉伯語和希伯來語)和CJK(中日韓)。支援嵌套的區塊級元素(如P、DIV),

    Atom編輯器mac版下載

    Atom編輯器mac版下載

    最受歡迎的的開源編輯器

    EditPlus 中文破解版

    EditPlus 中文破解版

    體積小,語法高亮,不支援程式碼提示功能

    PhpStorm Mac 版本

    PhpStorm Mac 版本

    最新(2018.2.1 )專業的PHP整合開發工具

    WebStorm Mac版

    WebStorm Mac版

    好用的JavaScript開發工具