最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

ThreadLocal導(dǎo)致JVM內(nèi)存泄漏原因探究

 更新時(shí)間:2023年04月19日 11:24:57   作者:胡尚  
ThreadLocal是JDK提供的線程本地變量機(jī)制,但若使用不當(dāng)可能導(dǎo)致內(nèi)存泄漏。正確的使用方式是在使用完后及時(shí)remove,或者使用弱引用等手段避免強(qiáng)引用導(dǎo)致的內(nèi)存泄漏。在多線程編程中,合理使用ThreadLocal可以提高并發(fā)性能,但也需要注意其潛在的內(nèi)存泄漏問題

為什么要使用ThreadLocal

在一整個(gè)業(yè)務(wù)邏輯流程中,為了在不同的地方或者不同的方法中使用同一個(gè)對(duì)象,但是又不想在方法形參中加這個(gè)對(duì)象,那么就可以使用ThreadLocal來保存

ThreadLocal最大的應(yīng)用場(chǎng)景就是跨方法進(jìn)行參數(shù)傳遞

ThreadLocal可以給每一個(gè)線程綁定一個(gè)變量的副本

使用ThreadLocal

ThreadLocal常用的方法其實(shí)也就下面幾個(gè)

// 返回當(dāng)前線程所對(duì)應(yīng)的線程局部變量。
public T get() {}
// 設(shè)置當(dāng)前線程的線程局部變量的值。
public void set(T value) {}
// 移除,當(dāng)線程結(jié)束后,該線程thread對(duì)象中的局部變量將在下一次gc時(shí)回收,如果顯示的調(diào)用此方法只是可以加快內(nèi)存回收的速度
// 所以javase開發(fā) 普通new Thread()方式中,這個(gè)方法并不是必須要調(diào)用的
// 但是javaWeb開發(fā)中就必須顯示調(diào)用,因?yàn)閖avaweb都是使用的線程池,并不是一個(gè)客戶端來一個(gè)請(qǐng)求,thread線程對(duì)象用完就刪除,而是會(huì)放回線程池中。
public void remove() {}
// 返回該線程局部變量的一個(gè)初始化
// protected方法,顯然是為了讓子類覆蓋而設(shè)計(jì)的。這個(gè)方法在第一次調(diào)用 get()或 set(Object)時(shí)才執(zhí)行,并且僅執(zhí)行 1 次
protected T initialValue() {}

在具體使用的時(shí)候,我們ThreadLocal對(duì)象一定會(huì)定義成靜態(tài)的,如果不定義成靜態(tài)的那么其他地方如何通過這個(gè)ThreadLocal實(shí)例去Map中拿數(shù)據(jù)嘞?

而且如果是多個(gè)線程保存一個(gè)變量的副本,一個(gè)靜態(tài)的ThreadLocal也足夠了,因?yàn)樗亲鳛槎鄠€(gè)map中的key存在的

簡(jiǎn)單使用案例

/**
 * @Description: 在一個(gè)方法中調(diào)用set()方法存值,在另一個(gè)方法中調(diào)用get()方法取值
 */
public class UseThreadLocalTest {
    public static ThreadLocal<String> threadLocal = new ThreadLocal<>();
    /**
     * 創(chuàng)建一個(gè)線程類
     */
    public static class ThreadTest extends Thread{
        private Integer id;
        ThreadTest(Integer id){
            this.id = id;
        }
        @Override
        public void run() {
            threadLocal.set(Thread.currentThread().getName() + ":" + id);
            print();
        }
        public void print(){
            System.out.println(threadLocal.get());
        }
    }
    /**
     * 開三個(gè)線程
     */
    public static void main(String[] args) {
        for (int i = 0; i < 3; i++) {
            new ThreadTest(i).start();
        }
    }
}

// 輸入結(jié)果如下
Thread-0:0
Thread-1:1
Thread-2:2

具體實(shí)現(xiàn)

ThreadLocal底層set()和get()方法的源碼如下

