程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> 深刻解析Java中ThreadLocal線程類的感化和用法

深刻解析Java中ThreadLocal線程類的感化和用法

編輯:關於JAVA

深刻解析Java中ThreadLocal線程類的感化和用法。本站提示廣大學習愛好者:(深刻解析Java中ThreadLocal線程類的感化和用法)文章只能為提供參考,不一定能成為您想要的結果。以下是深刻解析Java中ThreadLocal線程類的感化和用法正文


ThreadLocal與線程成員變量還有差別,ThreadLocal該類供給了線程部分變量。這個部分變量與普通的成員變量紛歧樣,ThreadLocal的變量在被多個線程應用時刻,每一個線程只能拿到該變量的一個正本,這是Java API中的描寫,經由過程浏覽API源碼,發明並不是正本,正本甚麼概念?克隆品? 或許是其余模樣,太隱約。
 
精確的說,應當是ThreadLocal類型的變量外部的注冊表(Map<Thread,T>)產生了變更,但ThreadLocal類型的變量自己切實其實是一個,這才是實質!
 
上面就做個例子:
 
1、尺度例子
 
界說了MyThreadLocal類,創立它的一個對象tlt,分離給四個線程應用,成果四個線程tlt變量並沒有湧現共用景象,二是各用各的,這解釋,四個線程應用的是tlt的正本(克隆品)。

 
/** 
* 應用了ThreadLocal的類 
*/ 
public class MyThreadLocal { 
    //界說了一個ThreadLocal變量,用來保留int或Integer數據 
    private ThreadLocal<Integer> tl = new ThreadLocal<Integer>() { 
        @Override 
        protected Integer initialValue() { 
            return 0; 
        } 
    }; 

    public Integer getNextNum() { 
        //將tl的值獲得後加1,並更新設置t1的值 
        tl.set(tl.get() + 1); 
        return tl.get(); 
    } 
}

 

/** 
* 測試線程 
*/ 
public class TestThread extends Thread { 
    private MyThreadLocal tlt = new MyThreadLocal(); 

    public TestThread(MyThreadLocal tlt) { 
        this.tlt = tlt; 
    } 

    @Override 
    public void run() { 
        for (int i = 0; i < 3; i++) { 
            System.out.println(Thread.currentThread().getName() + "\t" + tlt.getNextNum()); 
        } 
    } 
}

 

/** 
* ThreadLocal測試 
*/ 
public class Test { 
    public static void main(String[] args) { 
        MyThreadLocal tlt = new MyThreadLocal(); 
        Thread t1 = new TestThread(tlt); 
        Thread t2 = new TestThread(tlt); 
        Thread t3 = new TestThread(tlt); 
        Thread t4 = new TestThread(tlt); 
        t1.start(); 
        t2.start(); 
        t3.start(); 
        t4.start(); 

    } 
}

 
可以看出,三個線程各自自力編號,互不影響:

Thread-0 1 
Thread-1 1 
Thread-0 2 
Thread-1 2 
Thread-0 3 
Thread-1 3 
Thread-2 1 
Thread-3 1 
Thread-2 2 
Thread-3 2 
Thread-2 3 
Thread-3 3 


Process finished with exit code 0

 
tlt對象是一個,空話tl對象也是一個,由於組合關系是一對一的。然則tl對象外部的Map跟著線程的增多,會創立許多Integer對象。只是Integer和int曾經通用了。所以感到不到Integer的對象屬性。
 
2、不消ThreadLocal
 
假設不消ThreadLocal,只須要將MyThreadLocal類從新界說為:



/** 
* 應用了ThreadLocal的類 
*/ 
public class MyThreadLocal { 
    private Integer t1 = 0; 
    public Integer getNextNum(){ 
        return t1=t1+1; 
    } 



//    界說了一個ThreadLocal變量,用來保留int或Integer數據 
//    private ThreadLocal<Integer> tl = new ThreadLocal<Integer>() { 
//        @Override 
//        protected Integer initialValue() { 
//            return 0; 
//        } 
//    }; 
// 
//    public Integer getNextNum() { 
//        //將tl的值獲得後加1,並更新設置t1的值 
//        tl.set(tl.get() + 1); 
//        return tl.get(); 
//    } 
}

 
然後運轉測試:

