這篇文章主要介紹“Java基礎(chǔ)之volatile應(yīng)用實(shí)例分析”,在日常操作中,相信很多人在Java基礎(chǔ)之volatile應(yīng)用實(shí)例分析問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”Java基礎(chǔ)之volatile應(yīng)用實(shí)例分析”的疑惑有所幫助!接下來,請跟著小編一起來學(xué)習(xí)吧!
網(wǎng)站建設(shè)哪家好,找成都創(chuàng)新互聯(lián)公司!專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了張掖免費(fèi)建站歡迎大家使用!
問:請談?wù)勀銓olatile的理解?
答:volatile是Java虛擬機(jī)提供的輕量級的同步機(jī)制,它有3個(gè)特性:
1)保證可見性
2)不保證原子性
3)禁止指令重排
剛學(xué)完java基礎(chǔ),如果有人問你什么是volatile?它有什么作用的話,相信一定非常懵逼…
可能看了答案,也完全不明白,什么是同步機(jī)制?什么是可見性?什么是原子性?什么是指令重排?
要想理解什么是可見性,首先要先理解JMM。
JMM(Java內(nèi)存模型,Java Memory Model)本身是一種抽象的概念,并不真實(shí)存在。它描述的是一組規(guī)則或規(guī)范,通過這組規(guī)范,定了程序中各個(gè)變量的訪問方法。JMM關(guān)于同步的規(guī)定:
1)線程解鎖前,必須把共享變量的值刷新回主內(nèi)存;
2)線程加鎖前,必須讀取主內(nèi)存的最新值到自己的工作內(nèi)存;
3)加鎖解鎖是同一把鎖;
由于JVM運(yùn)行程序的實(shí)體是線程,創(chuàng)建每個(gè)線程時(shí),JMM會為其創(chuàng)建一個(gè)工作內(nèi)存(有些地方稱為??臻g),工作內(nèi)存是每個(gè)線程的私有數(shù)據(jù)區(qū)域。
Java內(nèi)存模型規(guī)定所有變量都存儲在主內(nèi)存,主內(nèi)存是共享內(nèi)存區(qū)域,所有線程都可以訪問。
但線程對變量的操作(讀取、賦值等)必須在工作內(nèi)存中進(jìn)行。因此首先要將變量從主內(nèi)存拷貝到自己的工作內(nèi)存,然后對變量進(jìn)行操作,操作完成后再將變量寫會主內(nèi)存中。
看了上面對JMM的介紹,可能還是優(yōu)點(diǎn)懵,接下來用一個(gè)賣票系統(tǒng)來進(jìn)行舉例:
1)如下圖,此時(shí)賣票系統(tǒng)后端只剩下1張票,并已讀入主內(nèi)存中:ticketNum=1。
2)此時(shí)網(wǎng)絡(luò)上有多個(gè)用戶都在搶票,那么此時(shí)就有多個(gè)線程同時(shí)都在進(jìn)行買票服務(wù),假設(shè)此時(shí)有3個(gè)線程都讀入了目前的票數(shù):ticketNum=1,那么接著就會買票。
3)假設(shè)線程1先搶占到cpu的資源,先買好票,并在自己的工作內(nèi)存中將ticketNum的值改為0:ticketNum=0,然后再寫回到主內(nèi)存中。
此時(shí),線程1的用戶已經(jīng)買到票了,那么線程2,線程3此時(shí)應(yīng)該不能再繼續(xù)買票了,因此需要系統(tǒng)通知線程2,線程3,ticketNum此時(shí)已經(jīng)等于0了:ticketNum=0。如果有這樣的通知操作,你就可以理解為就具有可見性。
通過上面對JMM的介紹和舉例,可以簡單總結(jié)下。
JMM內(nèi)存模型的可見性是指,多線程訪問主內(nèi)存的某一個(gè)資源時(shí),如果某一個(gè)線程在自己的工作內(nèi)存中修改了該資源,并寫回主內(nèi)存,那么JMM內(nèi)存模型應(yīng)該要通知其他線程來從新獲取最新的資源,來保證最新資源的可見性。
在1.1中,已經(jīng)基本理解了可見性的含義,接下來用代碼來驗(yàn)證一下,volatile確實(shí)可以保證可見性。
首先先驗(yàn)證下,不使用volatile,是不是就是沒有可見性。
package com.koping.test;import java.util.concurrent.TimeUnit;class MyData{ int number = 0; public void add10() { this.number += 10; }}public class VolatileVisibilityDemo { public static void main(String[] args) { MyData myData = new MyData(); // 啟動一個(gè)線程修改myData的number,將number的值加10 new Thread( () -> { System.out.println("線程" + Thread.currentThread().getName()+"\t 正在執(zhí)行"); try{ TimeUnit.SECONDS.sleep(3); } catch (Exception e) { e.printStackTrace(); } myData.add10(); System.out.println("線程" + Thread.currentThread().getName()+"\t 更新后,number的值為" + myData.number); } ).start(); // 看一下主線程能否保持可見性 while (myData.number == 0) { // 當(dāng)上面的線程將number加10后,如果有可見性的話,那么就會跳出循環(huán); // 如果沒有可見性的話,就會一直在循環(huán)里執(zhí)行 } System.out.println("具有可見性!"); }}
運(yùn)行結(jié)果如下圖,可以看到雖然線程0已經(jīng)將number的值改為了10,但是主線程還是在循環(huán)中,因?yàn)榇藭r(shí)number不具有可見性,系統(tǒng)不會主動通知。
在上面代碼的第7行給變量number添加volatile后再次測試,如下圖,此時(shí)主線程成功退出了循環(huán),因?yàn)镴MM主動通知了主線程更新number的值了,number已經(jīng)不為0了。
理解了上面說的可見性之后,再來理解下什么叫原子性?
原子性是指不可分隔,完整性,即某個(gè)線程正在做某個(gè)業(yè)務(wù)時(shí),中間不能被分割。要么同時(shí)成功,要么同時(shí)失敗。
還是有點(diǎn)抽象,接下來舉個(gè)例子。
如下圖,創(chuàng)建了一個(gè)測試原子性的類:TestPragma。在add方法中將n加1,通過查看編譯后的代碼可以看到,n++被拆分為3個(gè)指令進(jìn)行執(zhí)行。
因此可能存在線程1正在執(zhí)行第1個(gè)指令,緊接著線程2也正在執(zhí)行第1個(gè)指令,這樣當(dāng)線程1和線程2都執(zhí)行完3個(gè)指令之后,很容易理解,此時(shí)n的值只加了1,而實(shí)際是有2個(gè)線程加了2次,因此這種情況就是不保證原子性。
在2.1中已經(jīng)進(jìn)行了舉例,可能存在2個(gè)線程執(zhí)行n++的操作,但是最終n的值卻只加了1的情況,接下來對這種情況再用代碼進(jìn)行演示下。
首先給MyData類添加一個(gè)add方法
package com.koping.test;class MyData { volatile int number = 0; public void add() { number++; }}
然后創(chuàng)建測試原子性的類:TestPragmaDemo。測試下20個(gè)線程給number各加1000次之后,number的值是否是20000。
package com.koping.test;public class TestPragmaDemo { public static void main(String[] args) { MyData myData = new MyData(); // 啟動20個(gè)線程,每個(gè)線程將myData的number值加1000次,那么理論上number值最終是20000 for (int i=0; i<20; i++) { new Thread(() -> { for (int j=0; j<1000; j++) { myData.add(); } }).start(); } // 程序運(yùn)行時(shí),模型會有主線程和守護(hù)線程。如果超過2個(gè),那就說明上面的20個(gè)線程還有沒執(zhí)行完的,就需要等待 while (Thread.activeCount()>2){ Thread.yield(); } System.out.println("number值加了20000次,此時(shí)number的實(shí)際值是:" + myData.number); }}
運(yùn)行結(jié)果如下圖,最終number的值僅為18410。
可以看到即使加了volatile,依然不保證有原子性。
上面介紹并證明了volatile不保證原子性,那如果希望保證原子性,怎么辦呢?以下提供了2種方法
方法1是在add方法上添加synchronized,這樣每次只有1個(gè)線程能執(zhí)行add方法。
結(jié)果如下圖,最終確實(shí)可以使number的值為20000,保證了原子性。
但是,實(shí)際業(yè)務(wù)邏輯方法中不可能只有只有number++這1行代碼,上面可能還有n行代碼邏輯?,F(xiàn)在為了保證number的值是20000,就把整個(gè)方法都加鎖了(其實(shí)另外那n行代碼,完全可以由多線程同時(shí)執(zhí)行的)。所以就優(yōu)點(diǎn)殺雞用牛刀,高射炮打蚊子,小題大做了。
package com.koping.test;class MyData { volatile int number = 0; public synchronized void add() { // 在n++上面可能還有n行代碼進(jìn)行邏輯處理 number++; }}
給MyData新曾一個(gè)原子整型類型的變量num,初始值為0。
package com.koping.test;import java.util.concurrent.atomic.AtomicInteger;class MyData { volatile int number = 0; volatile AtomicInteger num = new AtomicInteger(); public void add() { // 在n++上面可能還有n行代碼進(jìn)行邏輯處理 number++; num.getAndIncrement(); }}
讓num也同步加20000次。結(jié)果如下圖,可以看到,使用原子整型的num可以保證原子性,也就是number++的時(shí)候不會被搶斷。
package com.koping.test;public class TestPragmaDemo { public static void main(String[] args) { MyData myData = new MyData(); // 啟動20個(gè)線程,每個(gè)線程將myData的number值加1000次,那么理論上number值最終是20000 for (int i=0; i<20; i++) { new Thread(() -> { for (int j=0; j<1000; j++) { myData.add(); } }).start(); } // 程序運(yùn)行時(shí),模型會有主線程和守護(hù)線程。如果超過2個(gè),那就說明上面的20個(gè)線程還有沒執(zhí)行完的,就需要等待 while (Thread.activeCount()>2){ Thread.yield(); } System.out.println("number值加了20000次,此時(shí)number的實(shí)際值是:" + myData.number); System.out.println("num值加了20000次,此時(shí)number的實(shí)際值是:" + myData.num); }}
在第2節(jié)中理解了什么是原子性,現(xiàn)在要理解下什么是指令重排?
計(jì)算機(jī)在執(zhí)行程序時(shí),為了提高性能,編譯器和處理器常常會對指令進(jìn)行重排:
源代碼–>編譯器優(yōu)化重排–>指令并行重排–>內(nèi)存系統(tǒng)重排–>最終執(zhí)行指令
處理器在進(jìn)行重排時(shí),必須要考慮指令之間的數(shù)據(jù)依賴性。
單線程環(huán)境中,可以確保最終執(zhí)行結(jié)果和代碼順序執(zhí)行的結(jié)果一致。
但是多線程環(huán)境中,線程交替執(zhí)行,由于編譯器優(yōu)化重排的存在,兩個(gè)線程使用的變量能否保持一致性是無法確定的,結(jié)果無法預(yù)測。
看了上面的文字性表達(dá),然后看一個(gè)很簡單的例子。
比如下面的mySort方法,在系統(tǒng)指令重排后,可能存在以下3種語句的執(zhí)行情況:
1)1234
2)2134
3)1324
以上這3種重排結(jié)果,對最后程序的結(jié)果都不會有影響,也考慮了指令之間的數(shù)據(jù)依賴性。
public void mySort() { int x = 1; // 語句1 int y = 2; // 語句2 x = x + 3; // 語句3 y = x * x; // 語句4}
看完指令重排的簡單介紹后,然后來看下單例模式的代碼。
package com.koping.test;public class SingletonDemo { private static SingletonDemo instance = null; private SingletonDemo() { System.out.println(Thread.currentThread().getName() + "\t 執(zhí)行構(gòu)造方法SingletonDemo()"); } public static SingletonDemo getInstance() { if (instance == null) { instance = new SingletonDemo(); } return instance; } public static void main(String[] args) { // 單線程測試 System.out.println("單線程的情況測試開始"); System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance()); System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance()); System.out.println("單線程的情況測試結(jié)束\n"); }}
首先是在單線程情況下進(jìn)行測試,結(jié)果如下圖??梢钥吹剑瑯?gòu)造方法只執(zhí)行了一次,是沒有問題的。
接下來在多線程情況下進(jìn)行測試,代碼如下。
package com.koping.test;public class SingletonDemo { private static SingletonDemo instance = null; private SingletonDemo() { System.out.println(Thread.currentThread().getName() + "\t 執(zhí)行構(gòu)造方法SingletonDemo()"); } public static SingletonDemo getInstance() { if (instance == null) { instance = new SingletonDemo(); } // DCL(Double Check Lock雙端檢索機(jī)制)// if (instance == null) {// synchronized (SingletonDemo.class) {// if (instance == null) {// instance = new SingletonDemo();// }// }// } return instance; } public static void main(String[] args) { // 單線程測試// System.out.println("單線程的情況測試開始");// System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance());// System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance());// System.out.println("單線程的情況測試結(jié)束\n"); // 多線程測試 System.out.println("多線程的情況測試開始"); for (int i=1; i<=10; i++) { new Thread(() -> { SingletonDemo.getInstance(); }, String.valueOf(i)).start(); } }}
在多線程情況下的運(yùn)行結(jié)果如下圖。可以看到,多線程情況下,出現(xiàn)了構(gòu)造方法執(zhí)行了2次的情況。
在3.3中的多線程單里模式下,構(gòu)造方法執(zhí)行了兩次,因此需要進(jìn)行改進(jìn),這里使用雙端檢鎖機(jī)制:Double Check Lock, DCL。即加鎖之前和之后都進(jìn)行檢查。
package com.koping.test;public class SingletonDemo { private static SingletonDemo instance = null; private SingletonDemo() { System.out.println(Thread.currentThread().getName() + "\t 執(zhí)行構(gòu)造方法SingletonDemo()"); } public static SingletonDemo getInstance() {// if (instance == null) {// instance = new SingletonDemo();// } // DCL(Double Check Lock雙端檢鎖機(jī)制) if (instance == null) { // a行 synchronized (SingletonDemo.class) { if (instance == null) { // b行 instance = new SingletonDemo(); // c行 } } } return instance; } public static void main(String[] args) { // 單線程測試// System.out.println("單線程的情況測試開始");// System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance());// System.out.println(SingletonDemo.getInstance() == SingletonDemo.getInstance());// System.out.println("單線程的情況測試結(jié)束\n"); // 多線程測試 System.out.println("多線程的情況測試開始"); for (int i=1; i<=10; i++) { new Thread(() -> { SingletonDemo.getInstance(); }, String.valueOf(i)).start(); } }}
在多次運(yùn)行后,可以看到,在多線程情況下,此時(shí)構(gòu)造方法也只執(zhí)行1次了。
需要注意的是3.4中的DCL版的單例模式依然不是100%準(zhǔn)確的?。?!
是不是不太明白為什么3.4DCL版單例模式不是100%準(zhǔn)確的原因?
是不是不太明白在3.1講完指令重排的簡單理解后,為什么突然要講多線程的單例模式?
因?yàn)?.4DCL版單例模式可能會由于指令重排而導(dǎo)致問題,雖然該問題出現(xiàn)的可能性可能是千萬分之一,但是該代碼依然不是100%準(zhǔn)確的。如果要保證100%準(zhǔn)確,那么需要添加volatile關(guān)鍵字,添加volatile可以禁止指令重排。
接下來分析下,為什么3.4DCL版單例模式不是100%準(zhǔn)確?
查看instance = new SingletonDemo();編譯后的指令,可以分為以下3步:
1)分配對象內(nèi)存空間:memory = allocate();
2)初始化對象:instance(memory);
3)設(shè)置instance指向分配的內(nèi)存地址:instance = memory;
由于步驟2和步驟3不存在數(shù)據(jù)依賴關(guān)系,因此可能出現(xiàn)執(zhí)行132步驟的情況。
比如線程1執(zhí)行了步驟13,還沒有執(zhí)行步驟2,此時(shí)instance!=null,但是對象還沒有初始化完成;
如果此時(shí)線程2搶占到cpu,然后發(fā)現(xiàn)instance!=null,然后直接返回使用,就會發(fā)現(xiàn)instance為空,就會出現(xiàn)異常。
這就是指令重排可能導(dǎo)致的問題,因此要想保證程序100%正確就需要加volatile禁止指令重排。
在3.1中簡單介紹了下執(zhí)行重排的含義,然后通過3.2-3.5,借助單例模式來舉例說明多線程情況下,為什么要使用volatile的原因,因?yàn)榭赡艽嬖谥噶钪嘏艑?dǎo)致程序異常。
接下來就介紹下volatile能保證禁止指令重排的原理。
首先要了解一個(gè)概念:內(nèi)存屏障(Memory Barrier),又稱為內(nèi)存柵欄。它是一個(gè)CPU指令,有2個(gè)作用:
1)保證特定操作的執(zhí)行順序;
2)保證某些變量的內(nèi)存可見性;
由于編譯器和處理器都能執(zhí)行指令重排。如果在指令之間插入一條Memory Barrier則會告訴編譯器和CPU,不管什么指令都不能和這條Memory Barrier指令重排序,也就是說,通過插入內(nèi)存屏障,禁止在內(nèi)存屏障前后的指令執(zhí)行重排需優(yōu)化。
內(nèi)存屏障的另一個(gè)作用是強(qiáng)制刷出各種CPU的緩存數(shù)據(jù),因此任何CPU上的線程都能讀取到這些數(shù)據(jù)的最新版本。
到此,關(guān)于“Java基礎(chǔ)之volatile應(yīng)用實(shí)例分析”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識,請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站,小編會繼續(xù)努力為大家?guī)砀鄬?shí)用的文章!
本文標(biāo)題:Java基礎(chǔ)之volatile應(yīng)用實(shí)例分析
文章地址:http://jinyejixie.com/article18/gdpjgp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供微信小程序、定制網(wǎng)站、ChatGPT、用戶體驗(yàn)、服務(wù)器托管、網(wǎng)站設(shè)計(jì)公司
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)