一、多線程導圖
二、多線程基礎
1、基礎概念
線程是操作系統能夠進行運算調度的最小單位,包含在進程之中,是進程中的實際運作單位。一條線程指的是進程中一個單一順序的控制流,一個進程中可以併發多個線程,每條線程並行執行不同的任務。
2、創建方式
繼承Thread類、實現Runnable接口、基於Callable和Future接口、Timer是後臺線程、線程池。
3、線程狀態
狀態描述:初始狀態、運行狀態、阻塞狀態、等待狀態、超時等待狀態、終止狀態。
4、執行機制
JVM中一個應用是可以有多個線程並行執行,線程被一對一映射為服務所在操作系統線程,調度在可用的CPU上執行,啟動時會創建一個操作系統線程;當該線程終止時,這個操作系統線程也會被回收。
5、內存模型
在虛擬機啟動運行時,會創建多個線程,數據區中有的模塊是線程共享的,有的是線程私有的:
線程共享:元數據區、堆Heap;
線程私有:虛擬機棧、本地方法棧、程序計數器;
單個CPU在特定時刻只能執行一個線程,所以多線程通過幾塊空間的使用,然後不斷的爭搶CPU的執行時間段。
三、常見概念
1、線程優先級
線程調度器傾向執行線程優先級高的線程,線程優先級高說明獲取CPU資源的概率高,或者獲取的執行時間分片多,被執行的概率高但不代表優先級低的一定最後執行。
2、守護線程
守護線程是支持輔助型線程,主要在程序中起到調度和支持性作用,當Jvm中非守護線程全部結束,守護線程也就會結束。
3、線程加入
線程A中,執行線程B的加入方法,那麼A線程就會等待線程B執行完畢再返回繼續執行。
4、本地線程
ThreadLocal也叫做線程本地變量,為變量在每個線程中的創建副本,每個線程可以訪問自己內部的副本變量,線程之間互不相互影響。
四、線程安全
在上圖線程與內存空間的佔用方式看,在線程訪問共享內存塊時,保證線程安全就很有必要。
1、同步控制
Synchronized關鍵字同步控制,可以修飾方法,修飾代碼塊,修飾靜態方法等,同步控制的資源少,可以提高多線程效率。
2、加鎖機制
Lock接口:Java併發編程中資源加鎖的根接口之一,規定了資源鎖使用的幾個基礎方法。
ReentrantLock類:實現Lock接口的可重入鎖,即線程如果獲得當前實例的鎖,並進入任務方法,在線程沒有釋放鎖的狀態下,可以再次進入任務方法,特點:互斥排它性,即同一個時刻只有一個線程進入任務。
Condition接口:描述可能會與鎖有關聯的條件變量,提供了更強大的功能,例如在線程的等待/通知機制上,Conditon可以實現多路通知和選擇性通知。
3、Volatile關鍵字
volatile修飾成員變量,不能修飾方法,即標識該線程在訪問這個變量時需要從共享內存中獲取,對該變量的修改,也需要同步刷新到共享內存中,保證了變量對所有線程的可見性。
五、線程通信
線程是個獨立的個體,但是在線程執行過程中,如果處理同一個業務邏輯,可能會產生資源爭搶,導致併發問題,甚至死鎖現象,線程之間協調工作,就需要通信機制來保障。
1、基礎方法
相關方法是Java中Object層級的基礎方法,任何對象都有該方法:notify()隨機通知一個在該對象上等待的線程,使其結束wait狀態返回;wait()線程進入waiting等待狀態,不會爭搶鎖對象,也可以設置等待時間;
2、等待/通知機制
等待/通知機制,該模式下指線程A在不滿足任務執行的情況下調用對象wait()方法進入等待狀態,線程B修改了線程A的執行條件,並調用對象notify()或者notifyAll()方法,線程A收到通知後從wait狀態返回,進而執行後續操作。兩個線程通過基於對象提供的wait()/notify()/notifyAll()等方法完成等待和通知間交互,提高程序的可伸縮性。
3、管道流通信
管道流主要用於在不同線程間直接傳送數據,一個線程發送數據到輸出管道,另一個線程從輸入管道中讀取數據,進而實現不同線程間的通信。
六、線程池
1、Executor接口
Executor系統中,將線程任務提交和任務執行進行了解耦的設計,Executor有各種功能強大的實現類,提供便捷方式來提交任務並且獲取任務執行結果,封裝了任務執行的過程,不再需要Thread().start()方式,顯式創建線程並關聯執行任務。
2、核心參數
3、相關API類
線程池任務:核心接口:Runnable、Callable接口和接口實現類;
任務的結果:接口Future和實現類FutureTask;
任務的執行:核心接口Executor和ExecutorService接口。在Executor框架中有兩個核心類實現了ExecutorService接口,ThreadPoolExecutor和ScheduledThreadPoolExecutor。
七、常用線程API
1、Fork/Join機制
Fork/Join框架用於並行執行任務,核心的思想就是將一個大任務切分成多個小任務,然後彙總每個小任務的執行結果得到這個大任務的最終結果。核心流程:切分任務,模塊任務異步執行,單任務結果合併。
2、容器類
ConcurrentHashMap:使用分段鎖機制,把容器中數據分成一段一段的方式存儲,然後給每一段數據配一把鎖,當一個線程佔用鎖訪問其中一個段數據的時候,其他段的數據也能被其他線程訪問,即考慮安全性也顧及執行效率。
ConcurrentLinkedQueue:基於鏈接節點的無界線程安全隊列,按照FIFO先進先出原則對元素進行排序,隊列的頭部 是隊列中時間最長的元素,隊列的尾部是隊列中時間最短的元素,新的元素添加到隊列的尾部,獲取元素操作從隊列頭部得到。
3、原子類
JDK自帶原子操作類,處理多個線程同時操作一個變量的情況,其中包括:基本類型、數組類型、引用類型、屬性修改類型。
八、應用場景
1、定時任務
通過配置設置一些程序在指定時間點,或者週期時間內規律循環執行,這裡任務的執行就是基於多線程技術。
2、異步處理
異步處理就是不按照當前同步代碼塊程序執行,異步處理與同步處理是對立的,異步的實現也需要多線程或者多進程,提高程序效率。
3、任務分解
分佈式數據庫中常見操作,數據分佈在不同的數據庫的副本中,在執行查詢時,每個服務都要跑查詢任務,最後在一個服務上做數據合併,或者提供一箇中間引擎層,用來彙總數據,在大型的定時任務中,經常把要處理的任務按照特定策略分片,多個線程同時處理。
4、連接池技術
創建和管理一個連接的緩衝池的技術,這些連接準備好被任何需要它們的線程使用,減少連接不斷創建和釋放的問題,提高程序效率。
本文源碼:GitHub·點這裡 || GitEE·點這裡