開發與維運

java-Thread筆記

生命週期

線程流轉.png

相關方法

interrupt():實例方法將線程中斷標識設置為true,如線程在wait/sleep則報java.lang.InterruptedException

interrupted():靜態方法,Thread.interrupted()重置當前線程中斷標識

isInterrupted(): 實例方法獲取當前線程中斷標識

join():中斷當前線程,等待調用線程結束後再執行

Thread.sleep(millis):當前線程休眠x毫秒,不釋放持有鎖

LockSupport.park():中斷當前線程,不釋放持有鎖

Object.wait(millis):當前線程等待x秒,不傳遞則無限期等待,釋放持有鎖

線程變量

ThreadLocal:同線程內共享,無法傳遞至子線程

生命週期:在設置第一個值時通過Thread.currentThread()與當前線程中threadLocals進行關聯,並初始化一個ThreadLocalMap進行存儲。

ThreadLocalMap中存儲內容的Entry使用的是WeakReference弱引用,便於垃圾回收。

  • 在非線程池情況下由於key為弱引用在代碼中沒有繼續使用時(強引用去掉後只剩弱引用),會被gc回收.get方法會清理不存在的key對應的value,保障了內存回收
  • 在線程池中使用時由於線程不會被回收,Thread這個強引用不會被清理,所以存在內存溢出風險。 可在使用完成之後通過remove方法清理來規避這個隱患。
  • 使用static初始化時也存在生命週期過長存在內存溢出隱患

InheritableThreadLocal:只有在創建線程池時會初始化,所以線程池場景會導致賦值邏輯混亂

重寫了childValue(),getMap(Thread),createMap(Thread t, T firstValue) 來實現子線程的內容賦值

ThreadLocal/InheritableThreadLocal 使用流程:

ThreadLocal,InheritableThreadLocal調用流程.png

TransmittableThreadLocal:可傳遞至子線程,子線程獨立操作,新開線程也會獲取新的值,需配合TtlRunnable或修改java啟動參數來使用

整個過程的官方完整時序圖:

TransmittableThreadLocal調用流程.png

依據官方時序圖自己的整理:

TransmittableThreadLocal調用流程-M.png

Leave a Reply

Your email address will not be published. Required fields are marked *