這篇文章主要介紹了ThreadLocal怎么用,具有一定借鑒價(jià)值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
10多年的興賓網(wǎng)站建設(shè)經(jīng)驗(yàn),針對(duì)設(shè)計(jì)、前端、開(kāi)發(fā)、售后、文案、推廣等六對(duì)一服務(wù),響應(yīng)快,48小時(shí)及時(shí)工作處理。成都營(yíng)銷網(wǎng)站建設(shè)的優(yōu)勢(shì)是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同,自動(dòng)調(diào)整興賓建站的顯示方式,使網(wǎng)站能夠適用不同顯示終端,在瀏覽器中調(diào)整網(wǎng)站的寬度,無(wú)論在任何一種瀏覽器上瀏覽網(wǎng)站,都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì),從而大程度地提升瀏覽體驗(yàn)。成都創(chuàng)新互聯(lián)公司從事“興賓網(wǎng)站設(shè)計(jì)”,“興賓網(wǎng)站推廣”以來(lái),每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。
1. ThreadLocal
ThreadLocal只有一個(gè)無(wú)參的構(gòu)造方法
public ThreadLocal()
ThreadLocal的相關(guān)方法
public T get()
public void set(T value)
public void remove()
protected T initialValue()
initialValue方法的訪問(wèn)修飾符是protected,該方法為第一次調(diào)用get方法提供一個(gè)初始值。默認(rèn)情況下,第一次調(diào)用get方法返回值null。在使用時(shí),我們一般會(huì)復(fù)寫ThreadLocal的initialValue方法,使第一次調(diào)用get方法時(shí)返回一個(gè)我們?cè)O(shè)定的初始值。
下面是一個(gè)ThreadLocal的一個(gè)簡(jiǎn)單使用示例
package javalearning; import java.util.Random; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; public class ThreadLocalDemo { /*定義了1個(gè)ThreadLocal對(duì)象, *并復(fù)寫它的initialValue方法,初始值是3*/ private ThreadLocal tlA = new ThreadLocal (){ protected Integer initialValue(){ return 3; } } ; /* private ThreadLocal tlB = new ThreadLocal (){ protected Integer initialValue(){ return 5; } }; */ /*設(shè)置一個(gè)信號(hào)量,許可數(shù)為1,讓三個(gè)線程順序執(zhí)行*/ Semaphore semaphore = new Semaphore(1); private Random rnd = new Random(); /*Worker定義為內(nèi)部類實(shí)現(xiàn)了Runnable接口,tlA定義在外部類中, 每個(gè)線程中調(diào)用這個(gè)對(duì)象的get方法,再調(diào)用一個(gè)set方法設(shè)置一個(gè)隨機(jī)值*/ public class Worker implements Runnable{ @Override public void run(){ try { Thread.sleep(rnd.nextint(1000)); /*隨機(jī)延時(shí)1s以內(nèi)的時(shí)間*/ semaphore.acquire(); /*獲取許可*/ } catch (InterruptedException e) { e.printStackTrace(); } int valA = tlA.get(); System.out.println(Thread.currentThread().getName() +" tlA initial val : "+ valA); valA = rnd.nextint(); tlA.set(valA); System.out.println(Thread.currentThread().getName() +" tlA new val: "+ valA); /* int valB = tlB.get(); System.out.println(Thread.currentThread().getName() +" tlB initial val : "+ valB); valB = rnd.nextInt(); tlA.set(valB); System.out.println(Thread.currentThread().getName() +" tlB 2 new val: "+ valB); */ semaphore.release(); /*在線程池中,當(dāng)線程退出之前一定要記得調(diào)用remove方法,因?yàn)樵诰€程池中的線程對(duì)象是循環(huán)使用的*/ tlA.remove(); /*tlB.remove();*/ } } /*創(chuàng)建三個(gè)線程,每個(gè)線程都會(huì)對(duì)ThreadLocal對(duì)象tlA進(jìn)行操作*/ public static void main(String[] args){ ExecutorService es = Executors.newFixedThreadPool(3); ThreadLocalDemo tld = new ThreadLocalDemo(); es.execute(tld.new Worker()); es.execute(tld.new Worker()); es.execute(tld.new Worker()); es.shutdown(); } }
運(yùn)行結(jié)果
pool-1-thread-1 tlA initial val : 3 pool-1-thread-1 tlA new val: -1288455998 pool-1-thread-3 tlA initial val : 3 pool-1-thread-3 tlA new val: 112537197 pool-1-thread-2 tlA initial val : 3 pool-1-thread-2 tlA new val: -12271334
從運(yùn)行結(jié)果可以看出,每個(gè)線程第一次調(diào)用TheadLocal對(duì)象的get方法時(shí)都得到初始值3,注意我們上面的代碼是讓三個(gè)線程順序執(zhí)行,顯然從運(yùn)行結(jié)果看,pool-1-thread-1線程結(jié)束后設(shè)置的新值,對(duì)pool-1-thread-3線程是沒(méi)有影響的,pool-1-thread-3線程完成后設(shè)置的新值對(duì)pool-1-thread-2線程也沒(méi)有影響。這就仿佛把ThreadLocal對(duì)象當(dāng)做每個(gè)線程內(nèi)部的對(duì)象一樣,但實(shí)際上tlA對(duì)象是個(gè)外部類對(duì)象,內(nèi)部類Worker訪問(wèn)到的是同一個(gè)tlA對(duì)象,也就是說(shuō)是被各個(gè)線程共享的。這是如何做到的呢?我們現(xiàn)在就來(lái)看看ThreadLocal對(duì)象的內(nèi)部原理。
2.ThreadLocal
首先,在Thread類中定義了一個(gè)threadLocals,它是ThreadLocal.ThreadLocalMap對(duì)象的引用,默認(rèn)值是null。ThreadLocal.ThreadLocalMap對(duì)象表示了一個(gè)以開(kāi)放地址形式的散列表。當(dāng)我們?cè)诰€程的run方法中第一次調(diào)用ThreadLocal對(duì)象的get方法時(shí),會(huì)為當(dāng)前線程創(chuàng)建一個(gè)ThreadLocalMap對(duì)象。也就是每個(gè)線程都各自有一張獨(dú)立的散列表,以ThreadLocal對(duì)象作為散列表的key,set方法中的值作為value(第一次調(diào)用get方法時(shí),以initialValue方法的返回值作為value)。顯然我們可以定義多個(gè)ThreadLocal對(duì)象,而我們一般將ThreadLocal對(duì)象定義為static類型或者外部類中。上面所表達(dá)的意思就是,相同的key在不同的散列表中的值必然是獨(dú)立的,每個(gè)線程都是在各自的散列表中執(zhí)行操作。
TheadLocal中的get源代碼
public T get() { Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null) { ThreadLocalMap.Entry e = map.getEntry(this);//這里的this是指當(dāng)前的ThreadLocal對(duì)象 if (e != null) { @SuppressWarnings("unchecked") T result = (T)e.value; return result; } } return setInitialValue(); }
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享的“ThreadLocal怎么用”這篇文章對(duì)大家有幫助,同時(shí)也希望大家多多支持創(chuàng)新互聯(lián),關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,更多相關(guān)知識(shí)等著你來(lái)學(xué)習(xí)!