摘要:今天給大家總結(jié)一下,面試中出鏡率很高的幾個(gè)多線程面試題,希望對大家學(xué)習(xí)和面試都能有所幫助。指令重排在單線程環(huán)境下不會(huì)出先問題,但是在多線程環(huán)境下會(huì)導(dǎo)致一個(gè)線程獲得還沒有初始化的實(shí)例。使用可以禁止的指令重排,保證在多線程環(huán)境下也能正常運(yùn)行。
下面最近發(fā)的一些并發(fā)編程的文章匯總,通過閱讀這些文章大家再看大廠面試中的并發(fā)編程問題就沒有那么頭疼了。今天給大家總結(jié)一下,面試中出鏡率很高的幾個(gè)多線程面試題,希望對大家學(xué)習(xí)和面試都能有所幫助。備注:文中的代碼自己實(shí)現(xiàn)一遍的話效果會(huì)更佳哦!
并發(fā)編程面試必備:synchronized 關(guān)鍵字使用、底層原理、JDK1.6 之后的底層優(yōu)化以及 和ReenTrantLock 的對比
并發(fā)編程面試必備:JUC 中的 Atomic 原子類總結(jié)
并發(fā)編程面試必備:AQS 原理以及 AQS 同步組件總結(jié)
該文已加入開源文檔:JavaGuide(一份涵蓋大部分Java程序員所需要掌握的核心知識)。地址:https://github.com/Snailclimb...一 面試中關(guān)于 synchronized 關(guān)鍵字的 5 連擊 1.1 說一說自己對于 synchronized 關(guān)鍵字的了解
【強(qiáng)烈推薦!非廣告!】阿里云雙11褥羊毛活動(dòng):https://m.aliyun.com/act/team1111/#/share?params=N.FF7yxCciiM.hf47liqn 差不多一折,不過僅限阿里云新人購買,不是新人的朋友自己找方法買哦!
synchronized關(guān)鍵字解決的是多個(gè)線程之間訪問資源的同步性,synchronized關(guān)鍵字可以保證被它修飾的方法或者代碼塊在任意時(shí)刻只能有一個(gè)線程執(zhí)行。
另外,在 Java 早期版本中,synchronized屬于重量級鎖,效率低下,因?yàn)楸O(jiān)視器鎖(monitor)是依賴于底層的操作系統(tǒng)的 Mutex Lock 來實(shí)現(xiàn)的,Java 的線程是映射到操作系統(tǒng)的原生線程之上的。如果要掛起或者喚醒一個(gè)線程,都需要操作系統(tǒng)幫忙完成,而操作系統(tǒng)實(shí)現(xiàn)線程之間的切換時(shí)需要從用戶態(tài)轉(zhuǎn)換到內(nèi)核態(tài),這個(gè)狀態(tài)之間的轉(zhuǎn)換需要相對比較長的時(shí)間,時(shí)間成本相對較高,這也是為什么早期的 synchronized 效率低的原因。慶幸的是在 Java 6 之后 Java 官方對從 JVM 層面對synchronized 較大優(yōu)化,所以現(xiàn)在的 synchronized 鎖效率也優(yōu)化得很不錯(cuò)了。JDK1.6對鎖的實(shí)現(xiàn)引入了大量的優(yōu)化,如自旋鎖、適應(yīng)性自旋鎖、鎖消除、鎖粗化、偏向鎖、輕量級鎖等技術(shù)來減少鎖操作的開銷。
1.2 說說自己是怎么使用 synchronized 關(guān)鍵字,在項(xiàng)目中用到了嗎synchronized關(guān)鍵字最主要的三種使用方式:
修飾實(shí)例方法,作用于當(dāng)前對象實(shí)例加鎖,進(jìn)入同步代碼前要獲得當(dāng)前對象實(shí)例的鎖
修飾靜態(tài)方法,作用于當(dāng)前類對象加鎖,進(jìn)入同步代碼前要獲得當(dāng)前類對象的鎖 。也就是給當(dāng)前類加鎖,會(huì)作用于類的所有對象實(shí)例,因?yàn)殪o態(tài)成員不屬于任何一個(gè)實(shí)例對象,是類成員( static 表明這是該類的一個(gè)靜態(tài)資源,不管new了多少個(gè)對象,只有一份,所以對該類的所有對象都加了鎖)。所以如果一個(gè)線程A調(diào)用一個(gè)實(shí)例對象的非靜態(tài) synchronized 方法,而線程B需要調(diào)用這個(gè)實(shí)例對象所屬類的靜態(tài) synchronized 方法,是允許的,不會(huì)發(fā)生互斥現(xiàn)象,因?yàn)樵L問靜態(tài) synchronized 方法占用的鎖是當(dāng)前類的鎖,而訪問非靜態(tài) synchronized 方法占用的鎖是當(dāng)前實(shí)例對象鎖。
修飾代碼塊,指定加鎖對象,對給定對象加鎖,進(jìn)入同步代碼庫前要獲得給定對象的鎖。 和 synchronized 方法一樣,synchronized(this)代碼塊也是鎖定當(dāng)前對象的。synchronized 關(guān)鍵字加到 static 靜態(tài)方法和 synchronized(class)代碼塊上都是是給 Class 類上鎖。這里再提一下:synchronized關(guān)鍵字加到非 static 靜態(tài)方法上是給對象實(shí)例上鎖。另外需要注意的是:盡量不要使用 synchronized(String a) 因?yàn)镴VM中,字符串常量池具有緩沖功能!
下面我已一個(gè)常見的面試題為例講解一下 synchronized 關(guān)鍵字的具體使用。
面試中面試官經(jīng)常會(huì)說:“單例模式了解嗎?來給我手寫一下!給我解釋一下雙重檢驗(yàn)鎖方式實(shí)現(xiàn)單利模式的原理唄!”
雙重校驗(yàn)鎖實(shí)現(xiàn)對象單例(線程安全)
public class Singleton { private volatile static Singleton uniqueInstance; private Singleton() { } public static Singleton getUniqueInstance() { //先判斷對象是否已經(jīng)實(shí)例過,沒有實(shí)例化過才進(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 = new Singleton(); 這段代碼其實(shí)是分為三步執(zhí)行:
為 uniqueInstance 分配內(nèi)存空間
初始化 uniqueInstance
將 uniqueInstance 指向分配的內(nèi)存地址
但是由于 JVM 具有指令重排的特性,執(zhí)行順序有可能變成 1->3->2。指令重排在單線程環(huán)境下不會(huì)出先問題,但是在多線程環(huán)境下會(huì)導(dǎo)致一個(gè)線程獲得還沒有初始化的實(shí)例。例如,線程 T1 執(zhí)行了 1 和 3,此時(shí) T2 調(diào)用 getUniqueInstance() 后發(fā)現(xiàn) uniqueInstance 不為空,因此返回 uniqueInstance,但此時(shí) uniqueInstance 還未被初始化。
使用 volatile 可以禁止 JVM 的指令重排,保證在多線程環(huán)境下也能正常運(yù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é)碼信息:首先切換到類的對應(yīng)目錄執(zhí)行 javac SynchronizedDemo.java 命令生成編譯后的 .class 文件,然后執(zhí)行javap -c -s -v -l SynchronizedDemo.class。
從上面我們可以看出:
synchronized 同步語句塊的實(shí)現(xiàn)使用的是 monitorenter 和 monitorexit 指令,其中 monitorenter 指令指向同步代碼塊的開始位置,monitorexit 指令則指明同步代碼塊的結(jié)束位置。 當(dāng)執(zhí)行 monitorenter 指令時(shí),線程試圖獲取鎖也就是獲取 monitor(monitor對象存在于每個(gè)Java對象的對象頭中,synchronized 鎖便是通過這種方式獲取鎖的,也是為什么Java中任意對象可以作為鎖的原因) 的持有權(quán).當(dāng)計(jì)數(shù)器為0則可以成功獲取,獲取后將鎖計(jì)數(shù)器設(shè)為1也就是加1。相應(yīng)的在執(zhí)行 monitorexit 指令后,將鎖計(jì)數(shù)器設(shè)為0,表明鎖被釋放。如果獲取對象鎖失敗,那當(dāng)前線程就要阻塞等待,直到鎖被另外一個(gè)線程釋放為止。
② synchronized 修飾方法的的情況
public class SynchronizedDemo2 { public synchronized void method() { System.out.println("synchronized 方法"); } }
synchronized 修飾的方法并沒有 monitorenter 指令和 monitorexit 指令,取得代之的確實(shí)是 ACC_SYNCHRONIZED 標(biāo)識,該標(biāo)識指明了該方法是一個(gè)同步方法,JVM 通過該 ACC_SYNCHRONIZED 訪問標(biāo)志來辨別一個(gè)方法是否聲明為同步方法,從而執(zhí)行相應(yīng)的同步調(diào)用。
1.4 說說 JDK1.6 之后的synchronized 關(guān)鍵字底層做了哪些優(yōu)化,可以詳細(xì)介紹一下這些優(yōu)化嗎JDK1.6 對鎖的實(shí)現(xiàn)引入了大量的優(yōu)化,如偏向鎖、輕量級鎖、自旋鎖、適應(yīng)性自旋鎖、鎖消除、鎖粗化等技術(shù)來減少鎖操作的開銷。
鎖主要存在四中狀態(tài),依次是:無鎖狀態(tài)、偏向鎖狀態(tài)、輕量級鎖狀態(tài)、重量級鎖狀態(tài),他們會(huì)隨著競爭的激烈而逐漸升級。注意鎖可以升級不可降級,這種策略是為了提高獲得鎖和釋放鎖的效率。
關(guān)于這幾種優(yōu)化的詳細(xì)信息可以查看:synchronized 關(guān)鍵字使用、底層原理、JDK1.6 之后的底層優(yōu)化以及 和ReenTrantLock 的對比
1.5 談?wù)?synchronized和ReenTrantLock 的區(qū)別① 兩者都是可重入鎖
兩者都是可重入鎖?!翱芍厝腈i”概念是:自己可以再次獲取自己的內(nèi)部鎖。比如一個(gè)線程獲得了某個(gè)對象的鎖,此時(shí)這個(gè)對象鎖還沒有釋放,當(dāng)其再次想要獲取這個(gè)對象的鎖的時(shí)候還是可以獲取的,如果不可鎖重入的話,就會(huì)造成死鎖。同一個(gè)線程每次獲取鎖,鎖的計(jì)數(shù)器都自增1,所以要等到鎖的計(jì)數(shù)器下降為0時(shí)才能釋放鎖。
② synchronized 依賴于 JVM 而 ReenTrantLock 依賴于 API
synchronized 是依賴于 JVM 實(shí)現(xiàn)的,前面我們也講到了 虛擬機(jī)團(tuán)隊(duì)在 JDK1.6 為 synchronized 關(guān)鍵字進(jìn)行了很多優(yōu)化,但是這些優(yōu)化都是在虛擬機(jī)層面實(shí)現(xiàn)的,并沒有直接暴露給我們。ReenTrantLock 是 JDK 層面實(shí)現(xiàn)的(也就是 API 層面,需要 lock() 和 unlock 方法配合 try/finally 語句塊來完成),所以我們可以通過查看它的源代碼,來看它是如何實(shí)現(xiàn)的。
③ ReenTrantLock 比 synchronized 增加了一些高級功能
相比synchronized,ReenTrantLock增加了一些高級功能。主要來說主要有三點(diǎn):①等待可中斷;②可實(shí)現(xiàn)公平鎖;③可實(shí)現(xiàn)選擇性通知(鎖可以綁定多個(gè)條件)
ReenTrantLock提供了一種能夠中斷等待鎖的線程的機(jī)制,通過lock.lockInterruptibly()來實(shí)現(xiàn)這個(gè)機(jī)制。也就是說正在等待的線程可以選擇放棄等待,改為處理其他事情。
ReenTrantLock可以指定是公平鎖還是非公平鎖。而synchronized只能是非公平鎖。所謂的公平鎖就是先等待的線程先獲得鎖。 ReenTrantLock默認(rèn)情況是非公平的,可以通過 ReenTrantLock類的ReentrantLock(boolean fair)構(gòu)造方法來制定是否是公平的。
synchronized關(guān)鍵字與wait()和notify/notifyAll()方法相結(jié)合可以實(shí)現(xiàn)等待/通知機(jī)制,ReentrantLock類當(dāng)然也可以實(shí)現(xiàn),但是需要借助于Condition接口與newCondition() 方法。Condition是JDK1.5之后才有的,它具有很好的靈活性,比如可以實(shí)現(xiàn)多路通知功能也就是在一個(gè)Lock對象中可以創(chuàng)建多個(gè)Condition實(shí)例(即對象監(jiān)視器),線程對象可以注冊在指定的Condition中,從而可以有選擇性的進(jìn)行線程通知,在調(diào)度線程上更加靈活。 在使用notify/notifyAll()方法進(jìn)行通知時(shí),被通知的線程是由 JVM 選擇的,用ReentrantLock類結(jié)合Condition實(shí)例可以實(shí)現(xiàn)“選擇性通知” ,這個(gè)功能非常重要,而且是Condition接口默認(rèn)提供的。而synchronized關(guān)鍵字就相當(dāng)于整個(gè)Lock對象中只有一個(gè)Condition實(shí)例,所有的線程都注冊在它一個(gè)身上。如果執(zhí)行notifyAll()方法的話就會(huì)通知所有處于等待狀態(tài)的線程這樣會(huì)造成很大的效率問題,而Condition實(shí)例的signalAll()方法 只會(huì)喚醒注冊在該Condition實(shí)例中的所有等待線程。
如果你想使用上述功能,那么選擇ReenTrantLock是一個(gè)不錯(cuò)的選擇。
④ 性能已不是選擇標(biāo)準(zhǔn)
二 面試中關(guān)于線程池的 4 連擊 2.1 講一下Java內(nèi)存模型在 JDK1.2 之前,Java的內(nèi)存模型實(shí)現(xiàn)總是從主存(即共享內(nèi)存)讀取變量,是不需要進(jìn)行特別的注意的。而在當(dāng)前的 Java 內(nèi)存模型下,線程可以把變量保存本地內(nèi)存(比如機(jī)器的寄存器)中,而不是直接在主存中進(jìn)行讀寫。這就可能造成一個(gè)線程在主存中修改了一個(gè)變量的值,而另外一個(gè)線程還繼續(xù)使用它在寄存器中的變量值的拷貝,造成數(shù)據(jù)的不一致。
要解決這個(gè)問題,就需要把變量聲明為 volatile,這就指示 JVM,這個(gè)變量是不穩(wěn)定的,每次使用它都到主存中進(jìn)行讀取。
說白了, volatile 關(guān)鍵字的主要作用就是保證變量的可見性然后還有一個(gè)作用是防止指令重排序。
2.2 說說 synchronized 關(guān)鍵字和 volatile 關(guān)鍵字的區(qū)別synchronized關(guān)鍵字和volatile關(guān)鍵字比較
volatile關(guān)鍵字是線程同步的輕量級實(shí)現(xiàn),所以volatile性能肯定比synchronized關(guān)鍵字要好。但是volatile關(guān)鍵字只能用于變量而synchronized關(guān)鍵字可以修飾方法以及代碼塊。synchronized關(guān)鍵字在JavaSE1.6之后進(jìn)行了主要包括為了減少獲得鎖和釋放鎖帶來的性能消耗而引入的偏向鎖和輕量級鎖以及其它各種優(yōu)化之后執(zhí)行效率有了顯著提升,實(shí)際開發(fā)中使用 synchronized 關(guān)鍵字的場景還是更多一些。
多線程訪問volatile關(guān)鍵字不會(huì)發(fā)生阻塞,而synchronized關(guān)鍵字可能會(huì)發(fā)生阻塞
volatile關(guān)鍵字能保證數(shù)據(jù)的可見性,但不能保證數(shù)據(jù)的原子性。synchronized關(guān)鍵字兩者都能保證。
volatile關(guān)鍵字主要用于解決變量在多個(gè)線程之間的可見性,而 synchronized關(guān)鍵字解決的是多個(gè)線程之間訪問資源的同步性。
三 面試中關(guān)于 線程池的 2 連擊 3.1 為什么要用線程池?線程池提供了一種限制和管理資源(包括執(zhí)行一個(gè)任務(wù))。 每個(gè)線程池還維護(hù)一些基本統(tǒng)計(jì)信息,例如已完成任務(wù)的數(shù)量。
這里借用《Java并發(fā)編程的藝術(shù)》提到的來說一下使用線程池的好處:
降低資源消耗。 通過重復(fù)利用已創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗。
提高響應(yīng)速度。 當(dāng)任務(wù)到達(dá)時(shí),任務(wù)可以不需要的等到線程創(chuàng)建就能立即執(zhí)行。
提高線程的可管理性。 線程是稀缺資源,如果無限制的創(chuàng)建,不僅會(huì)消耗系統(tǒng)資源,還會(huì)降低系統(tǒng)的穩(wěn)定性,使用線程池可以進(jìn)行統(tǒng)一的分配,調(diào)優(yōu)和監(jiān)控。
3.2 實(shí)現(xiàn)Runnable接口和Callable接口的區(qū)別如果想讓線程池執(zhí)行任務(wù)的話需要實(shí)現(xiàn)的Runnable接口或Callable接口。 Runnable接口或Callable接口實(shí)現(xiàn)類都可以被ThreadPoolExecutor或ScheduledThreadPoolExecutor執(zhí)行。兩者的區(qū)別在于 Runnable 接口不會(huì)返回結(jié)果但是 Callable 接口可以返回結(jié)果。
備注: 工具類Executors可以實(shí)現(xiàn)Runnable對象和Callable對象之間的相互轉(zhuǎn)換。(Executors.callable(Runnable task)或Executors.callable(Runnable task,Object resule))。
3.3 執(zhí)行execute()方法和submit()方法的區(qū)別是什么呢?1)execute() 方法用于提交不需要返回值的任務(wù),所以無法判斷任務(wù)是否被線程池執(zhí)行成功與否;
2)submit()方法用于提交需要返回值的任務(wù)。線程池會(huì)返回一個(gè)future類型的對象,通過這個(gè)future對象可以判斷任務(wù)是否執(zhí)行成功,并且可以通過future的get()方法來獲取返回值,get()方法會(huì)阻塞當(dāng)前線程直到任務(wù)完成,而使用 get(long timeout,TimeUnit unit)方法則會(huì)阻塞當(dāng)前線程一段時(shí)間后立即返回,這時(shí)候有可能任務(wù)沒有執(zhí)行完。
3.4 如何創(chuàng)建線程池《阿里巴巴Java開發(fā)手冊》中強(qiáng)制線程池不允許使用 Executors 去創(chuàng)建,而是通過 ThreadPoolExecutor 的方式,這樣的處理方式讓寫的同學(xué)更加明確線程池的運(yùn)行規(guī)則,規(guī)避資源耗盡的風(fēng)險(xiǎn)**
Executors 返回線程池對象的弊端如下:
FixedThreadPool 和 SingleThreadExecutor : 允許請求的隊(duì)列長度為 Integer.MAX_VALUE,可能堆積大量的請求,從而導(dǎo)致OOM。
CachedThreadPool 和 ScheduledThreadPool : 允許創(chuàng)建的線程數(shù)量為 Integer.MAX_VALUE ,可能會(huì)創(chuàng)建大量線程,從而導(dǎo)致OOM。
方式一:通過構(gòu)造方法實(shí)現(xiàn)
方式二:通過Executor 框架的工具類Executors來實(shí)現(xiàn)
我們可以創(chuàng)建三種類型的ThreadPoolExecutor:
FixedThreadPool : 該方法返回一個(gè)固定線程數(shù)量的線程池。該線程池中的線程數(shù)量始終不變。當(dāng)有一個(gè)新的任務(wù)提交時(shí),線程池中若有空閑線程,則立即執(zhí)行。若沒有,則新的任務(wù)會(huì)被暫存在一個(gè)任務(wù)隊(duì)列中,待有線程空閑時(shí),便處理在任務(wù)隊(duì)列中的任務(wù)。
SingleThreadExecutor: 方法返回一個(gè)只有一個(gè)線程的線程池。若多余一個(gè)任務(wù)被提交到該線程池,任務(wù)會(huì)被保存在一個(gè)任務(wù)隊(duì)列中,待線程空閑,按先入先出的順序執(zhí)行隊(duì)列中的任務(wù)。
CachedThreadPool: 該方法返回一個(gè)可根據(jù)實(shí)際情況調(diào)整線程數(shù)量的線程池。線程池的線程數(shù)量不確定,但若有空閑線程可以復(fù)用,則會(huì)優(yōu)先使用可復(fù)用的線程。若所有線程均在工作,又有新的任務(wù)提交,則會(huì)創(chuàng)建新的線程處理任務(wù)。所有線程在當(dāng)前任務(wù)執(zhí)行完畢后,將返回線程池進(jìn)行復(fù)用。
對應(yīng)Executors工具類中的方法如圖所示:
Atomic 翻譯成中文是原子的意思。在化學(xué)上,我們知道原子是構(gòu)成一般物質(zhì)的最小單位,在化學(xué)反應(yīng)中是不可分割的。在我們這里 Atomic 是指一個(gè)操作是不可中斷的。即使是在多個(gè)線程一起執(zhí)行的時(shí)候,一個(gè)操作一旦開始,就不會(huì)被其他線程干擾。
所以,所謂原子類說簡單點(diǎn)就是具有原子/原子操作特征的類。
并發(fā)包 java.util.concurrent 的原子類都存放在java.util.concurrent.atomic下,如下圖所示。
4.2 JUC 包中的原子類是哪4類?基本類型
使用原子的方式更新基本類型
AtomicInteger:整形原子類
AtomicLong:長整型原子類
AtomicBoolean :布爾型原子類
數(shù)組類型
使用原子的方式更新數(shù)組里的某個(gè)元素
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)行原子更新時(shí)可能出現(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)致其他線程在之后的一小段時(shí)間內(nèi)還是可以讀到舊的值。
AtomicInteger 類的使用示例
使用 AtomicInteger 之后,不用對 increment() 方法加鎖也可以保證線程安全。
class AtomicIntegerTest { private AtomicInteger count = new AtomicInteger(); //使用AtomicInteger之后,不需要對該方法加鎖,也可以實(shí)現(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(更新操作時(shí)提供“比較并替換”的作用) 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 (compare and swap) + volatile 和 native 方法來保證原子操作,從而避免 synchronized 的高開銷,執(zhí)行效率大為提升。
CAS的原理是拿期望的值和原本的一個(gè)值作比較,如果相同則更新成新的值。UnSafe 類的 objectFieldOffset() 方法是一個(gè)本地方法,這個(gè)方法是用來拿到“原來的值”的內(nèi)存地址,返回值是 valueOffset。另外 value 是一個(gè)volatile變量,在內(nèi)存中可見,因此 JVM 可以保證任何時(shí)刻任何線程總能拿到該變量的最新值。
關(guān)于 Atomic 原子類這部分更多內(nèi)容可以查看我的這篇文章:并發(fā)編程面試必備:JUC 中的 Atomic 原子類總結(jié)
五 AQS 5.1 AQS 介紹AQS的全稱為(AbstractQueuedSynchronizer),這個(gè)類在java.util.concurrent.locks包下面。
AQS是一個(gè)用來構(gòu)建鎖和同步器的框架,使用AQS能簡單且高效地構(gòu)造出應(yīng)用廣泛的大量的同步器,比如我們提到的ReentrantLock,Semaphore,其他的諸如ReentrantReadWriteLock,SynchronousQueue,F(xiàn)utureTask等等皆是基于AQS的。當(dāng)然,我們自己也能利用AQS非常輕松容易地構(gòu)造出符合我們自己需求的同步器。
5.2 AQS 原理分析AQS 原理這部分參考了部分博客,在5.2節(jié)末尾放了鏈接。
在面試中被問到并發(fā)知識的時(shí)候,大多都會(huì)被問到“請你說一下自己對于AQS原理的理解”。下面給大家一個(gè)示例供大家參加,面試不是背題,大家一定要假如自己的思想,即使加入不了自己的思想也要保證自己能夠通俗的講出來而不是背出來。
下面大部分內(nèi)容其實(shí)在AQS類注釋上已經(jīng)給出了,不過是英語看著比較吃力一點(diǎn),感興趣的話可以看看源碼。
5.2.1 AQS 原理概覽AQS核心思想是,如果被請求的共享資源空閑,則將當(dāng)前請求資源的線程設(shè)置為有效的工作線程,并且將共享資源設(shè)置為鎖定狀態(tài)。如果被請求的共享資源被占用,那么就需要一套線程阻塞等待以及被喚醒時(shí)鎖分配的機(jī)制,這個(gè)機(jī)制AQS是用CLH隊(duì)列鎖實(shí)現(xiàn)的,即將暫時(shí)獲取不到鎖的線程加入到隊(duì)列中。
CLH(Craig,Landin,and Hagersten)隊(duì)列是一個(gè)虛擬的雙向隊(duì)列(虛擬的雙向隊(duì)列即不存在隊(duì)列實(shí)例,僅存在結(jié)點(diǎn)之間的關(guān)聯(lián)關(guān)系)。AQS是將每條請求共享資源的線程封裝成一個(gè)CLH鎖隊(duì)列的一個(gè)結(jié)點(diǎn)(Node)來實(shí)現(xiàn)鎖的分配。
看個(gè)AQS(AbstractQueuedSynchronizer)原理圖:
AQS使用一個(gè)int成員變量來表示同步狀態(tài),通過內(nèi)置的FIFO隊(duì)列來完成獲取資源線程的排隊(duì)工作。AQS使用CAS對該同步狀態(tài)進(jìn)行原子操作實(shí)現(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.2 AQS 對資源的共享方式
AQS定義兩種資源共享方式
Exclusive(獨(dú)占):只有一個(gè)線程能執(zhí)行,如ReentrantLock。又可分為公平鎖和非公平鎖:
公平鎖:按照線程在隊(duì)列中的排隊(duì)順序,先到者先拿到鎖
非公平鎖:當(dāng)線程要獲取鎖時(shí),無視隊(duì)列順序直接去搶鎖,誰搶到就是誰的
Share(共享):多個(gè)線程可同時(shí)執(zhí)行,如Semaphore/CountDownLatch。Semaphore、CountDownLatCh、 CyclicBarrier、ReadWriteLock 我們都會(huì)在后面講到。
ReentrantReadWriteLock 可以看成是組合式,因?yàn)镽eentrantReadWriteLock也就是讀寫鎖允許多個(gè)線程同時(shí)對某一資源進(jìn)行讀。
不同的自定義同步器爭用共享資源的方式也不同。自定義同步器在實(shí)現(xiàn)時(shí)只需要實(shí)現(xiàn)共享資源 state 的獲取與釋放方式即可,至于具體線程等待隊(duì)列的維護(hù)(如獲取資源失敗入隊(duì)/喚醒出隊(duì)等),AQS已經(jīng)在頂層實(shí)現(xiàn)好了。
5.2.3 AQS底層使用了模板方法模式同步器的設(shè)計(jì)是基于模板方法模式的,如果需要自定義同步器一般的方式是這樣(模板方法模式很經(jīng)典的一個(gè)應(yīng)用):
使用者繼承AbstractQueuedSynchronizer并重寫指定的方法。(這些重寫方法很簡單,無非是對于共享資源state的獲取和釋放)
將AQS組合在自定義同步組件的實(shí)現(xiàn)中,并調(diào)用其模板方法,而這些模板方法會(huì)調(diào)用使用者重寫的方法。
這和我們以往通過實(shí)現(xiàn)接口的方式有很大區(qū)別,這是模板方法模式很經(jīng)典的一個(gè)運(yùn)用。
AQS使用了模板方法模式,自定義同步器時(shí)需要重寫下面幾個(gè)AQS提供的模板方法:
isHeldExclusively()//該線程是否正在獨(dú)占資源。只有用到condition才需要去實(shí)現(xiàn)它。 tryAcquire(int)//獨(dú)占方式。嘗試獲取資源,成功則返回true,失敗則返回false。 tryRelease(int)//獨(dú)占方式。嘗試釋放資源,成功則返回true,失敗則返回false。 tryAcquireShared(int)//共享方式。嘗試獲取資源。負(fù)數(shù)表示失??;0表示成功,但沒有剩余可用資源;正數(shù)表示成功,且有剩余資源。 tryReleaseShared(int)//共享方式。嘗試釋放資源,成功則返回true,失敗則返回false。
默認(rèn)情況下,每個(gè)方法都拋出 UnsupportedOperationException。 這些方法的實(shí)現(xiàn)必須是內(nèi)部線程安全的,并且通常應(yīng)該簡短而不是阻塞。AQS類中的其他方法都是final ,所以無法被其他類使用,只有這幾個(gè)方法可以被其他類使用。
以ReentrantLock為例,state初始化為0,表示未鎖定狀態(tài)。A線程lock()時(shí),會(huì)調(diào)用tryAcquire()獨(dú)占該鎖并將state+1。此后,其他線程再tryAcquire()時(shí)就會(huì)失敗,直到A線程unlock()到state=0(即釋放鎖)為止,其它線程才有機(jī)會(huì)獲取該鎖。當(dāng)然,釋放鎖之前,A線程自己是可以重復(fù)獲取此鎖的(state會(huì)累加),這就是可重入的概念。但要注意,獲取多少次就要釋放多么次,這樣才能保證state是能回到零態(tài)的。
再以CountDownLatch以例,任務(wù)分為N個(gè)子線程去執(zhí)行,state也初始化為N(注意N要與線程個(gè)數(shù)一致)。這N個(gè)子線程是并行執(zhí)行的,每個(gè)子線程執(zhí)行完后countDown()一次,state會(huì)CAS(Compare and Swap)減1。等到所有子線程都執(zhí)行完后(即state=0),會(huì)unpark()主調(diào)用線程,然后主調(diào)用線程就會(huì)從await()函數(shù)返回,繼續(xù)后余動(dòng)作。
一般來說,自定義同步器要么是獨(dú)占方法,要么是共享方式,他們也只需實(shí)現(xiàn)tryAcquire-tryRelease、tryAcquireShared-tryReleaseShared中的一種即可。但AQS也支持自定義同步器同時(shí)實(shí)現(xiàn)獨(dú)占和共享兩種方式,如ReentrantReadWriteLock。
推薦兩篇 AQS 原理和相關(guān)源碼分析的文章:
http://www.cnblogs.com/watery...
https://www.cnblogs.com/cheng...
5.3 AQS 組件總結(jié)Semaphore(信號量)-允許多個(gè)線程同時(shí)訪問: synchronized 和 ReentrantLock 都是一次只允許一個(gè)線程訪問某個(gè)資源,Semaphore(信號量)可以指定多個(gè)線程同時(shí)訪問某個(gè)資源。
CountDownLatch (倒計(jì)時(shí)器): CountDownLatch是一個(gè)同步工具類,用來協(xié)調(diào)多個(gè)線程之間的同步。這個(gè)工具通常用來控制線程等待,它可以讓某一個(gè)線程等待直到倒計(jì)時(shí)結(jié)束,再開始執(zhí)行。
CyclicBarrier(循環(huán)柵欄): CyclicBarrier 和 CountDownLatch 非常類似,它也可以實(shí)現(xiàn)線程間的技術(shù)等待,但是它的功能比 CountDownLatch 更加復(fù)雜和強(qiáng)大。主要應(yīng)用場景和 CountDownLatch 類似。CyclicBarrier 的字面意思是可循環(huán)使用(Cyclic)的屏障(Barrier)。它要做的事情是,讓一組線程到達(dá)一個(gè)屏障(也可以叫同步點(diǎn))時(shí)被阻塞,直到最后一個(gè)線程到達(dá)屏障時(shí),屏障才會(huì)開門,所有被屏障攔截的線程才會(huì)繼續(xù)干活。CyclicBarrier默認(rèn)的構(gòu)造方法是 CyclicBarrier(int parties),其參數(shù)表示屏障攔截的線程數(shù)量,每個(gè)線程調(diào)用await方法告訴 CyclicBarrier 我已經(jīng)到達(dá)了屏障,然后當(dāng)前線程被阻塞。
關(guān)于AQS這部分的更多內(nèi)容可以查看我的這篇文章:并發(fā)編程面試必備:AQS 原理以及 AQS 同步組件總結(jié)
Reference《深入理解 Java 虛擬機(jī)》
《實(shí)戰(zhàn) Java 高并發(fā)程序設(shè)計(jì)》
《Java并發(fā)編程的藝術(shù)》
http://www.cnblogs.com/watery...
https://www.cnblogs.com/cheng...
【強(qiáng)烈推薦!非廣告!】阿里云雙11褥羊毛活動(dòng)(10.29-11.12):https://m.aliyun.com/act/team1111/#/share?params=N.FF7yxCciiM.hf47liqn 。一句話解析該次活動(dòng):新用戶低至一折購買(1核2g服務(wù)器僅8.3/月,比學(xué)生機(jī)還便宜,真的強(qiáng)烈推薦屯3年)。老用戶可以加入我的戰(zhàn)隊(duì),然后分享自己的鏈接,可以獲得紅包和25%的返現(xiàn),我們的戰(zhàn)隊(duì)目前300位新人,所以可以排進(jìn)前100,后面可以瓜分百萬現(xiàn)金(按拉新人數(shù)瓜分現(xiàn)金,拉的越多分的越多!不要自己重新開戰(zhàn)隊(duì),后面不能參與瓜分現(xiàn)金)。
你若盛開,清風(fēng)自來。 歡迎關(guān)注我的微信公眾號:“Java面試通關(guān)手冊”,一個(gè)有溫度的微信公眾號。公眾號后臺回復(fù)關(guān)鍵字“1”,可以免費(fèi)獲取一份我精心準(zhǔn)備的小禮物哦!
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/71990.html
摘要:代碼示例自定義實(shí)現(xiàn)注冊運(yùn)行和預(yù)想一樣,輸出結(jié)果為,如果移除掉注解的屬性,輸出結(jié)果為總結(jié)在大多數(shù)情況下,我們應(yīng)該避免使用任何接口,除非我們需要它們。 showImg(https://segmentfault.com/img/remote/1460000019807821?w=1920&h=1080); 通過如下前序兩篇文章: Spring Bean 生命周期之我從哪里來? Spring...
摘要:總體來說,玄武科技的真的很熱情,為他們點(diǎn)個(gè)贊,雖然自己最后沒能去玄武科技,然后就是技術(shù)面非常簡單,面和高管面也都還好,不會(huì)有壓抑的感覺,總體聊得很愉快。 該文已加入開源文檔:JavaGuide(一份涵蓋大部分Java程序員所需要掌握的核心知識)。地址:https://github.com/Snailclimb... 秋招歷程流水賬總結(jié) 筆主大四準(zhǔn)畢業(yè)生,在秋招末流比較幸運(yùn)地進(jìn)入了一家...
摘要:最終能和面試官聊的開心愉快投緣的叫面霸。能夠與很好的集成提供映射標(biāo)簽,支持對象與數(shù)據(jù)庫的字段關(guān)系映射提供對象關(guān)系映射標(biāo)簽,支持對象關(guān)系組件維護(hù)。使用可以有效的防止注入,提高系統(tǒng)安全性。 showImg(https://segmentfault.com/img/bVbsSlt?w=358&h=269); 一、概述 面試,難還是不難?取決于面試者的底蘊(yùn)(氣場+技能)、心態(tài)和認(rèn)知及溝通技巧。...
摘要:又是金三銀四的時(shí)候,我希望這份面試題能夠祝你一臂之力自我和項(xiàng)目相關(guān)自我介紹你覺得自己的優(yōu)點(diǎn)是你覺得自己有啥缺點(diǎn)你有哪些你為什么要離開上家公司你上家公司在,我們公司在,離這么遠(yuǎn)為什么要選擇我們這里上家公司的同事和領(lǐng)導(dǎo)是怎么評價(jià)你的介紹下你的上 又是金三銀四的時(shí)候,我希望這份面試題能夠祝你一臂之力! 自我和項(xiàng)目相關(guān) 1、自我介紹 2、你覺得自己的優(yōu)點(diǎn)是?你覺得自己有啥缺點(diǎn)? 3、你有哪些 ...
閱讀 2978·2021-11-25 09:43
閱讀 3600·2021-11-24 11:13
閱讀 3373·2021-10-14 09:42
閱讀 2578·2021-09-23 11:53
閱讀 3622·2021-09-22 15:57
閱讀 3233·2021-09-02 09:54
閱讀 3510·2019-08-30 13:47
閱讀 1650·2019-08-29 16:55