在Java內(nèi)存模型中測試并發(fā)程序代碼
讓我們來看看這段代碼:
import java.util.BitSet; import java.util.concurrent.CountDownLatch; public class AnExample { public static void main(String[] args) throws Exception { BitSet bs = new BitSet(); CountDownLatch latch = new CountDownLatch(1); Thread t1 = new Thread(new Runnable() { public void run() { try { latch.await(); Thread.sleep(1000); } catch (Exception ex) { } bs.set(1); } }); Thread t2 = new Thread(new Runnable() { public void run() { try { latch.await(); Thread.sleep(1000); } catch (Exception e) { } bs.set(2); } }); t1.start(); t2.start(); latch.countDown(); t1.join(); t2.join(); // crucial part here: System.out.println(bs.get(1)); System.out.println(bs.get(2)); } }
問題來了,這段代碼輸出的結(jié)果是什么呢?它究竟能輸出什么結(jié)果,上面的程序即使在崩潰的JVM上,仍然允許打印輸出什么結(jié)果呢?
讓我們來看看這個程序做了什么:
- 初始化了一個BitSet對象
- 兩個線程并行運(yùn)行,分別對第一和第二位的字段值設(shè)置為true
- 我們嘗試讓這兩個線程同時運(yùn)行。
- 讀取BitSet對象的值,然后輸出結(jié)果。
接下來,我們需要構(gòu)造一些測試用例來檢查這些行為。顯然,其中一個只能運(yùn)行該例子,然后觀察結(jié)果,回答上面的問題,可是,回答第二個關(guān)于允許輸出的結(jié)果,需要些技巧。
熟能生巧
幸運(yùn)的是,我們可以使用工具。 JCStress 就是一個為了解決這類問題而產(chǎn)生的測試工具。
我們可以很容易地將我們的test case寫成JCStress可以識別的形式。事實上, 它已經(jīng)為我們準(zhǔn)備好了多種可能情況下的接口。我們需要一個例子,在這個例子中,2個線程并發(fā)地執(zhí)行,執(zhí)行的結(jié)果表示為2個布爾值。
我們使用一個Actor2_Arbiter1_Test<BitSet, BooleanResult2>接口, 它將為我們的2個線程提供一些方法塊和一個轉(zhuǎn)換方法,這個轉(zhuǎn)換方法將表示BitSet狀態(tài)的結(jié)果轉(zhuǎn)換成一對布爾值。我們需要找個 Java 8 JVM 來運(yùn)行它, 但是現(xiàn)在這已經(jīng)不是什么問題了.
看下面的實現(xiàn). 是不是特別簡潔?
public class AnExampleTest implements Actor2_Arbiter1_Test<BitSet, BooleanResult2> { @Override public void actor1(BitSet s, BooleanResult2 r) { s.set(1); } @Override public void actor2(BitSet s, BooleanResult2 r) { s.set(2); } @Override public void arbiter1(BitSet s, BooleanResult2 r) { r.r1 = s.get(1); r.r2 = s.get(2); } @Override public BitSet newState() { return new BitSet(); } @Override public BooleanResult2 newResult() { return new BooleanResult2(); } }
現(xiàn)在在運(yùn)行這個測試的時候,控制會去嘗試各種花樣以求獲取驅(qū)動這些動作的因素的所有可能組合: 并行的或者非并行的, 有和無負(fù)載檢測的, 還有一行中進(jìn)行許多許多次, 因此所有可能的結(jié)果都會被記錄到.
當(dāng)你想知道你的并行代碼是如何運(yùn)作的時候,這是比靠你自己去挖空心思想出所有細(xì)節(jié)更勝一籌的辦法.
此外,為了能利用到JCStress 約束帶來的全面性的便利,我們需要給它提供一個對可能結(jié)果的解釋. 要那樣做的話我們就需要使用如下所示的一個簡單的XML文件.
<test name="org.openjdk.jcstress.tests.custom.AnExampleTest"> <contributed-by>Oleg Shelajev</contributed-by> <description> Tests if BitSet works well without synchronization. </description> <case> <match>[true, true]</match> <expect>ACCEPTABLE</expect> <description> Seeing all updates intact. </description> </case> <case> <match>[true, false]</match> <expect>ACCEPTABLE_INTERESTING</expect> <description> T2 overwrites T1 result. </description> </case> <case> <match>[false, true]</match> <expect>ACCEPTABLE_INTERESTING</expect> <description> T1 overwrites T2 result. </description> </case> <unmatched> <expect>FORBIDDEN</expect> <description> All other cases are unexpected. </description> </unmatched> </test>
現(xiàn)在,我們已經(jīng)準(zhǔn)備好讓這頭野獸開始咆哮了. 通過使用下面的命令行運(yùn)行測試.
java -XX:+UnlockDiagnosticVMOptions -XX:+WhiteBoxAPI -XX:-RestrictContended -jar tests-custom/target/jcstress.jar -t=".*AnExampleTest"
而我們所得到的結(jié)果是一份優(yōu)雅的報告.
現(xiàn)在很清楚的是,我們不僅可以得到預(yù)期的結(jié)果,即兩個線程都已經(jīng)設(shè)置了它們的位,也遇到了一個競爭條件,一個線程將覆蓋另一個線程的結(jié)果。
即使你看到發(fā)生了這種事情,也一定要有“山人自有妙計”的淡定心態(tài),不是嗎?
順便說一下,如果你在思考如何修改這個代碼,答案是仔細(xì)閱讀 Javadoc 中的 BitSet 類,并意識到那并非是線程安全的,需要外部同步。這可以很容易地通過增加同步塊相關(guān)設(shè)定值來實現(xiàn)。
synchronized (bs) { bs.set(1); }
- 淺析Java內(nèi)存模型與垃圾回收
- Java 高并發(fā)三:Java內(nèi)存模型和線程安全詳解
- Java8內(nèi)存模型PermGen Metaspace實例解析
- Java內(nèi)存模型JMM詳解
- Java內(nèi)存模型與JVM運(yùn)行時數(shù)據(jù)區(qū)的區(qū)別詳解
- Java內(nèi)存區(qū)域和內(nèi)存模型講解
- Java內(nèi)存模型之happens-before概念詳解
- Java內(nèi)存模型(JMM)及happens-before原理
- 細(xì)談java同步之JMM(Java Memory Model)
- 學(xué)習(xí)Java內(nèi)存模型JMM心得
- JAVA內(nèi)存模型(JMM)詳解
相關(guān)文章
Hibernate對數(shù)據(jù)庫刪除、查找、更新操作實例代碼
本篇文章主要介紹了Hibernate對數(shù)據(jù)庫刪除、查找、更新操作實例代碼,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-05-05Java8函數(shù)式接口Predicate用法示例詳解
這篇文章主要為大家介紹了Java8函數(shù)式接口Predicate用法示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-07-07Intellij IDEA 關(guān)閉和開啟自動更新的提示?
這篇文章主要介紹了Intellij IDEA 關(guān)閉和開啟自動更新的提示操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04使用Java實現(xiàn)系統(tǒng)托盤功能的介紹(附源碼以及截圖)
本篇文章介紹了,在Java中實現(xiàn)系統(tǒng)托盤功能的詳解,文中附源碼以及截圖介紹。需要的朋友參考下2013-05-05教你使用Java獲取當(dāng)前時間戳的詳細(xì)代碼
這篇文章主要介紹了如何使用Java獲取當(dāng)前時間戳,通過兩個java示例,向大家展示如何獲取java中的當(dāng)前時間戳,文本通過示例代碼給大家展示了java獲取當(dāng)前時間戳的方法,需要的朋友可以參考下2022-01-01springboot中RabbitMQ死信隊列的實現(xiàn)示例
死信隊列是一種特殊的消息隊列,用來存儲無法被正常消費(fèi)的消息,常被用來實現(xiàn)延遲處理,異常消息處理等,本文主要介紹了springboot中RabbitMQ死信隊列的實現(xiàn)示例,感興趣的可以了解一下2024-01-01