ThreadLocal 變量和 與線程池配合使用時可能會出現的問題

ThreadLocal 的介紹和使用

先看下ThreadLocal變量的使用

public void set(T value) {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null)map.set(this, value);elsecreateMap(t, value);} //獲取Thread類里面的 ThreadLocalMap 變量ThreadLocalMap getMap(Thread t) {return t.threadLocals;}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();}

可以看出來，ThreadLocal就是在每個線程 Thread 類里的變量 ThreadLocalMap。

而ThreadLocalMap 這個Map和HashMap類似。

從這可以看出來，ThreadLocal 中有一個在每個線程中不一樣的Map(因為是Thread類的成員變量)，所以實現了一個多個線程隔離的數據集。

線程池的回顧

線程池的實現中，啟動的工作線程如果有工作會一直工作，直到workQueue中的數據沒有，并且超過了pollingTime才會銷毀這個工作線程。

兩者結合的問題

所以在使用線程池的時候再使用 ThreadLocal 變量就會有一個，同一個工作線程執行不同的任務時，ThreadLocal變量就會有臟讀的現象。來看一個例子：

public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(2);final ThreadLocal<String> threadLocal = new ThreadLocal<String>();Runnable runnable = new Runnable() {public void run() {System.out.println(threadLocal.get() == null);threadLocal.set(Thread.currentThread().getName()+": name");}};executorService.submit(runnable);executorService.submit(runnable);executorService.submit(runnable);executorService.submit(runnable);executorService.submit(runnable);executorService.submit(runnable);executorService.shutdown();}

console中打印的數據：

true true false false false false

結論

由上面的console中打印的數據可以看出來，在提交后面幾個任務的時候 threadLocal都不是空值了。即說明

線程池中多個任務可能會使用同一個 ThreadLocal,原因是線程池可能會使用公用的線程來執行任務

總結

以上是生活随笔為你收集整理的ThreadLocal 变量和 与线程池配合使用时可能会出现的问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。