Java并發(fā)編程(六)volatile關(guān)鍵字解析
由于volatile關(guān)鍵字是與Java的內(nèi)存模型有關(guān)的,因此在講述volatile關(guān)鍵之前,我們先來(lái)了解一下與內(nèi)存模型相關(guān)的概念和知識(shí)。
一.內(nèi)存模型的相關(guān)概念
Java內(nèi)存模型規(guī)定所有的變量都是存在主存當(dāng)中,每個(gè)線程都有自己的工作內(nèi)存。線程對(duì)變量的所有操作都必須在工作內(nèi)存中進(jìn)行,而不能直接對(duì)主存進(jìn)行操作。并且每個(gè)線程不能訪問(wèn)其他線程的工作內(nèi)存。
在java中,執(zhí)行下面這個(gè)語(yǔ)句:
int i=3;
執(zhí)行線程必須先在自己的工作線程中對(duì)變量i所在的緩存行進(jìn)行賦值操作,然后再寫(xiě)入主存當(dāng)中。而不是直接將數(shù)值3寫(xiě)入主存當(dāng)中。 =====緩存不一致的問(wèn)題
詳解:http://www.rzrgm.cn/dolphin0520/p/3920373.html
二.原子性,可見(jiàn)性和有序性
1.原子性
原子性:即一個(gè)操作或者多個(gè)操作 要么全部執(zhí)行并且執(zhí)行的過(guò)程不會(huì)被任何因素打斷,要么就都不執(zhí)行。
對(duì)基本數(shù)據(jù)類型的變量的讀取和賦值操作是原子性操作,即這些操作是不可被中斷的,要么執(zhí)行,要么不執(zhí)行。
i = 9;
假若一個(gè)線程執(zhí)行到這個(gè)語(yǔ)句時(shí),我暫且假設(shè)為一個(gè)32位的變量賦值包括兩個(gè)過(guò)程:為低16位賦值,為高16位賦值。
那么就可能發(fā)生一種情況:當(dāng)將低16位數(shù)值寫(xiě)入之后,突然被中斷,而此時(shí)又有一個(gè)線程去讀取i的值,那么讀取到的就是錯(cuò)誤的數(shù)據(jù)。
java.util.concurrent.atomic包中有很多類使用了很高效的機(jī)器級(jí)指令(而不是使用鎖)來(lái)保證其他操作的原子性。例如AtomicInteger類提供了方法incrementAndGet和decrementAndGet,它們分別以原子方式將一個(gè)整數(shù)自增和自減。可以安全地使用AtomicInteger類作為共享計(jì)數(shù)器而無(wú)需同步。
另外這個(gè)包還包含AtomicBoolean,AtomicLong和AtomicReference這些原子類僅供開(kāi)發(fā)并發(fā)工具的系統(tǒng)程序員使用,應(yīng)用程序員不應(yīng)該使用這些類。
2.可見(jiàn)性
可見(jiàn)性是指當(dāng)多個(gè)線程訪問(wèn)同一個(gè)變量時(shí),一個(gè)線程修改了這個(gè)變量的值,其他線程能夠立即看得到修改的值。
舉個(gè)簡(jiǎn)單的例子,看下面這段代碼:
//線程1執(zhí)行的代碼 int i = 0; i = 10; //線程2執(zhí)行的代碼 j = i; 假若執(zhí)行線程1的是CPU1,執(zhí)行線程2的是CPU2。由上面的分析可知,當(dāng)線程1執(zhí)行 i =10這句時(shí),會(huì)先把i的初始值加載到CPU1的高速緩存中,然后賦值為10,那么在CPU1的高速緩存當(dāng)中i的值變?yōu)?0了,卻沒(méi)有立即寫(xiě)入到主存當(dāng)中。 此時(shí)線程2執(zhí)行 j = i,它會(huì)先去主存讀取i的值并加載到CPU2的緩存當(dāng)中,注意此時(shí)內(nèi)存當(dāng)中i的值還是0,那么就會(huì)使得j的值為0,而不是10. 這就是可見(jiàn)性問(wèn)題,線程1對(duì)變量i修改了之后,線程2沒(méi)有立即看到線程1修改的值。
3.有序性
有序性:即程序執(zhí)行的順序按照代碼的先后順序執(zhí)行。
舉個(gè)簡(jiǎn)單的例子,看下面這段代碼:
int i = 0; boolean flag = false; i = 1; //語(yǔ)句1 flag = true; //語(yǔ)句2 上面代碼定義了一個(gè)int型變量,定義了一個(gè)boolean類型變量,然后分別對(duì)兩個(gè)變量進(jìn)行賦值操作。從代碼順序上看,語(yǔ)句1是在語(yǔ)句2前面的,那么JVM在真正執(zhí)行這段代碼的時(shí)候會(huì)保證語(yǔ)句1一定會(huì)在語(yǔ)句2前面執(zhí)行嗎?不一定,為什么呢?這里可能會(huì)發(fā)生指令重排序(Instruction Reorder)。 下面解釋一下什么是指令重排序,一般來(lái)說(shuō),處理器為了提高程序運(yùn)行效率,可能會(huì)對(duì)輸入代碼進(jìn)行優(yōu)化,它不保證程序中各個(gè)語(yǔ)句的執(zhí)行先后順序同代碼中的順序一致,但是它會(huì)保證程序最終執(zhí)行結(jié)果和代碼順序執(zhí)行的結(jié)果是一致的。 比如上面的代碼中,語(yǔ)句1和語(yǔ)句2誰(shuí)先執(zhí)行對(duì)最終的程序結(jié)果并沒(méi)有影響,那么就有可能在執(zhí)行過(guò)程中,語(yǔ)句2先執(zhí)行而語(yǔ)句1后執(zhí)行。
但是要注意,雖然處理器會(huì)對(duì)指令進(jìn)行重排序,但是它會(huì)保證程序最終結(jié)果會(huì)和代碼順序執(zhí)行結(jié)果相同,那么它靠什么保證的呢?再看下面一個(gè)例子:
int a = 10; //語(yǔ)句1 int r = 2; //語(yǔ)句2 a = a + 3; //語(yǔ)句3 r = a*a; //語(yǔ)句4 這段代碼有4個(gè)語(yǔ)句,那么可能的一個(gè)執(zhí)行順序是: 語(yǔ)句2 語(yǔ)句1 語(yǔ)句3 語(yǔ)句4 那么可不可能是這個(gè)執(zhí)行順序呢: 語(yǔ)句2 語(yǔ)句1 語(yǔ)句4 語(yǔ)句3 不可能,因?yàn)樘幚砥髟谶M(jìn)行重排序時(shí)是會(huì)考慮指令之間的數(shù)據(jù)依賴性,如果一個(gè)指令I(lǐng)nstruction 2必須用到Instruction 1的結(jié)果,那么處理器會(huì)保證Instruction 1會(huì)在Instruction 2之前執(zhí)行。
雖然重排序不會(huì)影響單個(gè)線程內(nèi)程序執(zhí)行的結(jié)果,但是多線程呢?下面看一個(gè)例子:
//線程1: context = loadContext(); //語(yǔ)句1 inited = true; //語(yǔ)句2 //線程2: while(!inited ){ sleep() } doSomethingwithconfig(context); 上面代碼中,由于語(yǔ)句1和語(yǔ)句2沒(méi)有數(shù)據(jù)依賴性,因此可能會(huì)被重排序。假如發(fā)生了重排序,在線程1執(zhí)行過(guò)程中先執(zhí)行語(yǔ)句2,而此是線程2會(huì)以為初始化工作已經(jīng)完成,那么就會(huì)跳出while循環(huán),去執(zhí)行doSomethingwithconfig(context)方法,而此時(shí)context并沒(méi)有被初始化,就會(huì)導(dǎo)致程序出錯(cuò)。
從上面可以看出,指令重排序不會(huì)影響單個(gè)線程的執(zhí)行,但是會(huì)影響到線程并發(fā)執(zhí)行的正確性。
也就是說(shuō),要想并發(fā)程序正確地執(zhí)行,必須要保證原子性、可見(jiàn)性以及有序性。只要有一個(gè)沒(méi)有被保證,就有可能會(huì)導(dǎo)致程序運(yùn)行不正確。
三.深入剖析volatile關(guān)鍵字
1.volatile關(guān)鍵字的兩層語(yǔ)義
一旦一個(gè)共享變量(類的成員變量、類的靜態(tài)成員變量)被volatile修飾之后,那么就具備了兩層語(yǔ)義:
1)保證了不同線程對(duì)這個(gè)變量進(jìn)行操作時(shí)的可見(jiàn)性,即一個(gè)線程修改了某個(gè)變量的值,這新值對(duì)其他線程來(lái)說(shuō)是立即可見(jiàn)的。
2)禁止進(jìn)行指令重排序。
先看一段代碼,假如線程1先執(zhí)行,線程2后執(zhí)行: //線程1 boolean stop = false; while(!stop){ doSomething(); } //線程2 stop = true; 很多人在中斷線程時(shí)可能都會(huì)采用這種標(biāo)記辦法。但是事實(shí)上,這段代碼會(huì)完全運(yùn)行正確么?即一定會(huì)將線程中斷么?不一定,也許在大多數(shù)時(shí)候,這個(gè)代碼能夠把線程中斷,但是也有可能會(huì)導(dǎo)致無(wú)法中斷線程(雖然這個(gè)可能性很小,但是只要一旦發(fā)生這種情況就會(huì)造成死循環(huán)了)。 為何有可能導(dǎo)致無(wú)法中斷線程?每個(gè)線程在運(yùn)行過(guò)程中都有自己的工作內(nèi)存,那么線程1在運(yùn)行的時(shí)候,會(huì)將stop變量的值拷貝一份放在自己的工作內(nèi)存當(dāng)中。那么當(dāng)線程2更改了stop變量的值之后,但是還沒(méi)來(lái)得及寫(xiě)入主存當(dāng)中,線程2轉(zhuǎn)去做其他事情了,那么線程1由于不知道線程2對(duì)stop變量的更改,因此還會(huì)一直循環(huán)下去。
但是用volatile修飾之后就變得不一樣了:
- 使用volatile關(guān)鍵字會(huì)強(qiáng)制將修改的值立即寫(xiě)入主存;
- 使用volatile關(guān)鍵字的話,當(dāng)線程2進(jìn)行修改時(shí),會(huì)導(dǎo)致線程1的工作內(nèi)存中緩存變量stop的緩存行無(wú)效;
- 由于線程1的工作內(nèi)存中緩存變量stop的緩存行無(wú)效,所以線程1再次讀取變量stop的值時(shí)會(huì)去主存讀取。
2.volatile保證原子性嗎?
從上面知道volatile關(guān)鍵字保證了操作的可見(jiàn)性,但是volatile能保證對(duì)變量的操作是原子性嗎?
public class Test { public volatile int inc = 0; public void increase() { inc++; } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保證前面的線程都執(zhí)行完 Thread.yield(); System.out.println(test.inc); } } 這段代碼每次運(yùn)行結(jié)果都不一致,都是一個(gè)小于10000的數(shù)字,在前面已經(jīng)提到過(guò),自增操作是不具備原子性的,它包括讀取變量的原始值、進(jìn)行加1操作、寫(xiě)入工作內(nèi)存。那么就是說(shuō)自增操作的三個(gè)子操作可能會(huì)分割開(kāi)執(zhí)行。 假如某個(gè)時(shí)刻變量inc的值為10,線程1對(duì)變量進(jìn)行自增操作,線程1先讀取了變量inc的原始值,然后線程1被阻塞了;然后線程2對(duì)變量進(jìn)行自增操作,線程2也去讀取變量inc的原始值,由于線程1只是對(duì)變量inc進(jìn)行讀取操作,而沒(méi)有對(duì)變量進(jìn)行修改操作,所以不會(huì)導(dǎo)致線程2的工作內(nèi)存中緩存變量inc的緩存行無(wú)效,所以線程2會(huì)直接去主存讀取inc的值,發(fā)現(xiàn)inc的值時(shí)10,然后進(jìn)行加1操作,并把11寫(xiě)入工作內(nèi)存,最后寫(xiě)入主存。然后線程1接著進(jìn)行加1操作,由于已經(jīng)讀取了inc的值,注意此時(shí)在線程1的工作內(nèi)存中inc的值仍然為10,所以線程1對(duì)inc進(jìn)行加1操作后inc的值為11,然后將11寫(xiě)入工作內(nèi)存,最后寫(xiě)入主存。那么兩個(gè)線程分別進(jìn)行了一次自增操作后,inc只增加了1。 自增操作不是原子性操作,而且volatile也無(wú)法保證對(duì)變量的任何操作都是原子性的。
把上面的代碼改成以下任何一種都可以達(dá)到效果:
①采用synchronized:
public class Test { public int inc = 0; public synchronized void increase() { inc++; } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保證前面的線程都執(zhí)行完 Thread.yield(); System.out.println(test.inc); } }
②采用Lock:
public class Test { public int inc = 0; Lock lock = new ReentrantLock(); public void increase() { lock.lock(); try { inc++; } finally{ lock.unlock(); } } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保證前面的線程都執(zhí)行完 Thread.yield(); System.out.println(test.inc); } }
③采用AtomicInteger:
public class Test { public AtomicInteger inc = new AtomicInteger(); public void increase() { inc.getAndIncrement(); } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保證前面的線程都執(zhí)行完 Thread.yield(); System.out.println(test.inc); } }
在java 1.5的java.util.concurrent.atomic包下提供了一些原子操作類,即對(duì)基本數(shù)據(jù)類型的 自增(加1操作),自減(減1操作)、以及加法操作(加一個(gè)數(shù)),減法操作(減一個(gè)數(shù))進(jìn)行了封裝,保證這些操作是原子性操作。atomic是利用CAS來(lái)實(shí)現(xiàn)原子性操作的(Compare And Swap),CAS實(shí)際上是利用處理器提供的CMPXCHG指令實(shí)現(xiàn)的,而處理器執(zhí)行CMPXCHG指令是一個(gè)原子性操作。
3.volatile能保證有序性嗎?
在前面提到volatile關(guān)鍵字能禁止指令重排序,所以volatile能在一定程度上保證有序性。
volatile關(guān)鍵字禁止指令重排序有兩層意思:
1)當(dāng)程序執(zhí)行到volatile變量的讀操作或者寫(xiě)操作時(shí),在其前面的操作的更改肯定全部已經(jīng)進(jìn)行,且結(jié)果已經(jīng)對(duì)后面的操作可見(jiàn);在其后面的操作肯定還沒(méi)有進(jìn)行;
2)在進(jìn)行指令優(yōu)化時(shí),不能將在對(duì)volatile變量訪問(wèn)的語(yǔ)句放在其后面執(zhí)行,也不能把volatile變量后面的語(yǔ)句放到其前面執(zhí)行。
可能上面說(shuō)的比較繞,舉個(gè)簡(jiǎn)單的例子: //x、y為非volatile變量 //flag為volatile變量 x = 2; //語(yǔ)句1 y = 0; //語(yǔ)句2 flag = true; //語(yǔ)句3 x = 4; //語(yǔ)句4 y = -1; //語(yǔ)句5 由于flag變量為volatile變量,那么在進(jìn)行指令重排序的過(guò)程的時(shí)候,不會(huì)將語(yǔ)句3放到語(yǔ)句1、語(yǔ)句2前面,也不會(huì)講語(yǔ)句3放到語(yǔ)句4、語(yǔ)句5后面。但是要注意語(yǔ)句1和語(yǔ)句2的順序、語(yǔ)句4和語(yǔ)句5的順序是不作任何保證的。 并且volatile關(guān)鍵字能保證,執(zhí)行到語(yǔ)句3時(shí),語(yǔ)句1和語(yǔ)句2必定是執(zhí)行完畢了的,且語(yǔ)句1和語(yǔ)句2的執(zhí)行結(jié)果對(duì)語(yǔ)句3、語(yǔ)句4、語(yǔ)句5是可見(jiàn)的。 ================================================= 那么我們回到前面舉的一個(gè)例子: //線程1: context = loadContext(); //語(yǔ)句1 inited = true; //語(yǔ)句2 //線程2: while(!inited ){ sleep() } doSomethingwithconfig(context); 前面舉這個(gè)例子的時(shí)候,提到有可能語(yǔ)句2會(huì)在語(yǔ)句1之前執(zhí)行,那么久可能導(dǎo)致context還沒(méi)被初始化,而線程2中就使用未初始化的context去進(jìn)行操作,導(dǎo)致程序出錯(cuò)。 這里如果用volatile關(guān)鍵字對(duì)inited變量進(jìn)行修飾,就不會(huì)出現(xiàn)這種問(wèn)題了,因?yàn)楫?dāng)執(zhí)行到語(yǔ)句2時(shí),必定能保證context已經(jīng)初始化完畢。
4.volatile的原理和實(shí)現(xiàn)機(jī)制
前面講述了源于volatile關(guān)鍵字的一些使用,下面我們來(lái)探討一下volatile到底如何保證可見(jiàn)性和禁止指令重排序的。
下面這段話摘自《深入理解Java虛擬機(jī)》:
“觀察加入volatile關(guān)鍵字和沒(méi)有加入volatile關(guān)鍵字時(shí)所生成的匯編代碼發(fā)現(xiàn),加入volatile關(guān)鍵字時(shí),會(huì)多出一個(gè)lock前綴指令”
lock前綴指令實(shí)際上相當(dāng)于一個(gè)內(nèi)存屏障(也成內(nèi)存柵欄),內(nèi)存屏障會(huì)提供3個(gè)功能:
1)它確保指令重排序時(shí)不會(huì)把其后面的指令排到內(nèi)存屏障之前的位置,也不會(huì)把前面的指令排到內(nèi)存屏障的后面;即在執(zhí)行到內(nèi)存屏障這句指令時(shí),在它前面的操作已經(jīng)全部完成;
2)它會(huì)強(qiáng)制將對(duì)緩存的修改操作立即寫(xiě)入主存;
3)如果是寫(xiě)操作,它會(huì)導(dǎo)致其他CPU中對(duì)應(yīng)的緩存行無(wú)效。
五.使用volatile關(guān)鍵字的場(chǎng)景
synchronized關(guān)鍵字是防止多個(gè)線程同時(shí)執(zhí)行一段代碼,那么就會(huì)很影響程序執(zhí)行效率,而volatile關(guān)鍵字在某些情況下性能要優(yōu)于synchronized,但是要注意volatile關(guān)鍵字是無(wú)法替代synchronized關(guān)鍵字的,因?yàn)関olatile關(guān)鍵字無(wú)法保證操作的原子性。通常來(lái)說(shuō),使用volatile必須具備以下2個(gè)條件:
1)對(duì)變量的寫(xiě)操作不依賴于當(dāng)前值
2)該變量沒(méi)有包含在具有其他變量的不變式中
第一個(gè)條件就是不能是自增自減等操作,上文已經(jīng)提到volatile不保證原子性。 第二個(gè)條件我們來(lái)舉個(gè)例子它包含了一個(gè)不變式 :下界總是小于或等于上界 public class NumberRange { private volatile int lower, upper; public int getLower() { return lower; } public int getUpper() { return upper; } public void setLower(int value) { if (value > upper) throw new IllegalArgumentException(...); lower = value; } public void setUpper(int value) { if (value < lower) throw new IllegalArgumentException(...); upper = value; } } 這種方式限制了范圍的狀態(tài)變量,因此將 lower 和 upper 字段定義為 volatile 類型不能夠充分實(shí)現(xiàn)類的線程安全,從而仍然需要使用同步。否則,如果湊巧兩個(gè)線程在同一時(shí)間使用不一致的值執(zhí)行 setLower 和 setUpper 的話,則會(huì)使范圍處于不一致的狀態(tài)。例如,如果初始狀態(tài)是 (0, 5),同一時(shí)間內(nèi),線程 A 調(diào)用 setLower(4) 并且線程 B 調(diào)用 setUpper(3),顯然這兩個(gè)操作交叉存入的值是不符合條件的,那么兩個(gè)線程都會(huì)通過(guò)用于保護(hù)不變式的檢查,使得最后的范圍值是 (4, 3),這顯然是不對(duì)的。
其實(shí)就是要保證操作的原子性就可以使用volatile,使用volatile主要有兩個(gè)場(chǎng)景:
①狀態(tài)標(biāo)志
volatile boolean shutdownRequested; ... public void shutdown() { shutdownRequested = true; } public void doWork() { while (!shutdownRequested) { // do stuff } } 很可能會(huì)從循環(huán)外部調(diào)用 shutdown() 方法 —— 即在另一個(gè)線程中 —— 因此,需要執(zhí)行某種同步來(lái)確保正確實(shí)現(xiàn) shutdownRequested 變量的可見(jiàn)性。然而,使用 synchronized 塊編寫(xiě)循環(huán)要比使用volatile 狀態(tài)標(biāo)志編寫(xiě)麻煩很多。由于 volatile 簡(jiǎn)化了編碼,并且狀態(tài)標(biāo)志并不依賴于程序內(nèi)任何其他狀態(tài),因此此處非常適合使用 volatile。
②雙重檢查模式 (DCL)
public class Singleton { private volatile static Singleton instance = null; public static Singleton getInstance() { if (instance == null) { synchronized(this) { if (instance == null) { instance = new Singleton(); } } } return instance; } } 在這里使用volatile會(huì)或多或少的影響性能,但考慮到程序的正確性,犧牲這點(diǎn)性能還是值得的。 DCL優(yōu)點(diǎn)是資源利用率高,第一次執(zhí)行g(shù)etInstance時(shí)單例對(duì)象才被實(shí)例化,效率高。缺點(diǎn)是第一次加載時(shí)反應(yīng)稍慢一些,在高并發(fā)環(huán)境下也有一定的缺陷,雖然發(fā)生的概率很小。 DCL雖然在一定程度解決了資源的消耗和多余的同步,線程安全等問(wèn)題,但是他還是在某些情況會(huì)出現(xiàn)失效的問(wèn)題,也就是DCL失效,在《java并發(fā)編程實(shí)踐》一書(shū)建議用以下的代碼(靜態(tài)內(nèi)部類單例模式)來(lái)替代DCL: public class Singleton { private Singleton(){ } public static Singleton getInstance(){ return SingletonHolder.sInstance; } private static class SingletonHolder { private static final Singleton sInstance = new Singleton(); } }
關(guān)于雙重檢查可以查看http://blog.csdn.net/dl88250/article/details/5439024
六. 總結(jié)
與鎖相比,Volatile 變量是一種非常簡(jiǎn)單但同時(shí)又非常脆弱的同步機(jī)制,它在某些情況下將提供優(yōu)于鎖的性能和伸縮性。如果嚴(yán)格遵循 volatile 的使用條件即變量真正獨(dú)立于其他變量和自己以前的值 ,在某些情況下可以使用 volatile 代替 synchronized 來(lái)簡(jiǎn)化代碼。然而,使用 volatile 的代碼往往比使用鎖的代碼更加容易出錯(cuò)。本文介紹了可以使用 volatile 代替 synchronized 的最常見(jiàn)的兩種用例,其他的情況我們最好還是去使用synchronized 。
posted on 2016-12-05 00:15 安卓筆記俠 閱讀(535) 評(píng)論(2) 收藏 舉報(bào)
浙公網(wǎng)安備 33010602011771號(hào)