// 存值時(shí) map最終是存儲(chǔ)在當(dāng)前線程Thread t = Thread.currentThread()中的,是thread的一個(gè)成員變量
// map的key是當(dāng)前threadLocal對(duì)象實(shí)例,value是要存的值
public void set(T value) {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null)
        map.set(this, value);
    else
        createMap(t, value);
}
// 取值時(shí)也是也是先從當(dāng)前線程Thread對(duì)象中取出map
// 然后在從map中根據(jù)當(dāng)前threadLocal對(duì)象實(shí)例作為key獲取到entry對(duì)象
public T get() {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null) {
        ThreadLocalMap.Entry e = map.getEntry(this);
        if (e != null) {
            @SuppressWarnings("unchecked")
            T result = (T)e.value;
            return result;
        }
    }
    return setInitialValue();
}

為了提高性能,才沒有采用加鎖的方式,而是將map和各個(gè)線程thread對(duì)象進(jìn)行關(guān)聯(lián),這樣就避免了產(chǎn)生線程安全問題,也避免了加鎖,提高了性能

我們接下來再來看看ThreadLocalMap它的實(shí)現(xiàn),它類似于jdk1.7版本的hashmap,底層存儲(chǔ)的是一個(gè)Entry對(duì)象的數(shù)組,初始容量也是16,存值時(shí)先用hash結(jié)果和數(shù)組長(zhǎng)度取余得到數(shù)組下標(biāo)位置,然后判斷是否產(chǎn)生了hash沖突,然后使用開發(fā)定址法來處理。根據(jù)算法的不同又可以分為線性探測(cè)再散列、二次探測(cè)再散列、偽隨機(jī)探測(cè)再散列。ThreadLocalMap它是使用的線性探測(cè)再散列法,如下所示

private static int nextIndex(int i, int len) {
    return ((i + 1 < len) ? i + 1 : 0);
}

Entry對(duì)象中的key它是一個(gè)弱引用,Entry繼承了WeakReference類,弱引用跟沒引用差不多,GC會(huì)直接回收掉,不管內(nèi)存是否足夠都會(huì)回收

static class Entry extends WeakReference<ThreadLocal<?>> {
    Object value;
    Entry(ThreadLocal<?> k, Object v) {
        super(k);
        value = v;
    }
}

引發(fā)內(nèi)存泄漏的原因

上面再介紹ThreadLocal基本使用api方法的時(shí)候也提到了,如果只是創(chuàng)建一個(gè)普通的線程Thread對(duì)象,是不會(huì)產(chǎn)生內(nèi)存泄漏問題的。因?yàn)閙ap是存儲(chǔ)在Thread對(duì)象中,一個(gè)普通線程執(zhí)行完了,那么這個(gè)線程的局部變量也就會(huì)被gc回收。

但如果結(jié)合到了線程池,一個(gè)Thread線程對(duì)象用完后放回線程池中,如果這個(gè)時(shí)候我們程序不顯示的調(diào)用remove()方法,那么就會(huì)造成內(nèi)存泄漏問題了。

因?yàn)镋ntry對(duì)象中的Key的弱引用,但是value還會(huì)存在,就會(huì)存在map中key為null的value

ThreadLocal 的底層實(shí)現(xiàn)中我們可以看見,無論是 get()、set()在某些時(shí) 候,調(diào)用了 expungeStaleEntry() 方法用來清除 Entry 中 Key 為 null 的 Value,但是這是不及時(shí)的,也不是每次都會(huì)執(zhí)行的,所以一些情況下還是會(huì)發(fā)生內(nèi)存泄露。

到此這篇關(guān)于ThreadLocal導(dǎo)致JVM內(nèi)存泄漏原因探究的文章就介紹到這了,更多相關(guān)JVM內(nèi)存泄漏內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

最新評(píng)論

通州市| 娱乐| 霍林郭勒市| 平陆县| 双牌县| 平和县| 区。| 邹城市| 盱眙县| 诏安县| 牡丹江市| 清水河县| 台北县| 三门峡市| 剑河县| 通辽市| 江口县| 彰化县| 抚顺县| 峨山| 申扎县| 临潭县| 江口县| 卫辉市| 本溪市| 云安县| 当涂县| 莫力| 甘肃省| 文成县| 镇雄县| 巨野县| 施秉县| 新建县| 永宁县| 凌海市| 抚州市| 玉门市| 彭泽县| 元朗区| 平阴县|