91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

java多線程編程之InheritableThreadLocal

發布時間:2020-09-11 23:59:59 來源:腳本之家 閱讀:185 作者:WAUANG 欄目:編程語言

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對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改
在線程A中:1508210392057對繼承值進行修改

是不是有一個疑問,為什么子線程能獲取父線程的數據?

我們可以看到InheritableThreadLocal重寫了getMap方法和createMap方法,上一節講ThreadLocal的時候我們知道,ThreadLocal的值是存儲在一個叫ThreadLocals的變量中,但是現在返回一個InheritableThreadLocals,這個變量和ThreadLocals是一模一樣的只是名字換了,那么究竟 為什么在新的 線程中 通過 threadlocal.get() 方法還能得到值呢?

我們看childValue方法可以猜測到可能在線程創建的時候,做了一些手腳,做了一些值得傳遞。

我們打開Thread類的源碼的時候可以發現 :

ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;

所以當我們創建一個子線程的時候,他就存在一個和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循環一個個的將父線程中的值放入我們新創建的值中。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

溧水县| 蒲城县| 茶陵县| 巴中市| 东安县| 怀来县| 天峨县| 航空| 东兴市| 宝山区| 南溪县| 九台市| 湖南省| 波密县| 平乡县| 梁山县| 西林县| 资中县| 博乐市| 车致| 英超| 涞源县| 宾川县| 墨竹工卡县| 肇东市| 台东市| 贞丰县| 樟树市| 社会| 瑞金市| 泽库县| 南和县| 新宾| 湖北省| 肃南| 桐城市| 德江县| 衡东县| 红原县| 陵川县| 武鸣县|