這篇文章主要為大家詳細介紹了java多線程編程之InheritableThreadLocal,具有一定的參考價值,感興趣的小伙伴們可以參考一下
InheritableThreadLocal的作用: 當我們需要在子線程中使用父線程中的值得時候我們就可以像使用ThreadLocal那樣來使用InheritableThreadLocal了。
首先我們來看看InheritableThreadLocal的jdk原始碼:
package java.lang; import java.lang.ref.*; public class InheritableThreadLocal<T> extends ThreadLocal<T> { protected T childValue(T parentValue) { return parentValue; } ThreadLocalMap getMap(Thread t) { return t.inheritableThreadLocals; } void createMap(Thread t, T firstValue) { t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue); } }
這段程式碼就是InheritableThreadLocal的完整原始碼(刪除了很長的註釋)。
首先我們可以看到它是繼承ThreadLocal類別的,然後提供了:
protected T childValue(T parentValue){}方法,這就是InheritableThreadLocal的關鍵所在,它提供了這個方法,傳回父執行緒中的值,如果還需要在父執行緒上新增值則可以重寫childValue方法。
package InheritableThreadLocal; import java.util.Date; public class InheritableThreadLocaExt extends InheritableThreadLocal{ protected Object initialValue() { return new Date().getTime(); } protected Object childValue(Object parentValue) { return parentValue+"对继承值进行修改"; } } package InheritableThreadLocal; public class tool { public static InheritableThreadLocaExt t=new InheritableThreadLocaExt(); } package InheritableThreadLocal; public class MyThread extends Thread{ public void run() { try { for(int i=0;i<10;i++) { System.out.println("在线程A中:"+tool.t.get()); sleep(100); } } catch (InterruptedException e) { e.printStackTrace(); } } } package InheritableThreadLocal; public class test { public static void main(String[] args) { try { for(int i=0;i<10;i++) { System.out.println("主线程中值:"+tool.t.get()); Thread.sleep(100); } Thread.sleep(5000); MyThread thread=new MyThread(); thread.start(); }catch(InterruptedException e){ e.printStackTrace(); } } }
運行輸出:
主執行緒中值:1508210392057
主執行緒中位數:1508210392057
主執行緒中值:1508210392057
主線程中值:1508210392057
主線程中值:1508210392057
主線程中值:1508210392057
主線程中值:1508210392057
主線程中值:1508210392057
主執行緒中位數:1508210392057
主執行緒中位數:1508210392057
在執行緒A中:1508210392057對繼承值進行修改
在執行緒A中:1508210392057對繼承值進行修改
在執行緒A中:1508210392057對繼承值進行修改
:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
#在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:15082103320577對繼承值進行修改
是不是有一個疑問,為什麼子執行緒能取得父執行緒的資料?
我們可以看到InheritableThreadLocal重寫了getMap方法和createMap方法,上一節講ThreadLocal的時候我們知道,ThreadLocal的值是儲存在一個叫做ThreadLocals的變數中,但現在傳回一個InheritableThreadLocals,這個變數和ThreadLocals是一模一樣的只是名字換了,那麼究竟為什麼在新的線程中透過threadlocal.get() 方法還能得到值呢?
我們看childValue方法可以猜測到可能在執行緒建立的時候,做了一些手腳,做了一些值得傳遞。
我們開啟Thread類別的原始碼的時候可以發現:
#所以當我們創建一個子線程的時候,他就存在一個和ThreadLocals的一樣的InheritableThreadLocal變量,再往下看:
private void init(ThreadGroup g, Runnable target, String name, long stackSize, AccessControlContext acc, . . if (inheritThreadLocals && parent.inheritableThreadLocals != null) this.inheritableThreadLocals = ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
if (inheritThreadLocals && parent.inheritableThreadLocals != null) this.inheritableThreadLocals = ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
繼續看:
static ThreadLocalMap createInheritedMap(ThreadLocalMap parentMap) { return new ThreadLocalMap(parentMap); }###
private ThreadLocalMap(ThreadLocalMap parentMap) { Entry[] parentTable = parentMap.table; int len = parentTable.length; setThreshold(len); table = new Entry[len]; for (int j = 0; j < len; j++) { Entry e = parentTable[j]; if (e != null) { @SuppressWarnings("unchecked") ThreadLocal<Object> key = (ThreadLocal<Object>) e.get(); if (key != null) { Object value = key.childValue(e.value); Entry c = new Entry(key, value); int h = key.threadLocalHashCode & (len - 1); while (table[h] != null) h = nextIndex(h, len); table[h] = c; size++; } } } }###有這段程式碼,先得到父線程(也就是目前執行的線程)的值,然後用for循環一個個的將父線程中的值放入我們新建立的值中。 ###
以上是Java多執行緒中有關InheritableThreadLocal的詳解的詳細內容。更多資訊請關注PHP中文網其他相關文章!