Thread-2 1 
Thread-2 2 
Thread-1 4 
Thread-1 6 
Thread-3 3 
Thread-3 9 
Thread-3 10 
Thread-1 8 
Thread-0 7 
Thread-0 11 
Thread-0 12 
Thread-2 5 

Process finished with exit code 0

 
從這裡可以看出,四個線程同享了tlt變量,成果每一個線程都直接修正tlt的屬性。
 
3、本身完成個ThreadLocal
 

package com.lavasoft.test2; 

import java.util.Collections; 
import java.util.HashMap; 
import java.util.Map; 

/** 
* 應用了ThreadLocal的類 
*/ 
public class MyThreadLocal { 

    //界說了一個ThreadLocal變量,用來保留int或Integer數據 
    private com.lavasoft.test2.ThreadLocal<Integer> tl = new com.lavasoft.test2.ThreadLocal<Integer>() { 
        @Override 
        protected Integer initialValue() { 
            return 0; 
        } 
    }; 

    public Integer getNextNum() { 
        //將tl的值獲得後加1,並更新設置t1的值 
        tl.set(tl.get() + 1); 
        return tl.get(); 
    } 
} 

class ThreadLocal<T> { 
    private Map<Thread, T> map = Collections.synchronizedMap(new HashMap<Thread, T>()); 

    public ThreadLocal() { 
    } 

    protected T initialValue() { 
        return null; 
    } 

    public T get() { 
        Thread t = Thread.currentThread(); 
        T obj = map.get(t); 
        if (obj == null && !map.containsKey(t)) { 
            obj = initialValue(); 
            map.put(t, obj); 
        } 
        return obj; 
    } 

    public void set(T value) { 
        map.put(Thread.currentThread(), value); 
    } 

    public void remove() { 
        map.remove(Thread.currentThread()); 
    } 
}

 
運轉測試:

Thread-0 1 
Thread-0 2 
Thread-0 3 
Thread-2 1 
Thread-2 2 
Thread-3 1 
Thread-2 3 
Thread-3 2 
Thread-1 1 
Thread-3 3 
Thread-1 2 
Thread-1 3 

Process finished with exit code 0

 
很不測,這個盜窟版的ThreadLocal也異樣運轉很好,完成了JavaAPI中ThreadLocal的功效。
 
4、透過景象看實質
 
其實從法式角度看,tlt變量切實其實是一個,毫無疑問的。然則為何打印出來的數字就互不影響呢?
是由於應用了Integer嗎?-----不是。
緣由是:protected T initialValue()和get(),由於每一個線程在挪用get()時刻,發明Map中不存在就創立。挪用它的時刻,就創立了一個新變量,類型為T。每次都新建,固然各用個的互不影響了。
為了看清實質,將Integer換失落,重寫部門類:
 

package com.lavasoft.test2; 

import java.util.Collections; 
import java.util.HashMap; 
import java.util.Map; 

/** 
* 應用了ThreadLocal的類 
*/ 
public class MyThreadLocal { 

    //界說了一個ThreadLocal變量,用來保留int或Integer數據 
    //    private ThreadLocal<Bean> tl = new ThreadLocal<Bean>() { 
    private com.lavasoft.test2.ThreadLocal<Bean> tl = new com.lavasoft.test2.ThreadLocal<Bean>() { 
        @Override 
        protected Bean initialValue() { 
            return new Bean(); 
        } 
    }; 

    @Override 
    public String toString() { 
        return "MyThreadLocal{" + 
                "tl=" + tl + 
                '}'; 
    } 

    public Bean getBean() { 
        return tl.get(); 
    } 

} 

class ThreadLocal<T> { 
    private Map<Thread, T> map = Collections.synchronizedMap(new HashMap<Thread, T>()); 

    public ThreadLocal() { 
    } 

    protected T initialValue() { 
        return null; 
    } 

    public T get() { 
        Thread t = Thread.currentThread(); 
        T obj = map.get(t); 
        if (obj == null && !map.containsKey(t)) { 
            obj = initialValue(); 
            map.put(t, obj); 
        } 
        return obj; 
    } 

    public void set(T value) { 
        map.put(Thread.currentThread(), value); 
    } 

