一篇博客帶你輕鬆應對java面試中的多線程與高並發
1. Java線程的創建方式
(1)繼承thread類
thread類本質是實現了runnable接口的一個實例,代表線程的一個實例。啟動線程的方式start方法。start是一個本地方法,執行後,執行run方法的代碼。
(2)實現runnable接口
如果自己的類已經繼承了別的類,就不能繼承thread類。只能實現runnable接口。
(3)實現callable接口
有返回值的任務必須實現callable接口,無返回值的任務必須實現runnable接口。執行callable接口後,可以獲取一個future對象,通過future對象的get方法可以獲得返回值。結合線程池可以實現有返回值的多線程。
(4)基於線程池的方式
2. 介紹一下java的線程池
java裏麵線程池的頂級接口是executor。嚴格意義上講。executor只是一個接口,真正的線程池是executorservice。
(1)newCachedThreadPool
創建一個可根據需要創建新線程的線程池,但是在以前構造的線程可用時將重用它們。對於執行很多短期異步任務的程序而言,這些線程池通常可提高程序性能。調用 execute 將重用以前構造的線程(如果線程可用)。如果現有線程沒有可用的,則創建一個新線程並添加到池中。終止並從緩存中移除那些已有 60 秒鐘未被使用的線程。因此,長時間保持空閑的線程池不會使用任何資源。
(2)newFixedThreadPool
創建一個可重用固定線程數的線程池,以共享的無界隊列方式來運行這些線程。在任意點,在大多數 nThreads 線程會處於處理任務的活動狀態。如果在所有線程處於活動狀態時提交附加任務,則在有可用線程之前,附加任務將在隊列中等待。如果在關閉前的執行期間由於失敗而導致任何線程終止,那麼一個新線程將代替它執行後續的任務(如果需要)。在某個線程被顯式地關閉之前,池中的線程將一直存在。
(3)newScheduledThreadPool
創建一個線程池,它可安排在給定延遲後運行命令或者定期地執行。
(4)newSingleThreadExecutor
Executors.newSingleThreadExecutor()返回一個線程池(這個線程池只有一個線程),這個線程
池可以在線程死後(或發生異常時)重新啟動一個線程來替代原來的線程繼續執行下去!
3. 線程的聲明周期
線程的生命周期包括新建new,就緒runable,運行running,阻塞blocked和死亡dead。
(1)新建狀態
當程序使用new關鍵字創建了一個線程之後,該線程就屬於新建狀態,此時僅由jvm為其分配內存,並初始化成員變量的值。
(2)就緒狀態
當線程對象調用了start方法之後。線程處於就緒狀態,jvm會為其創建方法調用棧和程序計數器。此時的現場等待cpu的調度。一旦拿到cpu就可以立即執行。
(3)運行狀態
處於就緒狀態的線程獲得了cpu的執行權,狀態就更改為running。此時線程處於運行狀態。
(4)阻塞狀態
阻塞狀態是指線程因為某種原因,放棄了cpu的使用權,暫時停止運行。恢復阻塞後進入就緒狀態,獲得cpu使用權之後,才進入執行狀態。
阻塞的情況分為三種:
等待阻塞
運行中的線程執行wait方法,jvm會把他放入等待隊列中。
同步阻塞
運行的線程獲取對象的同步鎖的時候,jvm會把該線程放入鎖池中。
其他阻塞
運行中的線程執行線程的sleep方法或join方法。或者發出io請求的時候,jvm把對象置為阻塞狀態。當sleep超時,join或者io完畢後,就可以拿到cpu的權,繼續執行。
(5)死亡狀態
正常結束,run或call的方法結束。
異常結束,出現報錯
調用stop,調用stop方法可能會產生思索。
4. 終止線程的四種方式
(1)正常執行結束
(2)使用同一標誌,多個線程共用一個變量,變量使用volite修飾,每次把他作為標誌位來進行判斷。
(3)interrupt結束線程
當線程處於阻塞狀態的時候,如果使用sleep,同步鎖的wait方法,socket的receive方法的時候,會使現場處於阻塞狀態。當調用線程的interrupt方法的時候。會拋出interruptexception異常。阻塞中的那個方法拋出異常,通過代碼捕獲異常,然後結束執行。
線程未處於阻塞狀態的時候,可以使用isinterrupted來進行判斷,while來調這個函數。
(4)stop方法終止線程
stop方法強制執行,會導致現場釋放他所佔有的所有鎖、被保護的數據可能就會出現不一致性。可能會出現很多奇怪的應用程序錯誤。
5. sleep和wait方法的區別
對於sleep方法,屬於Thread類,wait方法數據object類中。
sleep方法導致線程的短暫執行,讓出cpu去執行其他線程。依然監控cpu,當時間到了,立馬拿到cpu的執行權。
調用sleep方法的時候,線程不會釋放鎖。wait方法會放棄對象鎖,進入鎖的等待池。此方法調用了notify之後,才能進入鎖池,進行重新競爭。
6. start與run方法的區別
start方法來啟動線程,真正實現了多線程運行。無需等待run方法結束。可以直接執行其他方法。
調用start方法使線程進入就緒狀態,獲得cpu即可運行。
run方法是線程的run方法執行體。
7. Java的後台進程
1. 定義:守護線程—也稱「服務線程」,他是後台線程,它有一個特性,即為用戶線程提供公
共服務,在沒有用戶線程可服務時會自動離開。
2. 優先級:守護線程的優先級比較低,用於為系統中的其它對象和線程提供服務。
3. 設置:通過 setDaemon(true)來設置線程為「守護線程」;將一個用戶線程設置為守護線程
的方式是在 線程對象創建 之前 用線程對象的 setDaemon 方法。
4. 在 Daemon 線程中產生的新線程也是 Daemon 的。
5. 線程則是 JVM 級別的,以 Tomcat 為例,如果你在 Web 應用中啟動一個線程,這個線程的生命周期並不會和 Web 應用程序保持同步。也就是說,即使你停止了 Web 應用,這個線程依舊是活躍的。
6. example: 垃圾回收線程就是一個經典的守護線程,當我們的程序中不再有任何運行的Thread,程序就不會再產生垃圾,垃圾回收器也就無事可做,所以當垃圾回收線程是 JVM 上僅剩的線程時,垃圾回收線程會自動離開。它始終在低級別的狀態中運行,用於實時監控和管理系統中的可回收資源。
7. 生命周期:守護進程(Daemon)是運行在後台的一種特殊進程。它獨立於控制終端並且周期性地執行某種任務或等待處理某些發生的事件。也就是說守護線程不依賴於終端,但是依賴於系統,與系統「同生共死」。當 JVM 中所有的線程都是守護線程的時候,JVM 就可以退出了;如果還有一個或以上的非守護線程則 JVM 不會退出。
8. Java的鎖
樂觀鎖
樂觀鎖是一種樂觀思想,即認為讀多寫少,遇到並發寫的可能性低,每次去拿數據的時候都認為別人不會修改,所以不會上鎖,但是在更新的時候會判斷一下在此期間別人有沒有去更新這個數據,採取在寫時先讀出當前版本號,然後加鎖操作(比較跟上一次的版本號,如果一樣則更新),如果失敗則要重複讀–比較–寫的操作。java 中的樂觀鎖基本都是通過 CAS 操作實現的,CAS 是一種更新的原子操作,比較當前值跟傳入值是否一樣,一樣則更新,否則失敗。
悲觀鎖
悲觀鎖是就是悲觀思想,即認為寫多,遇到並發寫的可能性高,每次去拿數據的時候都認為別人會修改,所以每次在讀寫數據的時候都會上鎖,這樣別人想讀寫這個數據就會 block 直到拿到鎖。java中的悲觀鎖就是Synchronized,AQS框架下的鎖則是先嘗試cas樂觀鎖去獲取鎖,獲取不到,才會轉換為悲觀鎖,如 RetreenLock。
自旋鎖
自旋鎖原理非常簡單,如果持有鎖的線程能在很短時間內釋放鎖資源,那麼那些等待競爭鎖
的線程就不需要做內核態和用戶態之間的切換進入阻塞掛起狀態,它們只需要等一等(自旋),
等持有鎖的線程釋放鎖後即可立即獲取鎖,這樣就避免用戶線程和內核的切換的消耗。
線程自旋是需要消耗 cup 的,說白了就是讓 cup 在做無用功,如果一直獲取不到鎖,那線程也不能一直佔用 cup 自旋做無用功,所以需要設定一個自旋等待的最大時間。
如果持有鎖的線程執行的時間超過自旋等待的最大時間扔沒有釋放鎖,就會導致其它爭用鎖
的線程在最大等待時間內還是獲取不到鎖,這時爭用線程會停止自旋進入阻塞狀態。
自旋鎖的優缺點
自旋鎖儘可能的減少線程的阻塞,這對於鎖的競爭不激烈,且佔用鎖時間非常短的代碼塊來
說性能能大幅度的提升,因為自旋的消耗會小於線程阻塞掛起再喚醒的操作的消耗,這些操作會導致線程發生兩次上下文切換!
但是如果鎖的競爭激烈,或者持有鎖的線程需要長時間佔用鎖執行同步塊,這時候就不適合
使用自旋鎖了,因為自旋鎖在獲取鎖前一直都是佔用 cpu 做無用功,佔著 XX 不 XX,同時有大量線程在競爭一個鎖,會導致獲取鎖的時間很長,線程自旋的消耗大於線程阻塞掛起操作的消耗,其它需要 cup 的線程又不能獲取到 cpu,造成 cpu 的浪費。所以這種情況下我們要關閉自旋鎖;
自旋鎖時間閾值
自旋鎖的目的是為了佔著 CPU 的資源不釋放,等到獲取到鎖立即進行處理。但是如何去選擇自旋的執行時間呢?如果自旋執行時間太長,會有大量的線程處於自旋狀態佔用 CPU 資源,進而會影響整體系統的性能。因此自旋的周期選的額外重要!
JVM 對於自旋周期的選擇,jdk1.5 這個限度是一定的寫死的,在 1.6 引入了適應性自旋鎖,適應性自旋鎖意味着自旋的時間不在是固定的了,而是由前一次在同一個鎖上的自旋時間以及鎖的擁有者的狀態來決定,基本認為一個線程上下文切換的時間是最佳的一個時間,同時 JVM 還針對當前 CPU 的負荷情況做了較多的優化,如果平均負載小於 CPUs 則一直自旋,如果有超過(CPUs/2)個線程正在自旋,則後來線程直接阻塞,如果正在自旋的線程發現 Owner 發生了變化則延遲自旋時間(自旋計數)或進入阻塞,如果 CPU 處於節電模式則停止自旋,自旋時間的最壞情況是 CPU的存儲延遲(CPU A 存儲了一個數據,到 CPU B 得知這個數據直接的時間差),自旋時會適當放棄線程優先級之間的差異。
Synchronized 同步鎖
synchronized 它可以把任意一個非 NULL 的對象當作鎖。他屬於獨佔式的悲觀鎖,同時屬於可重入鎖。
Synchronized 作用範圍
1. 作用於方法時,鎖住的是對象的實例(this);
2. 當作用於靜態方法時,鎖住的是Class實例,又因為Class的相關數據存儲在永久帶PermGen(jdk1.8 則是 metaspace),永久帶是全局共享的,因此靜態方法鎖相當於類的一個全局鎖,會鎖所有調用該方法的線程;
3. synchronized 作用於一個對象實例時,鎖住的是所有以該對象為鎖的代碼塊。它有多個隊列,當多個線程一起訪問某個對象監視器的時候,對象監視器會將這些線程存儲在不同的容器中。
Synchronized 核心組件
1) Wait Set:哪些調用 wait 方法被阻塞的線程被放置在這裡;
2) Contention List:競爭隊列,所有請求鎖的線程首先被放在這個競爭隊列中;
3) Entry List:Contention List 中那些有資格成為候選資源的線程被移動到 Entry List 中;
4) OnDeck:任意時刻,最多只有一個線程正在競爭鎖資源,該線程被成為 OnDeck;
5) Owner:當前已經獲取到所資源的線程被稱為 Owner;
6) !Owner:當前釋放鎖的線程。
1. JVM 每次從隊列的尾部取出一個數據用於鎖競爭候選者(OnDeck),但是並發情況下,
ContentionList 會被大量的並發線程進行 CAS 訪問,為了降低對尾部元素的競爭,JVM 會將一部分線程移動到 EntryList 中作為候選競爭線程。
2. Owner 線程會在 unlock 時,將 ContentionList 中的部分線程遷移到 EntryList 中,並指定EntryList 中的某個線程為 OnDeck 線程(一般是最先進去的那個線程)。
3. Owner 線程並不直接把鎖傳遞給 OnDeck 線程,而是把鎖競爭的權利交給 OnDeck,
OnDeck 需要重新競爭鎖。這樣雖然犧牲了一些公平性,但是能極大的提升系統的吞吐量,在JVM 中,也把這種選擇行為稱之為「競爭切換」。
4. OnDeck 線程獲取到鎖資源後會變為 Owner 線程,而沒有得到鎖資源的仍然停留在 EntryList中。如果 Owner 線程被 wait 方法阻塞,則轉移到 WaitSet 隊列中,直到某個時刻通過 notify或者 notifyAll 喚醒,會重新進去 EntryList 中。
5. 處於 ContentionList、EntryList、WaitSet 中的線程都處於阻塞狀態,該阻塞是由操作系統
來完成的(Linux 內核下採用 pthread_mutex_lock 內核函數實現的)。
6. Synchronized 是非公平鎖。 Synchronized 在線程進入 ContentionList 時,等待的線程會先嘗試自旋獲取鎖,如果獲取不到就進入 ContentionList,這明顯對於已經進入隊列的線程是不公平的,還有一個不公平的事情就是自旋獲取鎖的線程還可能直接搶佔 OnDeck 線程的鎖資源。
參考://blog.csdn.net/zqz_zqz/article/details/70233767
7. 每個對象都有個 monitor 對象,加鎖就是在競爭 monitor 對象,代碼塊加鎖是在前後分別加上 monitorenter 和 monitorexit 指令來實現的,方法加鎖是通過一個標記位來判斷的
8. synchronized 是一個重量級操作,需要調用操作系統相關接口,性能是低效的,有可能給線程加鎖消耗的時間比有用操作消耗的時間更多。
9. Java1.6,synchronized 進行了很多的優化,有適應自旋、鎖消除、鎖粗化、輕量級鎖及偏向鎖等,效率有了本質上的提高。在之後推出的 Java1.7 與 1.8 中,均對該關鍵字的實現機理做了優化。引入了偏向鎖和輕量級鎖。都是在對象頭中有標記位,不需要經過操作系統加鎖。
ReentrantLock
ReentantLock 繼承接口 Lock 並實現了接口中定義的方法,他是一種可重入鎖,除了能完
成 synchronized 所能完成的所有工作外,還提供了諸如可響應中斷鎖、可輪詢鎖請求、定時鎖等避免多線程死鎖的方法。
Lock 接口的主要方法
1. void lock(): 執行此方法時, 如果鎖處於空閑狀態, 當前線程將獲取到鎖. 相反, 如果鎖已經被其他線程持有, 將禁用當前線程, 直到當前線程獲取到鎖.
2. boolean tryLock():如果鎖可用, 則獲取鎖, 並立即返回 true, 否則返回 false. 該方法和
lock()的區別在於, tryLock()只是“試圖“獲取鎖, 如果鎖不可用, 不會導致當前線程被禁用,
當前線程仍然繼續往下執行代碼. 而 lock()方法則是一定要獲取到鎖, 如果鎖不可用, 就一
直等待, 在未獲得鎖之前,當前線程並不繼續向下執行.
3. void unlock():執行此方法時, 當前線程將釋放持有的鎖. 鎖只能由持有者釋放, 如果線程
並不持有鎖, 卻執行該方法, 可能導致異常的發生.
4. Condition newCondition():條件對象,獲取等待通知組件。該組件和當前的鎖綁定,
當前線程只有獲取了鎖,才能調用該組件的 await()方法,而調用後,當前線程將縮放鎖。
5. getHoldCount() :查詢當前線程保持此鎖的次數,也就是執行此線程執行 lock 方法的次
數。
6. getQueueLength():返回正等待獲取此鎖的線程估計數,比如啟動 10 個線程,1 個
線程獲得鎖,此時返回的是 9
7. getWaitQueueLength:(Condition condition)返回等待與此鎖相關的給定條件的線
程估計數。比如 10 個線程,用同一個 condition 對象,並且此時這 10 個線程都執行了
condition 對象的 await 方法,那麼此時執行此方法返回 10
8. hasWaiters(Condition condition):查詢是否有線程等待與此鎖有關的給定條件
(condition),對於指定 contidion 對象,有多少線程執行了 condition.await 方法
9. hasQueuedThread(Thread thread):查詢給定線程是否等待獲取此鎖
10. hasQueuedThreads():是否有線程等待此鎖
11. isFair():該鎖是否公平鎖
12. isHeldByCurrentThread(): 當前線程是否保持鎖鎖定,線程的執行 lock 方法的前後分
別是 false 和 true
13. isLock():此鎖是否有任意線程佔用
14. lockInterruptibly():如果當前線程未被中斷,獲取鎖
15. tryLock():嘗試獲得鎖,僅在調用時鎖未被線程佔用,獲得鎖
16. tryLock(long timeout TimeUnit unit):如果鎖在給定等待時間內沒有被另一個線程保持,
則獲取該鎖
非公平鎖
JVM 按隨機、就近原則分配鎖的機制則稱為不公平鎖,ReentrantLock 在構造函數中提供了
是否公平鎖的初始化方式,默認為非公平鎖。非公平鎖實際執行的效率要遠遠超出公平鎖,除非程序有特殊需要,否則最常用非公平鎖的分配機制。
公平鎖
公平鎖指的是鎖的分配機制是公平的,通常先對鎖提出獲取請求的線程會先被分配到鎖,ReentrantLock 在構造函數中提供了是否公平鎖的初始化方式來定義公平鎖。
ReentrantLock 與 synchronized
1. ReentrantLock 通過方法 lock()與 unlock()來進行加鎖與解鎖操作,與 synchronized 會被 JVM 自動解鎖機制不同,ReentrantLock 加鎖後需要手動進行解鎖。為了避免程序出現異常而無法正常解鎖的情況,使用 ReentrantLock 必須在 finally 控制塊中進行解鎖操作。
2. ReentrantLock 相比 synchronized 的優勢是可中斷、公平鎖、多個鎖。這種情況下需要
使用 ReentrantLock。
Condition 類和 Object 類鎖方法區別區別
1. Condition 類的 awiat 方法和 Object 類的 wait 方法等效
2. Condition 類的 signal 方法和 Object 類的 notify 方法等效
3. Condition 類的 signalAll 方法和 Object 類的 notifyAll 方法等效
4. ReentrantLock 類可以喚醒指定條件的線程,而 object 的喚醒是隨機的
指定條件喚醒,多建立幾個condition。
tryLock 和 lock 和 lockInterruptibly 的區別
1. tryLock 能獲得鎖就返回 true,不能就立即返回 false,tryLock(long timeout,TimeUnit
unit),可以增加時間限制,如果超過該時間段還沒獲得鎖,返回 false。
2. lock 能獲得鎖就返回 true,不能的話一直等待獲得鎖。
3. lock 和 lockInterruptibly,如果兩個線程分別執行這兩個方法,但此時中斷這兩個線程,
lock 不會拋出異常,而 lockInterruptibly 會拋出異常。
可重入鎖的好處
假如一個線程擁有了這個鎖。另一個線程需要這個鎖,這個時候進行調用。可以直接調用,不用等待重新獲取。
Semaphore 信號量
Semaphore 是一種基於計數的信號量。它可以設定一個閾值,基於此,多個線程競爭獲取許可信號,做完自己的申請後歸還,超過閾值後,線程申請許可信號將會被阻塞。Semaphore 可以用來構建一些對象池,資源池之類的,比如數據庫連接池。
實現互斥鎖(計數器為 1)
我們也可以創建計數為 1 的 Semaphore,將其作為一種類似互斥鎖的機制,這也叫二元信號量,表示兩種互斥狀態。
代碼實現
其他用途
可以創建一個信號量,每個線程消耗一下信號量。用完之後。獲取一下剩餘數量,如果和初始相等,證明線程內部都執行完畢了,可以繼續執行主線程了。
Semaphore 與 ReentrantLock
Semaphore 基本能完成 ReentrantLock 的所有工作,使用方法也與之類似,通過 acquire()與release()方法來獲得和釋放臨界資源。經實測,Semaphone.acquire()方法默認為可響應中斷鎖,與 ReentrantLock.lockInterruptibly()作用效果一致,也就是說在等待臨界資源的過程中可以被Thread.interrupt()方法中斷。
此外,Semaphore 也實現了可輪詢的鎖請求與定時鎖的功能,除了方法名 tryAcquire 與 tryLock不同,其使用方法與 ReentrantLock 幾乎一致。Semaphore 也提供了公平與非公平鎖的機制,也可在構造函數中進行設定。
Semaphore 的鎖釋放操作也由手動進行,因此與 ReentrantLock 一樣,為避免線程因拋出異常而無法正常釋放鎖的情況發生,釋放鎖的操作也必須在 finally 代碼塊中完成。
AtomicInteger
首先說明,此處 AtomicInteger ,一個提供原子操作的 Integer 的類,常見的還有
AtomicBoolean、AtomicInteger、AtomicLong、AtomicReference 等,他們的實現原理相同,
區別在與運算對象類型的不同。令人興奮地,還可以通過 AtomicReference<V>將一個對象的所有操作轉化成原子操作。
我們知道,在多線程程序中,諸如++i 或 i++等運算不具有原子性,是不安全的線程操作之一。
通常我們會使用 synchronized 將該操作變成一個原子操作,但 JVM 為此類操作特意提供了一些同步類,使得使用更方便,且使程序運行效率變得更高。通過相關資料顯示,通常AtomicInteger的性能是 ReentantLock 的好幾倍。
可重入鎖(遞歸鎖)
本文裏面講的是廣義上的可重入鎖,而不是單指 JAVA 下的 ReentrantLock。可重入鎖,也叫做遞歸鎖,指的是同一線程 外層函數獲得鎖之後 ,內層遞歸函數仍然有獲取該鎖的代碼,但不受影響。在 JAVA 環境下 ReentrantLock 和 synchronized 都是可重入鎖。
公平鎖與非公平鎖
公平鎖(Fair)
加鎖前檢查是否有排隊等待的線程,優先排隊等待的線程,先來先得
非公平鎖(Nonfair)
加鎖時不考慮排隊等待問題,直接嘗試獲取鎖,獲取不到自動到隊尾等待
1. 非公平鎖性能比公平鎖高 5~10 倍,因為公平鎖需要在多核的情況下維護一個隊列
2. Java 中的 synchronized 是非公平鎖,ReentrantLock 默認的 lock()方法採用的是非公平鎖。
ReadWriteLock 讀寫鎖
為了提高性能,Java 提供了讀寫鎖,在讀的地方使用讀鎖,在寫的地方使用寫鎖,靈活控制,如果沒有寫鎖的情況下,讀是無阻塞的,在一定程度上提高了程序的執行效率。讀寫鎖分為讀鎖和寫鎖,多個讀鎖不互斥,讀鎖與寫鎖互斥,這是由 jvm 自己控制的,你只要上好相應的鎖即可。
讀鎖
如果你的代碼只讀數據,可以很多人同時讀,但不能同時寫,那就上讀鎖。
寫鎖
如果你的代碼修改數據,只能有一個人在寫,且不能同時讀取,那就上寫鎖。總之,讀的時候上讀鎖,寫的時候上寫鎖!
Java 中讀寫鎖有個接口 java.util.concurrent.locks.ReadWriteLock ,也有具體的實現
ReentrantReadWriteLock。
共享鎖和獨佔鎖
獨佔鎖
獨佔鎖模式下,每次只能有一個線程能持有鎖,ReentrantLock 就是以獨佔方式實現的互斥鎖。
獨佔鎖是一種悲觀保守的加鎖策略,它避免了讀/讀衝突,如果某個只讀線程獲取鎖,則其他讀線程都只能等待,這種情況下就限制了不必要的並發性,因為讀操作並不會影響數據的一致性。
共享鎖
共享鎖則允許多個線程同時獲取鎖,並發訪問 共享資源,如:ReadWriteLock。共享鎖則是一種樂觀鎖,它放寬了加鎖策略,允許多個執行讀操作的線程同時訪問共享資源。
1. AQS 的內部類 Node 定義了兩個常量 SHARED 和 EXCLUSIVE,他們分別標識 AQS 隊列中等待線程的鎖獲取模式。
2. java 的並發包中提供了 ReadWriteLock,讀–寫鎖。它允許一個資源可以被多個讀操作訪問,
或者被一個寫操作訪問,但兩者不能同時進行。
重量級鎖(Mutex Lock)
Synchronized 是通過對象內部的一個叫做監視器鎖(monitor)來實現的。但是監視器鎖本質又是依賴於底層的操作系統的 Mutex Lock 來實現的。而操作系統實現線程之間的切換這就需要從用戶態轉換到核心態,這個成本非常高,狀態之間的轉換需要相對比較長的時間,這就是為什麼Synchronized 效率低的原因。因此,這種依賴於操作系統 Mutex Lock 所實現的鎖我們稱之為「重量級鎖」。JDK 中對 Synchronized 做的種種優化,其核心都是為了減少這種重量級鎖的使用。
JDK1.6 以後,為了減少獲得鎖和釋放鎖所帶來的性能消耗,提高性能,引入了「輕量級鎖」和「偏向鎖」。
輕量級鎖
鎖的狀態總共有四種:無鎖狀態、偏向鎖、輕量級鎖和重量級鎖。
鎖升級
隨着鎖的競爭,鎖可以從偏向鎖升級到輕量級鎖,再升級的重量級鎖(但是鎖的升級是單向的,也就是說只能從低到高升級,不會出現鎖的降級)。
「輕量級」是相對於使用操作系統互斥量來實現的傳統鎖而言的。但是,首先需要強調一點的是,輕量級鎖並不是用來代替重量級鎖的,它的本意是在沒有多線程競爭的前提下,減少傳統的重量級鎖使用產生的性能消耗。在解釋輕量級鎖的執行過程之前,先明白一點,輕量級鎖所適應的場景是線程交替執行同步塊的情況,如果存在同一時間訪問同一鎖的情況,就會導致輕量級鎖膨脹為重量級鎖。
偏向鎖
Hotspot 的作者經過以往的研究發現大多數情況下鎖不僅不存在多線程競爭,而且總是由同一線程多次獲得。偏向鎖的目的是在某個線程獲得鎖之後,消除這個線程鎖重入(CAS)的開銷,看起來讓這個線程得到了偏護。引入偏向鎖是為了在無多線程競爭的情況下盡量減少不必要的輕量級鎖執行路徑,因為輕量級鎖的獲取及釋放依賴多次 CAS 原子指令,而偏向鎖只需要在置換ThreadID 的時候依賴一次 CAS 原子指令(由於一旦出現多線程競爭的情況就必須撤銷偏向鎖,所以偏向鎖的撤銷操作的性能損耗必須小於節省下來的 CAS 原子指令的性能消耗)。上面說過,輕量級鎖是為了在線程交替執行同步塊時提高性能,而偏向鎖則是在只有一個線程執行同步塊時進一步提高性能。
分段鎖
分段鎖也並非一種實際的鎖,而是一種思想 ConcurrentHashMap 是學習分段鎖的最好實踐。
鎖優化
減少鎖持有時間
只用在有線程安全要求的程序上加鎖
減小鎖粒度
將大對象(這個對象可能會被很多線程訪問),拆成小對象,大大增加並行度,降低鎖競爭。
降低了鎖的競爭,偏向鎖,輕量級鎖成功率才會提高。最最典型的減小鎖粒度的案例就是
ConcurrentHashMap。
鎖分離
最常見的鎖分離就是讀寫鎖 ReadWriteLock,根據功能進行分離成讀鎖和寫鎖,這樣讀讀不互斥,讀寫互斥,寫寫互斥,即保證了線程安全,又提高了性能。JDK 並發包 1。讀寫分離思想可以延伸,只要操作互不影響,鎖就可以分離。比如LinkedBlockingQueue 從頭部取出,從尾部放數據。
鎖粗化
通常情況下,為了保證多線程間的有效並發,會要求每個線程持有鎖的時間盡量短,即在使用完公共資源後,應該立即釋放鎖。但是,凡事都有一個度,如果對同一個鎖不停的進行請求、同步和釋放,其本身也會消耗系統寶貴的資源,反而不利於性能的優化 。
鎖消除
鎖消除是在編譯器級別的事情。在即時編譯器時,如果發現不可能被共享的對象,則可以消除這些對象的鎖操作,多數是因為程序員編碼不規範引起。
9. 線程基本方法
線程等待(wait)
調用該方法的線程進入 WAITING 狀態,只有等待另外線程的通知或被中斷才會返回,需要注意的是調用 wait()方法後,會釋放對象的鎖。因此,wait 方法一般用在同步方法或同步代碼塊中。
線程睡眠(sleep)
sleep 導致當前線程休眠,與 wait 方法不同的是 sleep 不會釋放當前佔有的鎖,sleep(long)會導致線程進入 TIMED-WATING 狀態,而 wait()方法會導致當前線程進入 WATING 狀態。
線程讓步(yield)
yield 會使當前線程讓出 CPU 執行時間片,與其他線程一起重新競爭 CPU 時間片。一般情況下,優先級高的線程有更大的可能性成功競爭得到 CPU 時間片,但這又不是絕對的,有的操作系統對線程優先級並不敏感。
線程中斷(interrupt)
中斷一個線程,其本意是給這個線程一個通知信號,會影響這個線程內部的一個中斷標識位。這個線程本身並不會因此而改變狀態(如阻塞,終止等)。
1. 調用 interrupt()方法並不會中斷一個正在運行的線程。也就是說處於 Running 狀態的線
程並不會因為被中斷而被終止,僅僅改變了內部維護的中斷標識位而已。
2. 若調用 sleep()而使線程處於 TIMED-WATING 狀態,這時調用 interrupt()方法,會拋出
InterruptedException,從而使線程提前結束 TIMED-WATING 狀態。
3. 許多聲明拋出 InterruptedException 的方法(如 Thread.sleep(long mills 方法)),拋出異
常前,都會清除中斷標識位,所以拋出異常後,調用 isInterrupted()方法將會返回 false。
4. 中斷狀態是線程固有的一個標識位,可以通過此標識位安全的終止線程。比如,你想終止
一個線程 thread 的時候,可以調用 thread.interrupt()方法,在線程的 run 方法內部可以
根據 thread.isInterrupted()的值來優雅的終止線程。
Join 等待其他線程終止
join() 方法,等待其他線程終止,在當前線程中調用一個線程的 join() 方法,則當前線程轉為阻塞狀態,回到另一個線程結束,當前線程再由阻塞狀態變為就緒狀態,等待 cpu 的寵幸。
為什麼要用 join()方法?
很多情況下,主線程生成並啟動了子線程,需要用到子線程返回的結果,也就是需要主線程需要在子線程結束後再結束,這時候就要用到 join() 方法。
線程喚醒(notify)
Object 類中的 notify() 方法,喚醒在此對象監視器上等待的單個線程,如果所有線程都在此對象上等待,則會選擇喚醒其中一個線程,選擇是任意的,並在對實現做出決定時發生,線程通過調用其中一個 wait() 方法,在對象的監視器上等待,直到當前的線程放棄此對象上的鎖定,才能繼續執行被喚醒的線程,被喚醒的線程將以常規方式與在該對象上主動同步的其他所有線程進行競爭。類似的方法還有 notifyAll() ,喚醒再次監視器上等待的所有線程。
其他方法
1. sleep():強迫一個線程睡眠N毫秒。
2. isAlive(): 判斷一個線程是否存活。
3. join(): 等待線程終止。
4. activeCount(): 程序中活躍的線程數。
5. enumerate(): 枚舉程序中的線程。
6. currentThread(): 得到當前線程。
7. isDaemon(): 一個線程是否為守護線程。
8. setDaemon(): 設置一個線程為守護線程。(用戶線程和守護線程的區別在於,是否等待主線
程依賴於主線程結束而結束)
9. setName(): 為線程設置一個名稱。
10. wait(): 強迫一個線程等待。
11. notify(): 通知一個線程繼續運行。
12. setPriority(): 設置一個線程的優先級。
13. getPriority()::獲得一個線程的優先級。
10. 線程的上下文切換
巧妙地利用了時間片輪轉的方式, CPU 給每個任務都服務一定的時間,然後把當前任務的狀態保存下來,在加載下一任務的狀態後,繼續服務下一任務,任務的狀態保存及再加載, 這段過程就叫做上下文切換。時間片輪轉的方式使多個任務在同一顆 CPU 上執行變成了可能。
線程
(有時候也稱做任務)是指一個程序運行的實例。在 Linux 系統中,線程就是能並行運行並且與他們的父進程(創建他們的進程)共享同一地址空間(一段內存區域)和其他資源的輕量級的進程。
上下文
是指某一時間點 CPU 寄存器和程序計數器的內容。
寄存器
是 CPU 內部的數量較少但是速度很快的內存(與之對應的是 CPU 外部相對較慢的 RAM 主內存)。寄存器通過對常用值(通常是運算的中間值)的快速訪問來提高計算機程序運行的速度。
程序計數器
是一個專用的寄存器,用於表明指令序列中 CPU 正在執行的位置,存的值為正在執行的指令的位置或者下一個將要被執行的指令的位置,具體依賴於特定的系統。
PCB-「切換楨
上下文切換可以認為是內核(操作系統的核心)在 CPU 上對於進程(包括線程)進行切換,上下文切換過程中的信息是保存在進程控制塊(PCB, process control block)中的。PCB 還經常被稱作「切換楨」(switchframe)。信息會一直保存到 CPU 的內存中,直到他們被再次使用。
上下文切換的活動
1. 掛起一個進程,將這個進程在 CPU 中的狀態(上下文)存儲於內存中的某處。
2. 在內存中檢索下一個進程的上下文並將其在 CPU 的寄存器中恢復。
3. 跳轉到程序計數器所指向的位置(即跳轉到進程被中斷時的代碼行),以恢復該進程在程序中。
引起線程上下文切換的原因
1. 當前執行任務的時間片用完之後,系統 CPU 正常調度下一個任務;
2. 當前執行任務碰到 IO 阻塞,調度器將此任務掛起,繼續下一任務;
3. 多個任務搶佔鎖資源,當前任務沒有搶到鎖資源,被調度器掛起,繼續下一任務;
4. 用戶代碼掛起當前任務,讓出 CPU 時間;
5. 硬件中斷;
11. 同步鎖與死鎖
同步鎖
當多個線程同時訪問同一個數據時,很容易出現問題。為了避免這種情況出現,我們要保證線程同步互斥,就是指並發執行的多個線程,在同一時間內只允許一個線程訪問共享數據。 Java 中可以使用 synchronized 關鍵字來取得一個對象的同步鎖。
死鎖
何為死鎖,就是多個線程同時被阻塞,它們中的一個或者全部都在等待某個資源被釋放。
12. 線程池原理
線程池做的工作主要是控制運行的線程的數量,處理過程中將任務放入隊列,然後在線程創建後啟動這些任務,如果線程數量超過了最大數量超出數量的線程排隊等候,等其它線程執行完畢,再從隊列中取出任務來執行。他的主要特點為:線程復用;控制最大並發數;管理線程。
線程復用
每一個 Thread 的類都有一個 start 方法。 當調用 start 啟動線程時 Java 虛擬機會調用該類的 run 方法。 那麼該類的 run() 方法中就是調用了 Runnable 對象的 run() 方法。 我們可以繼承重寫Thread 類,在其 start 方法中添加不斷循環調用傳遞過來的 Runnable 對象。 這就是線程池的實現原理。循環方法中不斷獲取 Runnable 是用 Queue 實現的,在獲取下一個 Runnable 之前可以是阻塞的。
線程池的組成
一般的線程池主要分為以下 4 個組成部分:
1. 線程池管理器:用於創建並管理線程池
2. 工作線程:線程池中的線程
3. 任務接口:每個任務必須實現的接口,用於工作線程調度其運行
4. 任務隊列:用於存放待處理的任務,提供一種緩衝機制
Java 中的線程池是通過 Executor 框架實現的,該框架中用到了 Executor,Executors,
ExecutorService,ThreadPoolExecutor ,Callable 和 Future、FutureTask 這幾個類。
ThreadPoolExecutor 的構造方法如下:
1. corePoolSize:指定了線程池中的線程數量。
2. maximumPoolSize:指定了線程池中的最大線程數量。
3. keepAliveTime:當前線程池數量超過 corePoolSize 時,多餘的空閑線程的存活時間,即多
次時間內會被銷毀。
4. unit:keepAliveTime 的單位。
5. workQueue:任務隊列,被提交但尚未被執行的任務。
6. threadFactory:線程工廠,用於創建線程,一般用默認的即可。
7. handler:拒絕策略,當任務太多來不及處理,如何拒絕任務。
拒絕策略
線程池中的線程已經用完了,無法繼續為新任務服務,同時,等待隊列也已經排滿了,再也
塞不下新任務了。這時候我們就需要拒絕策略機制合理的處理這個問題。
JDK 內置的拒絕策略如下:
1. AbortPolicy : 直接拋出異常,阻止系統正常運行。
2. CallerRunsPolicy : 只要線程池未關閉,該策略直接在調用者線程中,運行當前被丟棄的
任務。顯然這樣做不會真的丟棄任務,但是,任務提交線程的性能極有可能會急劇下降。
3. DiscardOldestPolicy : 丟棄最老的一個請求,也就是即將被執行的一個任務,並嘗試再
次提交當前任務。
4. DiscardPolicy : 該策略默默地丟棄無法處理的任務,不予任何處理。如果允許任務丟
失,這是最好的一種方案。
以上內置拒絕策略均實現了 RejectedExecutionHandler 接口,若以上策略仍無法滿足實際
需要,完全可以自己擴展 RejectedExecutionHandler 接口。
Java 線程池工作過程
1. 線程池剛創建時,裏面沒有一個線程。任務隊列是作為參數傳進來的。不過,就算隊列裏面有任務,線程池也不會馬上執行它們。
2. 當調用 execute() 方法添加一個任務時,線程池會做如下判斷:
a) 如果正在運行的線程數量小於 corePoolSize,那麼馬上創建線程運行這個任務;
b) 如果正在運行的線程數量大於或等於 corePoolSize,那麼將這個任務放入隊列;
c) 如果這時候隊列滿了,而且正在運行的線程數量小於 maximumPoolSize,那麼還是要
創建非核心線程立刻運行這個任務;
d) 如果隊列滿了,而且正在運行的線程數量大於或等於 maximumPoolSize,那麼線程池
會拋出異常 RejectExecutionException。
3. 當一個線程完成任務時,它會從隊列中取下一個任務來執行。
4. 當一個線程無事可做,超過一定的時間(keepAliveTime)時,線程池會判斷,如果當前運行的線程數大於 corePoolSize,那麼這個線程就被停掉。所以線程池的所有任務完成後,它最終會收縮到 corePoolSize 的大小。
13. JAVA 阻塞隊列原理
阻塞隊列,關鍵字是阻塞,先理解阻塞的含義,在阻塞隊列中,線程阻塞有這樣的兩種情況:
- 當隊列中沒有數據的情況下,消費者端的所有線程都會被自動阻塞(掛起),直到有數據放入隊列。
- 當隊列中填滿數據的情況下,生產者端的所有線程都會被自動阻塞(掛起),直到隊列中有空的位置,線程被自動喚醒。
阻塞隊列的主要方法
„ 拋出異常:拋出一個異常;
„ 特殊值:返回一個特殊值(null 或 false,視情況而定)
„ 則塞:在成功操作之前,一直阻塞線程
„ 超時:放棄前只在最大的時間內阻塞
插入操作:
1:public abstract boolean add(E paramE):將指定元素插入此隊列中(如果立即可行
且不會違反容量限制),成功時返回 true,如果當前沒有可用的空間,則拋
出 IllegalStateException。如果該元素是 NULL,則會拋出 NullPointerException 異常。
2:public abstract boolean offer(E paramE):將指定元素插入此隊列中(如果立即可行
且不會違反容量限制),成功時返回 true,如果當前沒有可用的空間,則返回 false。
3:public abstract void put(E paramE) throws InterruptedException: 將指定元素插入此隊列中,將等待可用的空間(如果有必要)
public void put(E paramE) throws InterruptedException {
checkNotNull(paramE);
ReentrantLock localReentrantLock = this.lock;
localReentrantLock.lockInterruptibly();
try {
while (this.count == this.items.length)
this.notFull.await();//如果隊列滿了,則線程阻塞等待
enqueue(paramE);
localReentrantLock.unlock();
} finally {
localReentrantLock.unlock();
}
}
4:offer(E o, long timeout, TimeUnit unit):可以設定等待的時間,如果在指定的時間
內,還不能往隊列中加入 BlockingQueue,則返回失敗。
獲取數據操作:
1:poll(time):取走 BlockingQueue 里排在首位的對象,若不能立即取出,則可以等 time 參數
規定的時間,取不到時返回 null;
2:poll(long timeout, TimeUnit unit):從 BlockingQueue 取出一個隊首的對象,如果在
指定時間內,隊列一旦有數據可取,則立即返回隊列中的數據。否則直到時間超時還沒有數
據可取,返回失敗。
3:take():取走 BlockingQueue 里排在首位的對象,若 BlockingQueue 為空,阻斷進入等待狀
態直到 BlockingQueue 有新的數據被加入。
4.drainTo():一次性從 BlockingQueue 獲取所有可用的數據對象(還可以指定獲取數據的個
數),通過該方法,可以提升獲取數據效率;不需要多次分批加鎖或釋放鎖。
Java 中的阻塞隊列
1. ArrayBlockingQueue :由數組結構組成的有界阻塞隊列。
2. LinkedBlockingQueue :由鏈表結構組成的有界阻塞隊列。
3. PriorityBlockingQueue :支持優先級排序的無界阻塞隊列。
4. DelayQueue:使用優先級隊列實現的無界阻塞隊列。
5. SynchronousQueue:不存儲元素的阻塞隊列。
6. LinkedTransferQueue:由鏈表結構組成的無界阻塞隊列。
7. LinkedBlockingDeque:由鏈表結構組成的雙向阻塞隊列
ArrayBlockingQueue(公平、非公平)
用數組實現的有界阻塞隊列。此隊列按照先進先出(FIFO)的原則對元素進行排序。默認情況下不保證訪問者公平的訪問隊列,所謂公平訪問隊列是指阻塞的所有生產者線程或消費者線程,當隊列可用時,可以按照阻塞的先後順序訪問隊列,即先阻塞的生產者線程,可以先往隊列里插入元素,先阻塞的消費者線程,可以先從隊列里獲取元素。通常情況下為了保證公平性會降低吞吐量。我們可以使用以下代碼創建一個公平的阻塞隊列:
ArrayBlockingQueue fairQueue = new ArrayBlockingQueue(1000,true);
LinkedBlockingQueue(兩個獨立鎖提高並發)
基於鏈表的阻塞隊列,同 ArrayListBlockingQueue 類似,此隊列按照先進先出(FIFO)的原則對元素進行排序。而 LinkedBlockingQueue 之所以能夠高效的處理並發數據,還因為其對於生產者端和消費者端分別採用了獨立的鎖來控制數據同步,這也意味着在高並發的情況下生產者和消費者可以並行地操作隊列中的數據,以此來提高整個隊列的並發性能。
LinkedBlockingQueue 會默認一個類似無限大小的容量(Integer.MAX_VALUE)。
PriorityBlockingQueue(compareTo 排序實現優先)
是一個支持優先級的無界隊列。默認情況下元素採取自然順序升序排列。可以自定義實現
compareTo()方法來指定元素進行排序規則,或者初始化 PriorityBlockingQueue 時,指定構造參數 Comparator 來對元素進行排序。需要注意的是不能保證同優先級元素的順序。
DelayQueue(緩存失效、定時任務 )
是一個支持延時獲取元素的無界阻塞隊列。隊列使用 PriorityQueue 來實現。隊列中的元素必須實現 Delayed 接口,在創建元素時可以指定多久才能從隊列中獲取當前元素。只有在延遲期滿時才能從隊列中提取元素。我們可以將 DelayQueue 運用在以下應用場景:
1. 緩存系統的設計:可以用 DelayQueue 保存緩存元素的有效期,使用一個線程循環查詢
DelayQueue,一旦能從 DelayQueue 中獲取元素時,表示緩存有效期到了。
2. 定時任務調度:使用 DelayQueue 保存當天將會執行的任務和執行時間,一旦從
DelayQueue 中獲取到任務就開始執行,從比如 TimerQueue 就是使用 DelayQueue 實現的。
SynchronousQueue(不存儲數據、可用於傳遞數據)
是一個不存儲元素的阻塞隊列。每一個 put 操作必須等待一個 take 操作,否則不能繼續添加元素。
SynchronousQueue 可以看成是一個傳球手,負責把生產者線程處理的數據直接傳遞給消費者線程。隊列本身並不存儲任何元素,非常適合於傳遞性場景,比如在一個線程中使用的數據,傳遞給另外一個線程使用, SynchronousQueue 的吞吐量高於 LinkedBlockingQueue 和
ArrayBlockingQueue。
LinkedTransferQueue
是一個由鏈表結構組成的無界阻塞 TransferQueue 隊列。相對於其他阻塞隊列,
LinkedTransferQueue 多了 tryTransfer 和 transfer 方法。
1. transfer 方法:如果當前有消費者正在等待接收元素(消費者使用 take()方法或帶時間限制的poll()方法時),transfer 方法可以把生產者傳入的元素立刻 transfer(傳輸)給消費者。如果沒有消費者在等待接收元素,transfer 方法會將元素存放在隊列的 tail 節點,並等到該元素被消費者消費了才返回。
2. tryTransfer 方法。則是用來試探下生產者傳入的元素是否能直接傳給消費者。如果沒有消費者等待接收元素,則返回 false。和 transfer 方法的區別是 tryTransfer 方法無論消費者是否接收,方法立即返回。而 transfer 方法是必須等到消費者消費了才返回。
對於帶有時間限制的 tryTransfer(E e, long timeout, TimeUnit unit)方法,則是試圖把生產者傳
入的元素直接傳給消費者,但是如果沒有消費者消費該元素則等待指定的時間再返回,如果超時還沒消費元素,則返回 false,如果在超時時間內消費了元素,則返回 true。
LinkedBlockingDeque
是一個由鏈表結構組成的雙向阻塞隊列。所謂雙向隊列指的你可以從隊列的兩端插入和移出元素。雙端隊列因為多了一個操作隊列的入口,在多線程同時入隊時,也就減少了一半的競爭。相比其他的阻塞隊列,LinkedBlockingDeque 多了 addFirst,addLast,offerFirst,offerLast,
peekFirst,peekLast 等方法,以 First 單詞結尾的方法,表示插入,獲取(peek)或移除雙端隊列的第一個元素。以 Last 單詞結尾的方法,表示插入,獲取或移除雙端隊列的最後一個元素。另外插入方法 add 等同於 addLast,移除方法 remove 等效於 removeFirst。但是 take 方法卻等同於 takeFirst,不知道是不是 Jdk 的 bug,使用時還是用帶有 First 和 Last 後綴的方法更清楚。
在初始化 LinkedBlockingDeque 時可以設置容量防止其過渡膨脹。另外雙向阻塞隊列可以運用在「工作竊取」模式中。
14. CyclicBarrier、CountDownLatch、Semaphore 的用法
CountDownLatch(線程計數器)
CountDownLatch 類位於 java.util.concurrent 包下,利用它可以實現類似計數器的功能。比如有一個任務 A,它要等待其他 4 個任務執行完畢之後才能執行,此時就可以利用 CountDownLatch來實現這種功能了。
CyclicBarrier(迴環柵欄–等待至 barrier 狀態再全部同時執行)
字面意思迴環柵欄,通過它可以實現讓一組線程等待至某個狀態之後再全部同時執行。叫做迴環是因為當所有等待線程都被釋放以後,CyclicBarrier 可以被重用。我們暫且把這個狀態就叫做barrier,當調用 await()方法之後,線程就處於 barrier 了。
CyclicBarrier 中最重要的方法就是 await 方法,它有 2 個重載版本:
1. public int await():用來掛起當前線程,直至所有線程都到達 barrier 狀態再同時執行後續任務;
2. public int await(long timeout, TimeUnit unit):讓這些線程等待至一定的時間,如果還有
線程沒有到達 barrier 狀態就直接讓到達 barrier 的線程執行後續任務。
具體使用如下,另外 CyclicBarrier 是可以重用的。
Semaphore(信號量–控制同時訪問的線程個數)
Semaphore 翻譯成字面意思為信號量,Semaphore 可以控制同時訪問的線程個數,通過
acquire() 獲取一個許可,如果沒有就等待,而 release() 釋放一個許可。
Semaphore 類中比較重要的幾個方法:
1. public void acquire(): 用來獲取一個許可,若無許可能夠獲得,則會一直等待,直到獲得許
可。
2. public void acquire(int permits):獲取 permits 個許可
3. public void release() { } :釋放許可。注意,在釋放許可之前,必須先獲獲得許可。
4. public void release(int permits) { }:釋放 permits 個許可
上面 4 個方法都會被阻塞,如果想立即得到執行結果,可以使用下面幾個方法
1. public boolean tryAcquire():嘗試獲取一個許可,若獲取成功,則立即返回 true,若獲取失
敗,則立即返回 false
2. public boolean tryAcquire(long timeout, TimeUnit unit):嘗試獲取一個許可,若在指定的
時間內獲取成功,則立即返回 true,否則則立即返回 false
3. public boolean tryAcquire(int permits):嘗試獲取 permits 個許可,若獲取成功,則立即返
回 true,若獲取失敗,則立即返回 false
4. public boolean tryAcquire(int permits, long timeout, TimeUnit unit): 嘗試獲取 permits
個許可,若在指定的時間內獲取成功,則立即返回 true,否則則立即返回 false
5. 還可以通過 availablePermits()方法得到可用的許可數目。
例子:若一個工廠有 5 台機器,但是有 8 個工人,一台機器同時只能被一個工人使用,只有使用完
了,其他工人才能繼續使用。那麼我們就可以通過 Semaphore 來實現:
CountDownLatch 和 CyclicBarrier 都能夠實現線程之間的等待,只不過它們側重點不
同;CountDownLatch 一般用於某個線程 A 等待若干個其他線程執行完任務之後,它才
執行;而 CyclicBarrier 一般用於一組線程互相等待至某個狀態,然後這一組線程再同時
執行;另外,CountDownLatch 是不能夠重用的,而 CyclicBarrier 是可以重用的。
Semaphore 其實和鎖有點類似,它一般用於控制對某組資源的訪問權限。
15. volatile 關鍵字的作用(變量可見性、禁止重排序)
Java 語言提供了一種稍弱的同步機制,即 volatile 變量,用來確保將變量的更新操作通知到其他線程。volatile 變量具備兩種特性,volatile 變量不會被緩存在寄存器或者對其他處理器不可見的地方,因此在讀取 volatile 類型的變量時總會返回最新寫入的值。
變量可見性
其一是保證該變量對所有線程可見,這裡的可見性指的是當一個線程修改了變量的值,那麼新的值對於其他線程是可以立即獲取的。
禁止重排序
volatile 禁止了指令重排。 比 sychronized 更輕量級的同步鎖
在訪問 volatile 變量時不會執行加鎖操作,因此也就不會使執行線程阻塞,因此 volatile 變量是一種比 sychronized 關鍵字更輕量級的同步機制。volatile 適合這種場景:一個變量被多個線程共享,線程直接給這個變量賦值。
當對非 volatile 變量進行讀寫的時候,每個線程先從內存拷貝變量到 CPU 緩存中。如果計算機有多個 CPU,每個線程可能在不同的 CPU 上被處理,這意味着每個線程可以拷貝到不同的 CPU cache 中。而聲明變量是 volatile 的,JVM 保證了每次讀變量都從內存中讀,跳過 CPU cache 這一步。
適用場景
值得說明的是對 volatile 變量的單次讀/寫操作可以保證原子性的,如 long 和 double 類型變量,但是並不能保證 i++這種操作的原子性,因為本質上 i++是讀、寫兩次操作。在某些場景下可以代替 Synchronized。但是,volatile 的不能完全取代 Synchronized 的位置,只有在一些特殊的場景下,才能適用 volatile。總的來說,必須同時滿足下面兩個條件才能保證在並發環境的線程安全:
(1)對變量的寫操作不依賴於當前值(比如 i++),或者說是單純的變量賦值(boolean
flag = true)。
(2)該變量沒有包含在具有其他變量的不變式中,也就是說,不同的 volatile 變量之間,不能互相依賴。只有在狀態真正獨立於程序內其他內容時才能使用 volatile。
16. 如何在兩個線程之間共享數據
Java 裏面進行多線程通信的主要方式就是共享內存的方式,共享內存主要的關注點有兩個:可見性和有序性原子性。Java 內存模型(JMM)解決了可見性和有序性的問題,而鎖解決了原子性的問題,理想情況下我們希望做到「同步」和「互斥」。有以下常規實現方法:
將數據抽象成一個類,並將數據的操作作為這個類的方法
- 將數據抽象成一個類,並將對這個數據的操作作為這個類的方法,這麼設計可以和容易做到同步,只要在方法上加」synchronized「。
Runnable 對象作為一個類的內部類
- 將 Runnable 對象作為一個類的內部類,共享數據作為這個類的成員變量,每個線程對共享數據的操作方法也封裝在外部類,以便實現對數據的各個操作的同步和互斥,作為內部類的各個 Runnable 對象調用外部類的這些方法。
17. ThreadLocal 作用(線程本地存儲)
ThreadLocal,很多地方叫做線程本地變量,也有些地方叫做線程本地存儲,ThreadLocal 的作用是提供線程內的局部變量,這種變量在線程的生命周期內起作用,減少同一個線程內多個函數或者組件之間一些公共變量的傳遞的複雜度。
ThreadLocalMap(線程的一個屬性)
1. 每個線程中都有一個自己的 ThreadLocalMap 類對象,可以將線程自己的對象保持到其中,
各管各的,線程可以正確的訪問到自己的對象。
2. 將一個共用的 ThreadLocal 靜態實例作為 key,將不同對象的引用保存到不同線程的
ThreadLocalMap 中,然後在線程執行的各處通過這個靜態 ThreadLocal 實例的 get()方法取
得自己線程保存的那個對象,避免了將這個對象作為參數傳遞的麻煩。
3. ThreadLocalMap 其實就是線程裏面的一個屬性,它在 Thread 類中定義
ThreadLocal.ThreadLocalMap threadLocals = null;
使用場景
最常見的 ThreadLocal 使用場景為 用來解決 數據庫連接、Session 管理等。
18. synchronized 和 ReentrantLock 的區別
兩者的共同點:
1. 都是用來協調多線程對共享對象、變量的訪問
2. 都是可重入鎖,同一線程可以多次獲得同一個鎖
3. 都保證了可見性和互斥性
兩者的不同點:
1. ReentrantLock 顯示的獲得、釋放鎖,synchronized 隱式獲得釋放鎖
2. ReentrantLock 可響應中斷、可輪迴,synchronized 是不可以響應中斷的,為處理鎖的
不可用性提供了更高的靈活性
3. ReentrantLock 是 API 級別的,synchronized 是 JVM 級別的
4. ReentrantLock 可以實現公平鎖
5. ReentrantLock 通過 Condition 可以綁定多個條件
6. 底層實現不一樣, synchronized 是同步阻塞,使用的是悲觀並發策略,lock 是同步非阻
塞,採用的是樂觀並發策略
7. Lock 是一個接口,而 synchronized 是 Java 中的關鍵字,synchronized 是內置的語言
實現。
8. synchronized 在發生異常時,會自動釋放線程佔有的鎖,因此不會導致死鎖現象發生;
而 Lock 在發生異常時,如果沒有主動通過 unLock()去釋放鎖,則很可能造成死鎖現象,
因此使用 Lock 時需要在 finally 塊中釋放鎖。
9. Lock 可以讓等待鎖的線程響應中斷,而 synchronized 卻不行,使用 synchronized 時,
等待的線程會一直等待下去,不能夠響應中斷。
10. 通過 Lock 可以知道有沒有成功獲取鎖,而 synchronized 卻無法辦到。
11. Lock 可以提高多個線程進行讀操作的效率,既就是實現讀寫鎖等。
19. Java 中用到的線程調度
搶佔式調度
搶佔式調度指的是每條線程執行的時間、線程的切換都由系統控制,系統控制指的是在系統某種運行機制下,可能每條線程都分同樣的執行時間片,也可能是某些線程執行的時間片較長,甚至某些線程得不到執行的時間片。在這種機制下,一個線程的堵塞不會導致整個進程堵塞。
協同式調度
協同式調度指某一線程執行完後主動通知系統切換到另一線程上執行,這種模式就像接力賽一樣,一個人跑完自己的路程就把接力棒交接給下一個人,下個人繼續往下跑。線程的執行時間由線程本身控制,線程切換可以預知,不存在多線程同步問題,但它有一個致命弱點:如果一個線程編寫有問題,運行到一半就一直堵塞,那麼可能導致整個系統崩潰。
JVM 的線程調度實現(搶佔式調度)
java 使用的線程調使用搶佔式調度,Java 中線程會按優先級分配 CPU 時間片運行,且優先級越高越優先執行,但優先級高並不代表能獨自佔用執行時間片,可能是優先級高得到越多的執行時間片,反之,優先級低的分到的執行時間少但不會分配不到執行時間。
線程讓出 cpu 的情況
1. 當前運行線程主動放棄 CPU,JVM 暫時放棄 CPU 操作(基於時間片輪轉調度的 JVM 操作系
統不會讓線程永久放棄 CPU,或者說放棄本次時間片的執行權),例如調用 yield()方法。
2. 當前運行線程因為某些原因進入阻塞狀態,例如阻塞在 I/O 上。
3. 當前運行線程結束,即運行完 run()方法裏面的任務。
20. 什麼是 CAS(比較並交換–樂觀鎖機制–鎖自旋)
概念及特性
CAS(Compare And Swap/Set)比較並交換,CAS 算法的過程是這樣:它包含 3 個參數
CAS(V,E,N)。V 表示要更新的變量(內存值),E 表示預期值(舊的),N 表示新值。當且僅當 V 值等於 E 值時,才會將 V 的值設為 N,如果 V 值和 E 值不同,則說明已經有其他線程做了更新,則當前線程什麼都不做。最後,CAS 返回當前 V 的真實值。
CAS 操作是抱着樂觀的態度進行的(樂觀鎖),它總是認為自己可以成功完成操作。當多個線程同時使用 CAS 操作一個變量時,只有一個會勝出,並成功更新,其餘均會失敗。失敗的線程不會被掛起,僅是被告知失敗,並且允許再次嘗試,當然也允許失敗的線程放棄操作。基於這樣的原理,CAS 操作即使沒有鎖,也可以發現其他線程對當前線程的干擾,並進行恰當的處理。
原子包 java.util.concurrent.atomic(鎖自旋)
JDK1.5 的原子包:java.util.concurrent.atomic 這個包裏面提供了一組原子類。其基本的特性就是在多線程環境下,當有多個線程同時執行這些類的實例包含的方法時,具有排他性,即當某個線程進入方法,執行其中的指令時,不會被其他線程打斷,而別的線程就像自旋鎖一樣,一直等到該方法執行完成,才由 JVM 從等待隊列中選擇一個另一個線程進入,這只是一種邏輯上的理解。
相對於對於 synchronized 這種阻塞算法,CAS 是非阻塞算法的一種常見實現。由於一般 CPU 切換時間比 CPU 指令集操作更加長, 所以 J.U.C 在性能上有了很大的提升。如下代碼。
getAndIncrement 採用了 CAS 操作,每次從內存中讀取數據然後將此數據和+1 後的結果進行CAS 操作,如果成功就返回結果,否則重試直到成功為止。而 compareAndSet 利用 JNI 來完成CPU 指令的操作。
ABA 問題
CAS 會導致「ABA 問題」。CAS 算法實現一個重要前提需要取出內存中某時刻的數據,而在下時刻比較並替換,那麼在這個時間差類會導致數據的變化。
比如說一個線程 one 從內存位置 V 中取出 A,這時候另一個線程 two 也從內存中取出 A,並且two 進行了一些操作變成了 B,然後 two 又將 V 位置的數據變成 A,這時候線程 one 進行 CAS 操作發現內存中仍然是 A,然後 one 操作成功。儘管線程 one 的 CAS 操作成功,但是不代表這個過程就是沒有問題的。
部分樂觀鎖的實現是通過版本號(version)的方式來解決 ABA 問題,樂觀鎖每次在執行數據的修改操作時,都會帶上一個版本號,一旦版本號和數據的版本號一致就可以執行修改操作並對版本號執行+1 操作,否則就執行失敗。因為每次操作的版本號都會隨之增加,所以不會出現 ABA 問題,因為版本號只會增加不會減少。
21. 什麼是 AQS(抽象的隊列同步器)
AbstractQueuedSynchronizer 類如其名,抽象的隊列式的同步器,AQS 定義了一套多線程訪問共享資源的同步器框架,許多同步類實現都依賴於它,如常用的ReentrantLock/Semaphore/CountDownLatch。
它維護了一個 volatile int state(代表共享資源)和一個 FIFO 線程等待隊列(多線程爭用資源被
阻塞時會進入此隊列)。這裡 volatile 是核心關鍵詞,具體 volatile 的語義,在此不述。state 的
訪問方式有三種:
getState()
setState()
compareAndSetState()
AQS 定義兩種資源共享方式
xclusive 獨佔資源-ReentrantLock
Exclusive(獨佔,只有一個線程能執行,如 ReentrantLock)
Share 共享資源-Semaphore/CountDownLatch
Share(共享,多個線程可同時執行,如 Semaphore/CountDownLatch)。
AQS 只是一個框架,具體資源的獲取/釋放方式交由自定義同步器去實現,AQS 這裡只定義了一個接口,具體資源的獲取交由自定義同步器去實現了(通過 state 的 get/set/CAS)之所以沒有定義成abstract ,是因為獨佔模式下只用實現 tryAcquire-tryRelease ,而共享模式下只用實現tryAcquireShared-tryReleaseShared。如果都定義成abstract,那麼每個模式也要去實現另一模式下的接口。不同的自定義同步器爭用共享資源的方式也不同。自定義同步器在實現時只需要實現共享資源 state 的獲取與釋放方式即可,至於具體線程等待隊列的維護(如獲取資源失敗入隊/喚醒出隊等),AQS 已經在頂層實現好了。自定義同步器實現時主要實現以下幾種方法:
1.isHeldExclusively():該線程是否正在獨佔資源。只有用到 condition 才需要去實現它。
2.tryAcquire(int):獨佔方式。嘗試獲取資源,成功則返回 true,失敗則返回 false。 3.tryRelease(int):獨佔方式。嘗試釋放資源,成功則返回 true,失敗則返回 false。 4.tryAcquireShared(int):共享方式。嘗試獲取資源。負數表示失敗;0 表示成功,但沒有剩餘可用資源;正數表示成功,且有剩餘資源。
5.tryReleaseShared(int):共享方式。嘗試釋放資源,如果釋放後允許喚醒後續等待結點返回true,否則返回 false。
同步器的實現是 ABS 核心(state 資源狀態計數)
同步器的實現是 ABS 核心,以 ReentrantLock 為例,state 初始化為 0,表示未鎖定狀態。A 線程lock()時,會調用 tryAcquire()獨佔該鎖並將 state+1。此後,其他線程再 tryAcquire()時就會失敗,直到 A 線程 unlock()到 state=0(即釋放鎖)為止,其它線程才有機會獲取該鎖。當然,釋放鎖之前,A 線程自己是可以重複獲取此鎖的(state 會累加),這就是可重入的概念。但要注意,獲取多少次就要釋放多麼次,這樣才能保證 state 是能回到零態的。
以 CountDownLatch 以例,任務分為 N 個子線程去執行,state 也初始化為 N(注意 N 要與線程個數一致)。這 N 個子線程是並行執行的,每個子線程執行完後 countDown()一次,state會 CAS 減 1。等到所有子線程都執行完後(即 state=0),會 unpark()主調用線程,然後主調用線程就會從 await()函數返回,繼續後余動作。
ReentrantReadWriteLock 實現獨佔和共享兩種方式
一般來說,自定義同步器要麼是獨佔方法,要麼是共享方式,他們也只需實現 tryAcquiretryRelease、tryAcquireShared-tryReleaseShared 中的一種即可。但 AQS 也支持自定義同步器同時實現獨佔和共享兩種方式,如 ReentrantReadWriteLock。