千鋒扣丁學(xué)堂Java培訓(xùn)之2019年Java大廠面試常見必問多線程面試題
2019-07-04 15:34:04
2346瀏覽
今天千鋒扣丁學(xué)堂
Java培訓(xùn)老師給大家分享一篇關(guān)于2019年Java大廠面試常見必問多線程面試題的詳細(xì)匯總，下面我們一起來看一下吧。
1、synchronized暴擊!
1.1介紹下synchronized
synchronized關(guān)鍵字解決的是多個線程之間訪問資源的同步性，synchronized關(guān)鍵字可以保證被它修飾的方法或者代碼塊在任意時刻只能有一個線程執(zhí)行。
另外，在Java早期版本中，synchronized屬于重量級鎖，效率低下，因為監(jiān)視器鎖（monitor）是依賴于底層的操作系統(tǒng)的MutexLock來實現(xiàn)的，Java的線程是映射到操作系統(tǒng)的原生線程之上的。
如果要掛起或者喚醒一個線程，都需要操作系統(tǒng)幫忙完成，而操作系統(tǒng)實現(xiàn)線程之間的切換時需要從用戶態(tài)轉(zhuǎn)換到內(nèi)核態(tài)，這個狀態(tài)之間的轉(zhuǎn)換需要相對比較長的時間，時間成本相對較高，這也是為什么早期的synchronized效率低的原因。
慶幸的是在Java6之后Java官方對從JVM層面對synchronized較大優(yōu)化，引入了大量的優(yōu)化，如自旋鎖、適應(yīng)性自旋鎖、鎖消除、鎖粗化、偏向鎖、輕量級鎖等技術(shù)來減少鎖操作的開銷，所以現(xiàn)在的synchronized鎖效率也優(yōu)化得很不錯了。
1.2實際怎么使用synchronized，在項目中用到了嗎
synchronized關(guān)鍵字最主要的三種使用方式：
修飾實例方法，作用于當(dāng)前對象實例加鎖，進(jìn)入同步代碼前要獲得當(dāng)前對象實例的鎖
修飾靜態(tài)方法，作用于當(dāng)前類對象加鎖，進(jìn)入同步代碼前要獲得當(dāng)前類對象的鎖。也就是給當(dāng)前類加鎖，會作用于類的所有對象實例，因為靜態(tài)成員不屬于任何一個實例對象，是類成員（static表明這是該類的一個靜態(tài)資源，不管new了多少個對象，只有一份，所以對該類的所有對象都加了鎖）。所以如果一個線程A調(diào)用一個實例對象的非靜態(tài)synchronized方法，而線程B需要調(diào)用這個實例對象所屬類的靜態(tài)synchronized方法，是允許的，不會發(fā)生互斥現(xiàn)象，因為訪問靜態(tài)synchronized方法占用的鎖是當(dāng)前類的鎖，而訪問非靜態(tài)synchronized方法占用的鎖是當(dāng)前實例對象鎖。
修飾代碼塊，指定加鎖對象，對給定對象加鎖，進(jìn)入同步代碼庫前要獲得給定對象的鎖。和synchronized方法一樣，synchronized(this)代碼塊也是鎖定當(dāng)前對象的。synchronized關(guān)鍵字加到static靜態(tài)方法和synchronized(class)代碼塊上都是是給Class類上鎖。這里再提一下：synchronized關(guān)鍵字加到非static靜態(tài)方法上是給對象實例上鎖。另外需要注意的是：盡量不要使用synchronized(Stringa)因為JVM中，字符串常量池具有緩沖功能！
面試中面試官經(jīng)常會說：“單例模式了解嗎？來給我手寫一下！給我解釋一下雙重檢驗鎖方式實現(xiàn)單利模式的原理唄！”
雙重校驗鎖實現(xiàn)對象單例（線程安全）
public class Singleton {
private volatile static Singleton uniqueInstance;
private Singleton() {
}
public static Singleton getUniqueInstance() {
//先判斷對象是否已經(jīng)實例過，沒有實例化過才進(jìn)入加鎖代碼
if (uniqueInstance == null) {
//類對象加鎖
synchronized (Singleton.class) {
if (uniqueInstance == null) {
uniqueInstance = new Singleton();
}
}
}
return uniqueInstance;
}
}
另外，需要注意uniqueInstance采用volatile關(guān)鍵字修飾也是很有必要。
uniqueInstance采用volatile關(guān)鍵字修飾也是很有必要的，uniqueInstance=newSingleton();這段代碼其實是分為三步執(zhí)行：
為uniqueInstance分配內(nèi)存空間
初始化uniqueInstance
將uniqueInstance指向分配的內(nèi)存地址
但是由于JVM具有指令重排的特性，執(zhí)行順序有可能變成1->3->2。指令重排在單線程環(huán)境下不會出先問題，但是在多線程環(huán)境下會導(dǎo)致一個線程獲得還沒有初始化的實例。例如，線程T1執(zhí)行了1和3，此時T2調(diào)用getUniqueInstance()后發(fā)現(xiàn)uniqueInstance不為空，因此返回uniqueInstance，但此時uniqueInstance還未被初始化。
使用volatile可以禁止JVM的指令重排，保證在多線程環(huán)境下也能正常運行。
1.3講一下synchronized關(guān)鍵字的底層原理
synchronized關(guān)鍵字底層原理屬于JVM層面。
①synchronized同步語句塊的情況
public class SynchronizedDemo {
public void method() {
synchronized (this) {
System.out.println("synchronized 代碼塊");
}
}
}
通過JDK自帶的javap命令查看SynchronizedDemo類的相關(guān)字節(jié)碼信息
從上面我們可以看出：
synchronized同步語句塊的實現(xiàn)使用的是monitorenter和monitorexit指令，其中monitorenter指令指向同步代碼塊的開始位置，monitorexit指令則指明同步代碼塊的結(jié)束位置。當(dāng)執(zhí)行monitorenter指令時，線程試圖獲取鎖也就是獲取monitor(monitor對象存在于每個Java對象的對象頭中，synchronized鎖便是通過這種方式獲取鎖的，也是為什么Java中任意對象可以作為鎖的原因)的持有權(quán).當(dāng)計數(shù)器為0則可以成功獲取，獲取后將鎖計數(shù)器設(shè)為1也就是加1。相應(yīng)的在執(zhí)行monitorexit指令后，將鎖計數(shù)器設(shè)為0，表明鎖被釋放。如果獲取對象鎖失敗，那當(dāng)前線程就要阻塞等待，直到鎖被另外一個線程釋放為止。
②synchronized修飾方法的的情況
public class SynchronizedDemo2 {
public synchronized void method() {
System.out.println("synchronized 方法");
}
}
synchronized關(guān)鍵字原理
synchronized修飾的方法并沒有monitorenter指令和monitorexit指令，取得代之的確實是ACC_SYNCHRONIZED標(biāo)識，該標(biāo)識指明了該方法是一個同步方法，JVM通過該ACC_SYNCHRONIZED訪問標(biāo)志來辨別一個方法是否聲明為同步方法，從而執(zhí)行相應(yīng)的同步調(diào)用。
1.4說說JDK1.6之后的synchronized關(guān)鍵字底層做了哪些優(yōu)化，可以詳細(xì)介紹一下這些優(yōu)化嗎
JDK1.6對鎖的實現(xiàn)引入了大量的優(yōu)化，如偏向鎖、輕量級鎖、自旋鎖、適應(yīng)性自旋鎖、鎖消除、鎖粗化等技術(shù)來減少鎖操作的開銷。
鎖主要存在四中狀態(tài)，依次是：無鎖狀態(tài)、偏向鎖狀態(tài)、輕量級鎖狀態(tài)、重量級鎖狀態(tài)，他們會隨著競爭的激烈而逐漸升級。注意鎖可以升級不可降級，這種策略是為了提高獲得鎖和釋放鎖的效率。
1.5談?wù)剆ynchronized和ReenTrantLock的區(qū)別
①兩者都是可重入鎖
兩者都是可重入鎖?！翱芍厝腈i”概念是：自己可以再次獲取自己的內(nèi)部鎖。比如一個線程獲得了某個對象的鎖，此時這個對象鎖還沒有釋放，當(dāng)其再次想要獲取這個對象的鎖的時候還是可以獲取的，如果不可鎖重入的話，就會造成死鎖。同一個線程每次獲取鎖，鎖的計數(shù)器都自增1，所以要等到鎖的計數(shù)器下降為0時才能釋放鎖。
②synchronized依賴于JVM而ReenTrantLock依賴于API
synchronized是依賴于JVM實現(xiàn)的，前面我們也講到了虛擬機(jī)團(tuán)隊在JDK1.6為synchronized關(guān)鍵字進(jìn)行了很多優(yōu)化，但是這些優(yōu)化都是在虛擬機(jī)層面實現(xiàn)的，并沒有直接暴露給我們。ReenTrantLock是JDK層面實現(xiàn)的（也就是API層面，需要lock()和unlock方法配合try/finally語句塊來完成），所以我們可以通過查看它的源代碼，來看它是如何實現(xiàn)的。
③ReenTrantLock比synchronized增加了一些高級功能
相比synchronized，ReenTrantLock增加了一些高級功能。主要來說主要有三點：①等待可中斷；②可實現(xiàn)公平鎖；③可實現(xiàn)選擇性通知（鎖可以綁定多個條件）
ReenTrantLock提供了一種能夠中斷等待鎖的線程的機(jī)制，通過lock.lockInterruptibly()來實現(xiàn)這個機(jī)制。也就是說正在等待的線程可以選擇放棄等待，改為處理其他事情。
ReenTrantLock可以指定是公平鎖還是非公平鎖。而synchronized只能是非公平鎖。所謂的公平鎖就是先等待的線程先獲得鎖。ReenTrantLock默認(rèn)情況是非公平的，可以通過ReenTrantLock類的ReentrantLock(booleanfair)構(gòu)造方法來制定是否是公平的。在此我向大家推薦一個架構(gòu)學(xué)習(xí)交流圈。交流學(xué)習(xí)企鵝群號：948368769（里面有大量的面試題及答案）里面會分享一些資深架構(gòu)師錄制的視頻錄像：有Spring，MyBatis，Netty源碼分析，高并發(fā)、高性能、分布式、微服務(wù)架構(gòu)的原理，JVM性能優(yōu)化、分布式架構(gòu)等這些成為架構(gòu)師必備的知識體系。還能領(lǐng)取免費的學(xué)習(xí)資源，目前受益良多
synchronized關(guān)鍵字與wait()和notify/notifyAll()方法相結(jié)合可以實現(xiàn)等待/通知機(jī)制，ReentrantLock類當(dāng)然也可以實現(xiàn)，但是需要借助于Condition接口與newCondition()方法。Condition是JDK1.5之后才有的，它具有很好的靈活性，比如可以實現(xiàn)多路通知功能也就是在一個Lock對象中可以創(chuàng)建多個Condition實例（即對象監(jiān)視器），線程對象可以注冊在指定的Condition中，從而可以有選擇性的進(jìn)行線程通知，在調(diào)度線程上更加靈活。在使用notify/notifyAll()方法進(jìn)行通知時，被通知的線程是由JVM選擇的，用ReentrantLock類結(jié)合Condition實例可以實現(xiàn)“選擇性通知”，這個功能非常重要，而且是Condition接口默認(rèn)提供的。而synchronized關(guān)鍵字就相當(dāng)于整個Lock對象中只有一個Condition實例，所有的線程都注冊在它一個身上。如果執(zhí)行notifyAll()方法的話就會通知所有處于等待狀態(tài)的線程這樣會造成很大的效率問題，而Condition實例的signalAll()方法只會喚醒注冊在該Condition實例中的所有等待線程。
如果你想使用上述功能，那么選擇ReenTrantLock是一個不錯的選擇。
④性能已不是選擇標(biāo)準(zhǔn)
2、線程池
2.1講一下Java內(nèi)存模型
在JDK1.2之前，Java的內(nèi)存模型實現(xiàn)總是從主存（即共享內(nèi)存）讀取變量，是不需要進(jìn)行特別的注意的。而在當(dāng)前的Java內(nèi)存模型下，線程可以把變量保存本地內(nèi)存（比如機(jī)器的寄存器）中，而不是直接在主存中進(jìn)行讀寫。這就可能造成一個線程在主存中修改了一個變量的值，而另外一個線程還繼續(xù)使用它在寄存器中的變量值的拷貝，造成數(shù)據(jù)的不一致。
數(shù)據(jù)的不一致
要解決這個問題，就需要把變量聲明為volatile，這就指示JVM，這個變量是不穩(wěn)定的，每次使用它都到主存中進(jìn)行讀取。
說白了，volatile關(guān)鍵字的主要作用就是保證變量的可見性然后還有一個作用是防止指令重排序。
volatile關(guān)鍵字的可見性
2.2說說synchronized關(guān)鍵字和volatile關(guān)鍵字的區(qū)別
synchronized關(guān)鍵字和volatile關(guān)鍵字比較
volatile關(guān)鍵字是線程同步的輕量級實現(xiàn)，所以volatile性能肯定比synchronized關(guān)鍵字要好。但是volatile關(guān)鍵字只能用于變量而synchronized關(guān)鍵字可以修飾方法以及代碼塊。synchronized關(guān)鍵字在JavaSE1.6之后進(jìn)行了主要包括為了減少獲得鎖和釋放鎖帶來的性能消耗而引入的偏向鎖和輕量級鎖以及其它各種優(yōu)化之后執(zhí)行效率有了顯著提升，實際開發(fā)中使用synchronized關(guān)鍵字的場景還是更多一些。
多線程訪問volatile關(guān)鍵字不會發(fā)生阻塞，而synchronized關(guān)鍵字可能會發(fā)生阻塞
volatile關(guān)鍵字能保證數(shù)據(jù)的可見性，但不能保證數(shù)據(jù)的原子性。synchronized關(guān)鍵字兩者都能保證。
volatile關(guān)鍵字主要用于解決變量在多個線程之間的可見性，而synchronized關(guān)鍵字解決的是多個線程之間訪問資源的同步性。
3、面試中關(guān)于線程池的2連擊
3.1為什么要用線程池？
線程池提供了一種限制和管理資源（包括執(zhí)行一個任務(wù)）。每個線程池還維護(hù)一些基本統(tǒng)計信息，例如已完成任務(wù)的數(shù)量。
這里借用《Java并發(fā)編程的藝術(shù)》提到的來說一下使用線程池的好處：
降低資源消耗。通過重復(fù)利用已創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗。
提高響應(yīng)速度。當(dāng)任務(wù)到達(dá)時，任務(wù)可以不需要的等到線程創(chuàng)建就能立即執(zhí)行。
提高線程的可管理性。線程是稀缺資源，如果無限制的創(chuàng)建，不僅會消耗系統(tǒng)資源，還會降低系統(tǒng)的穩(wěn)定性，使用線程池可以進(jìn)行統(tǒng)一的分配，調(diào)優(yōu)和監(jiān)控。
3.2實現(xiàn)Runnable接口和Callable接口的區(qū)別
如果想讓線程池執(zhí)行任務(wù)的話需要實現(xiàn)的Runnable接口或Callable接口。Runnable接口或Callable接口實現(xiàn)類都可以被ThreadPoolExecutor或ScheduledThreadPoolExecutor執(zhí)行。兩者的區(qū)別在于Runnable接口不會返回結(jié)果但是Callable接口可以返回結(jié)果。
備注：工具類Executors可以實現(xiàn)Runnable對象和Callable對象之間的相互轉(zhuǎn)換。（Executors.callable（Runnabletask）或Executors.callable（Runnabletask，Objectresule））。
3.3執(zhí)行execute()方法和submit()方法的區(qū)別是什么呢？
1)execute()方法用于提交不需要返回值的任務(wù)，所以無法判斷任務(wù)是否被線程池執(zhí)行成功與否；
2)submit()方法用于提交需要返回值的任務(wù)。線程池會返回一個future類型的對象，通過這個future對象可以判斷任務(wù)是否執(zhí)行成功，并且可以通過future的get()方法來獲取返回值，get()方法會阻塞當(dāng)前線程直到任務(wù)完成，而使用get（longtimeout，TimeUnitunit）方法則會阻塞當(dāng)前線程一段時間后立即返回，這時候有可能任務(wù)沒有執(zhí)行完。
3.4如何創(chuàng)建線程池
《阿里巴巴Java開發(fā)手冊》中強(qiáng)制線程池不允許使用Executors去創(chuàng)建，而是通過ThreadPoolExecutor的方式，這樣的處理方式讓寫的同學(xué)更加明確線程池的運行規(guī)則，規(guī)避資源耗盡的風(fēng)險**
Executors返回線程池對象的弊端如下：
FixedThreadPool和SingleThreadExecutor：允許請求的隊列長度為Integer.MAX_VALUE,可能堆積大量的請求，從而導(dǎo)致OOM。
CachedThreadPool和ScheduledThreadPool：允許創(chuàng)建的線程數(shù)量為Integer.MAX_VALUE，可能會創(chuàng)建大量線程，從而導(dǎo)致OOM。
方式一：通過構(gòu)造方法實現(xiàn)
通過構(gòu)造方法實現(xiàn)
方式二：通過Executor框架的工具類Executors來實現(xiàn)
我們可以創(chuàng)建三種類型的ThreadPoolExecutor：
FixedThreadPool：該方法返回一個固定線程數(shù)量的線程池。該線程池中的線程數(shù)量始終不變。當(dāng)有一個新的任務(wù)提交時，線程池中若有空閑線程，則立即執(zhí)行。若沒有，則新的任務(wù)會被暫存在一個任務(wù)隊列中，待有線程空閑時，便處理在任務(wù)隊列中的任務(wù)。
SingleThreadExecutor：方法返回一個只有一個線程的線程池。若多余一個任務(wù)被提交到該線程池，任務(wù)會被保存在一個任務(wù)隊列中，待線程空閑，按先入先出的順序執(zhí)行隊列中的任務(wù)。在此我向大家推薦一個架構(gòu)學(xué)習(xí)交流圈。交流學(xué)習(xí)企鵝群號：948368769（里面有大量的面試題及答案）里面會分享一些資深架構(gòu)師錄制的視頻錄像：有Spring，MyBatis，Netty源碼分析，高并發(fā)、高性能、分布式、微服務(wù)架構(gòu)的原理，JVM性能優(yōu)化、分布式架構(gòu)等這些成為架構(gòu)師必備的知識體系。還能領(lǐng)取免費的學(xué)習(xí)資源，目前受益良多
CachedThreadPool：該方法返回一個可根據(jù)實際情況調(diào)整線程數(shù)量的線程池。線程池的線程數(shù)量不確定，但若有空閑線程可以復(fù)用，則會優(yōu)先使用可復(fù)用的線程。若所有線程均在工作，又有新的任務(wù)提交，則會創(chuàng)建新的線程處理任務(wù)。所有線程在當(dāng)前任務(wù)執(zhí)行完畢后，將返回線程池進(jìn)行復(fù)用。
對應(yīng)Executors工具類中的方法如圖所示：
通過Executor框架的工具類Executors來實現(xiàn)
4、Atomic原子類
4.1介紹一下Atomic原子類
Atomic翻譯成中文是原子的意思。在化學(xué)上，我們知道原子是構(gòu)成一般物質(zhì)的最小單位，在化學(xué)反應(yīng)中是不可分割的。在我們這里Atomic是指一個操作是不可中斷的。即使是在多個線程一起執(zhí)行的時候，一個操作一旦開始，就不會被其他線程干擾。
所以，所謂原子類說簡單點就是具有原子/原子操作特征的類。
并發(fā)包java.util.concurrent的原子類都存放在java.util.concurrent.atomic下,如下圖所示。
JUC原子類概覽
4.2JUC包中的原子類是哪4類?
基本類型
使用原子的方式更新基本類型
AtomicInteger：×××原子類
AtomicLong：長整型原子類
AtomicBoolean：布爾型原子類
數(shù)組類型
使用原子的方式更新數(shù)組里的某個元素
AtomicIntegerArray：×××數(shù)組原子類
AtomicLongArray：長×××數(shù)組原子類
AtomicReferenceArray：引用類型數(shù)組原子類
引用類型
AtomicReference：引用類型原子類
AtomicStampedRerence：原子更新引用類型里的字段原子類
AtomicMarkableReference：原子更新帶有標(biāo)記位的引用類型
對象的屬性修改類型
AtomicIntegerFieldUpdater:原子更新×××字段的更新器
AtomicLongFieldUpdater：原子更新長×××字段的更新器
AtomicStampedReference：原子更新帶有版本號的引用類型。該類將整數(shù)值與引用關(guān)聯(lián)起來，可用于解決原子的更新數(shù)據(jù)和數(shù)據(jù)的版本號，可以解決使用CAS進(jìn)行原子更新時可能出現(xiàn)的ABA問題。
4.3講講AtomicInteger的使用
AtomicInteger類常用方法
public final int get() //獲取當(dāng)前的值
public final int getAndSet(int newValue)//獲取當(dāng)前的值，并設(shè)置新的值
public final int getAndIncrement()//獲取當(dāng)前的值，并自增
public final int getAndDecrement() //獲取當(dāng)前的值，并自減
public final int getAndAdd(int delta) //獲取當(dāng)前的值，并加上預(yù)期的值
boolean compareAndSet(int expect, int update) //如果輸入的數(shù)值等于預(yù)期值，則以原子方式將該值設(shè)置為輸入值（update）
public final void lazySet(int newValue)//最終設(shè)置為newValue,使用 lazySet 設(shè)置之后可能導(dǎo)致其他線程在之后的一小段時間內(nèi)還是可以讀到舊的值。</pre>
AtomicInteger類的使用示例
使用AtomicInteger之后，不用對increment()方法加鎖也可以保證線程安全。
class AtomicIntegerTest {
private AtomicInteger count = new AtomicInteger();
//使用AtomicInteger之后，不需要對該方法加鎖，也可以實現(xiàn)線程安全。
public void increment() {
count.incrementAndGet();
}
public int getCount() {
return count.get();
}
}
4.4能不能給我簡單介紹一下AtomicInteger類的原理
AtomicInteger線程安全原理簡單分析
AtomicInteger類的部分源碼：
// setup to use Unsafe.compareAndSwapInt for updates（更新操作時提供“比較并替換”的作用）
private static final Unsafe unsafe = Unsafe.getUnsafe();
private static final long valueOffset;
static {
try {
valueOffset = unsafe.objectFieldOffset
(AtomicInteger.class.getDeclaredField("value"));
} catch (Exception ex) { throw new Error(ex); }
}
private volatile int value;
AtomicInteger類主要利用CAS(compareandswap)+volatile和native方法來保證原子操作，從而避免synchronized的高開銷，執(zhí)行效率大為提升。
CAS的原理是拿期望的值和原本的一個值作比較，如果相同則更新成新的值。UnSafe類的objectFieldOffset()方法是一個本地方法，這個方法是用來拿到“原來的值”的內(nèi)存地址，返回值是valueOffset。另外value是一個volatile變量，在內(nèi)存中可見，因此JVM可以保證任何時刻任何線程總能拿到該變量的最新值。
5、AQS
5.1AQS介紹
AQS的全稱為（AbstractQueuedSynchronizer），這個類在java.util.concurrent.locks包下面。
enterimagedescriptionhere
AQS是一個用來構(gòu)建鎖和同步器的框架，使用AQS能簡單且高效地構(gòu)造出應(yīng)用廣泛的大量的同步器，比如我們提到的ReentrantLock，Semaphore，其他的諸如ReentrantReadWriteLock，SynchronousQueue，F(xiàn)utureTask等等皆是基于AQS的。當(dāng)然，我們自己也能利用AQS非常輕松容易地構(gòu)造出符合我們自己需求的同步器。
5.2AQS原理分析
AQS原理這部分參考了部分博客，在5.2節(jié)末尾放了鏈接。
在面試中被問到并發(fā)知識的時候，大多都會被問到“請你說一下自己對于AQS原理的理解”。下面給大家一個示例供大家參加，面試不是背題，大家一定要假如自己的思想，即使加入不了自己的思想也要保證自己能夠通俗的講出來而不是背出來。在此我向大家推薦一個架構(gòu)學(xué)習(xí)交流圈。交流學(xué)習(xí)企鵝群號：948368769（里面有大量的面試題及答案）里面會分享一些資深架構(gòu)師錄制的視頻錄像：有Spring，MyBatis，Netty源碼分析，高并發(fā)、高性能、分布式、微服務(wù)架構(gòu)的原理，JVM性能優(yōu)化、分布式架構(gòu)等這些成為架構(gòu)師必備的知識體系。還能領(lǐng)取免費的學(xué)習(xí)資源，目前受益良多
下面大部分內(nèi)容其實在AQS類注釋上已經(jīng)給出了，不過是英語看著比較吃力一點，感興趣的話可以看看源碼。
5.2.1AQS原理概覽
AQS核心思想是，如果被請求的共享資源空閑，則將當(dāng)前請求資源的線程設(shè)置為有效的工作線程，并且將共享資源設(shè)置為鎖定狀態(tài)。如果被請求的共享資源被占用，那么就需要一套線程阻塞等待以及被喚醒時鎖分配的機(jī)制，這個機(jī)制AQS是用CLH隊列鎖實現(xiàn)的，即將暫時獲取不到鎖的線程加入到隊列中。
CLH(Craig,Landin,andHagersten)隊列是一個虛擬的雙向隊列（虛擬的雙向隊列即不存在隊列實例，僅存在結(jié)點之間的關(guān)聯(lián)關(guān)系）。AQS是將每條請求共享資源的線程封裝成一個CLH鎖隊列的一個結(jié)點（Node）來實現(xiàn)鎖的分配。
看個AQS(AbstractQueuedSynchronizer)原理圖：
enterimagedescriptionhere
AQS使用一個int成員變量來表示同步狀態(tài)，通過內(nèi)置的FIFO隊列來完成獲取資源線程的排隊工作。AQS使用CAS對該同步狀態(tài)進(jìn)行原子操作實現(xiàn)對其值的修改。
private volatile int state;//共享變量，使用volatile修飾保證線程可見性
狀態(tài)信息通過procted類型的getState，setState，compareAndSetState進(jìn)行操作
//返回同步狀態(tài)的當(dāng)前值
protected final int getState() {
return state;
}
// 設(shè)置同步狀態(tài)的值
protected final void setState(int newState) {
state = newState;
}
//原子地（CAS操作）將同步狀態(tài)值設(shè)置為給定值update如果當(dāng)前同步狀態(tài)的值等于expect（期望值）
protected final boolean compareAndSetState(int expect, int update) {
return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}
5.2.2AQS對資源的共享方式
AQS定義兩種資源共享方式
Exclusive（獨占）：只有一個線程能執(zhí)行，如ReentrantLock。又可分為公平鎖和非公平鎖：
公平鎖：按照線程在隊列中的排隊順序，先到者先拿到鎖
非公平鎖：當(dāng)線程要獲取鎖時，無視隊列順序直接去搶鎖，誰搶到就是誰的
Share（共享）：多個線程可同時執(zhí)行，如Semaphore/CountDownLatch。Semaphore、CountDownLatCh、CyclicBarrier、ReadWriteLock我們都會在后面講到。
ReentrantReadWriteLock可以看成是組合式，因為ReentrantReadWriteLock也就是讀寫鎖允許多個線程同時對某一資源進(jìn)行讀。
不同的自定義同步器爭用共享資源的方式也不同。自定義同步器在實現(xiàn)時只需要實現(xiàn)共享資源state的獲取與釋放方式即可，至于具體線程等待隊列的維護(hù)（如獲取資源失敗入隊/喚醒出隊等），AQS已經(jīng)在頂層實現(xiàn)好了。
5.2.3AQS底層使用了模板方法模式
同步器的設(shè)計是基于模板方法模式的，如果需要自定義同步器一般的方式是這樣（模板方法模式很經(jīng)典的一個應(yīng)用）：
使用者繼承AbstractQueuedSynchronizer并重寫指定的方法。（這些重寫方法很簡單，無非是對于共享資源state的獲取和釋放）
將AQS組合在自定義同步組件的實現(xiàn)中，并調(diào)用其模板方法，而這些模板方法會調(diào)用使用者重寫的方法。
這和我們以往通過實現(xiàn)接口的方式有很大區(qū)別，這是模板方法模式很經(jīng)典的一個運用。
AQS使用了模板方法模式，自定義同步器時需要重寫下面幾個AQS提供的模板方法：
isHeldExclusively()//該線程是否正在獨占資源。只有用到condition才需要去實現(xiàn)它。
tryAcquire(int)//獨占方式。嘗試獲取資源，成功則返回true，失敗則返回false。
tryRelease(int)//獨占方式。嘗試釋放資源，成功則返回true，失敗則返回false。
tryAcquireShared(int)//共享方式。嘗試獲取資源。負(fù)數(shù)表示失敗；0表示成功，但沒有剩余可用資源；正數(shù)表示成功，且有剩余資源。
tryReleaseShared(int)//共享方式。嘗試釋放資源，成功則返回true，失敗則返回false。
默認(rèn)情況下，每個方法都拋出UnsupportedOperationException。這些方法的實現(xiàn)必須是內(nèi)部線程安全的，并且通常應(yīng)該簡短而不是阻塞。AQS類中的其他方法都是final，所以無法被其他類使用，只有這幾個方法可以被其他類使用。
以ReentrantLock為例，state初始化為0，表示未鎖定狀態(tài)。A線程lock()時，會調(diào)用tryAcquire()獨占該鎖并將state+1。此后，其他線程再tryAcquire()時就會失敗，直到A線程unlock()到state=0（即釋放鎖）為止，其它線程才有機(jī)會獲取該鎖。當(dāng)然，釋放鎖之前，A線程自己是可以重復(fù)獲取此鎖的（state會累加），這就是可重入的概念。但要注意，獲取多少次就要釋放多么次，這樣才能保證state是能回到零態(tài)的。
再以CountDownLatch以例，任務(wù)分為N個子線程去執(zhí)行，state也初始化為N（注意N要與線程個數(shù)一致）。這N個子線程是并行執(zhí)行的，每個子線程執(zhí)行完后countDown()一次，state會CAS(CompareandSwap)減1。等到所有子線程都執(zhí)行完后(即state=0)，會unpark()主調(diào)用線程，然后主調(diào)用線程就會從await()函數(shù)返回，繼續(xù)后余動作。
一般來說，自定義同步器要么是獨占方法，要么是共享方式，他們也只需實現(xiàn)tryAcquire-tryRelease、tryAcquireShared-tryReleaseShared中的一種即可。但AQS也支持自定義同步器同時實現(xiàn)獨占和共享兩種方式，如ReentrantReadWriteLock。
5.3AQS組件總結(jié)
Semaphore(信號量)-允許多個線程同時訪問：synchronized和ReentrantLock都是一次只允許一個線程訪問某個資源，Semaphore(信號量)可以指定多個線程同時訪問某個資源。
CountDownLatch（倒計時器）：CountDownLatch是一個同步工具類，用來協(xié)調(diào)多個線程之間的同步。這個工具通常用來控制線程等待，它可以讓某一個線程等待直到倒計時結(jié)束，再開始執(zhí)行。
CyclicBarrier(循環(huán)柵欄)：CyclicBarrier和CountDownLatch非常類似，它也可以實現(xiàn)線程間的技術(shù)等待，但是它的功能比CountDownLatch更加復(fù)雜和強(qiáng)大。主要應(yīng)用場景和CountDownLatch類似。CyclicBarrier的字面意思是可循環(huán)使用（Cyclic）的屏障（Barrier）。它要做的事情是，讓一組線程到達(dá)一個屏障（也可以叫同步點）時被阻塞，直到最后一個線程到達(dá)屏障時，屏障才會開門，所有被屏障攔截的線程才會繼續(xù)干活。CyclicBarrier默認(rèn)的構(gòu)造方法是CyclicBarrier(intparties)，其參數(shù)表示屏障攔截的線程數(shù)量，每個線程調(diào)用await方法告訴CyclicBarrier我已經(jīng)到達(dá)了屏障，然后當(dāng)前線程被阻塞。
以上就是關(guān)于千鋒扣丁學(xué)堂Java培訓(xùn)之2019年Java大廠面試常見必問多線程面試題匯總的全部內(nèi)容，
希望對大家的學(xué)習(xí)有所幫助，想要了解更多關(guān)于Java開發(fā)方面內(nèi)容的小伙伴，請關(guān)注扣丁學(xué)堂Java培訓(xùn)官網(wǎng)、微信等平臺，扣丁學(xué)堂IT職業(yè)在線學(xué)習(xí)教育有專業(yè)的Java講師為您指導(dǎo)，此外扣丁學(xué)堂老師精心推出的Java視頻教程定能讓你快速掌握J(rèn)ava從入門到精通開發(fā)實戰(zhàn)技能?？鄱W(xué)堂Java技術(shù)交流群：850353792。
【關(guān)注微信公眾號獲取更多學(xué)習(xí)資料】 【掃碼進(jìn)入JavaEE/微服務(wù)VIP免費公開課】
查看更多關(guān)于“Java開發(fā)資訊”的相關(guān)文章>>
標(biāo)簽:
Java培訓(xùn)
Java視頻教程
Java多線程
Java面試題
Java學(xué)習(xí)視頻
springBoot項目
返回頂部