    public void remove() { 
        map.remove(Thread.currentThread()); 
    } 
}

 

package com.lavasoft.test2; 

/** 
* 測試Bean 
*/ 
public class Bean { 
    private String id = "0"; 
    private String name = "none"; 

    public Bean() { 
    } 

    public Bean(String id, String name) { 
        this.id = id; 
        this.name = name; 
    } 

    public String getId() { 
        return id; 
    } 

    public void setId(String id) { 
        this.id = id; 
    } 

    public String getName() { 
        return name; 
    } 

    public void setName(String name) { 
        this.name = name; 
    } 

    public String showinfo() { 
        return "Bean{" + 
                "id='" + id + '\'' + 
                ", name='" + name + '\'' + 
                '}'; 
    } 
}

 

package com.lavasoft.test2; 

/** 
* 測試線程 
*/ 
public class TestThread extends Thread { 
    private MyThreadLocal tlt = new MyThreadLocal(); 

    public TestThread(MyThreadLocal tlt) { 
        this.tlt = tlt; 
    } 

    @Override 
    public void run() { 
        System.out.println(">>>>>:" + tlt); 
        for (int i = 0; i < 3; i++) { 
            System.out.println(Thread.currentThread().getName() + "\t" +tlt.getBean()+"\t"+tlt.getBean().showinfo()); 
        } 
    } 
}

 
然後運轉測試:

>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 


Process finished with exit code 0

 
從打印成果很清晰的看到,MyThreadLocal的tlt對象切實其實是一個,tlt對象裡的ThreadLocal的tl對象也是一個,然則,將t1t給每一個線程用的時刻,線程會從新創立Bean對象參加到ThreadLocal的Map中去應用。


關於ThreadLocal的幾個誤區:
1、ThreadLocal是java線程的一個完成

ThreadLocal切實其實是和java線程有關,不外它其實不是java線程的一個完成,它只是用來保護當地變量。針對每一個線程,供給本身的變量版本,重要是為了不線程抵觸,每一個線程保護本身的版本。彼此自力,修正不會影響到對方。

2、ThreadLocal是絕對於每一個session的

ThreadLocal望文生義,是針對線程。在java web編程上,每一個用戶從開端到會話停止,都有本身的一個session標識。然則ThreadLocal其實不是在會話層上。其實,Threadlocal是自力於用戶session的。它是一種辦事器端行動,當辦事器每生成一個新的線程時,就會保護本身的ThreadLocal。

關於這個誤會,小我以為應當是開辟人員在當地基於一些運用辦事器測試的成果。盡人皆知,普通的運用辦事器都邑保護一套線程池,也就是說,關於每次拜訪,其實不必定就重生成一個線程。而是本身有一個線程緩存池。關於拜訪,先從緩存池外面找到已有的線程,假如曾經用光,才去重生成新的線程。

所以,因為開辟人員本身在測試時,普通只要他本身在測,如許辦事器的累贅很小,如許招致每次拜訪能夠是共用異樣一個線程,招致會有如許的誤會:每一個session有一個ThreadLocal

3、ThreadLocal是絕對於每一個線程的,用戶每次拜訪會有新的ThreadLocal

實際下去說,ThreadLocal是切實其實是絕對於每一個線程,每一個線程會有本身的ThreadLocal。然則下面曾經講到,普通的運用辦事器都邑保護一套線程池。是以,分歧用戶拜訪,能夠會接收到異樣的線程。是以,在做基於TheadLocal時,須要謹嚴,防止湧現ThreadLocal變量的緩存,招致其他線程拜訪到本線程變量

4、對每一個用戶拜訪,ThreadLocal可以多用

可以說,ThreadLocal是一把雙刃劍,用得來的話可以起到異常好的後果。然則,ThreadLocal假如用得欠好,就會跟全局變量一樣。代碼不克不及重用,不克不及自力測試。由於,一些原來可以重用的類,如今依附於ThreadLocal變量。假如在其他沒有ThreadLocal場所,這些類就變得弗成用了。小我認為ThreadLocal用得很好的幾個運用場所,值得參考

1、寄存以後session用戶:quake want的jert

2、寄存一些context變量,好比webwork的ActionContext

3、寄存session,好比Spring hibernate orm的session

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved