1. 程式人生 > >轉: 【Java並發編程】之五:volatile變量修飾符—意料之外的問題(含代碼)

轉: 【Java並發編程】之五:volatile變量修飾符—意料之外的問題(含代碼)

功能 模式 aik 執行 方法 end bold 有變 目的

轉載請註明出處:

volatile用處說明

在JDK1.2之前,Java的內存模型實現總是從主存(即共享內存)讀取變量,是不需要進行特別的註意的。而隨著JVM的成熟和優化,現在在多線程環境下volatile關鍵字的使用變得非常重要。

在當前的Java內存模型下,線程可以把變量保存在本地內存(比如機器的寄存器)中,而不是直接在主存中進行讀寫。這就可能造成一個線程在主存中修改了一個變量的值,而另外一個線程還繼續使用它在寄存器中的變量值的拷貝,造成數據的不一致。 要解決這個問題,就需要把變量聲明為volatile(也可以使用同步,參見http://blog.csdn.net/ns_code/article/details/17288243
),這就指示JVM,這個變量是不穩定的,每次使用它都到主存中進行讀取。一般說來,多任務環境下,各任務間共享的變量都應該加volatile修飾符。
Volatile修飾的成員變量在每次被線程訪問時,都強迫從共享內存中重讀該成員變量的值。而且,當成員變量發生變化時,強迫線程將變化值回寫到共享內存。這樣在任何時刻,兩個不同的線程總是看到某個成員變量的同一個值。 Java語言規範中指出:為了獲得最佳速度,允許線程保存共享成員變量的私有拷貝,而且只當線程進入或者離開同步代碼塊時才將私有拷貝與共享內存中的原始值進行比較。 這樣當多個線程同時與某個對象交互時,就必須註意到要讓線程及時的得到共享成員變量的變化。而volatile關鍵字
就是提示JVM:對於這個成員變量不能保存它的私有拷貝,而應直接與共享成員變量交互。
volatile是一種稍弱的同步機制,在訪問volatile變量時不會執行加鎖操作,也就不會執行線程阻塞,因此volatilei變量是一種比synchronized關鍵字更輕量級的同步機制。 使用建議:在兩個或者更多的線程需要訪問的成員變量上使用volatile。當要訪問的變量已在synchronized代碼塊中,或者為常量時,沒必要使用volatile。 由於使用volatile屏蔽掉了JVM中必要的代碼優化,所以在效率上比較低,因此一定在必要時才使用此關鍵字

示例程序

下面給出一段代碼,通過其運行結果來說明使用關鍵字volatile產生的差異,但實際上遇到了意料之外的問題:

[java] view plain copy
  1. public class Volatile extends Object implements Runnable {
  2. //value變量沒有被標記為volatile
  3. private int value;
  4. //missedIt變量被標記為volatile
  5. private volatile boolean missedIt;
  6. //creationTime不需要聲明為volatile,因為代碼執行中它沒有發生變化
  7. private long creationTime;
  8. public Volatile() {
  9. value = 10;
  10. missedIt = false;
  11. //獲取當前時間,亦即調用Volatile構造函數時的時間
  12. creationTime = System.currentTimeMillis();
  13. }
  14. public void run() {
  15. print("entering run()");
  16. //循環檢查value的值是否不同
  17. while ( value < 20 ) {
  18. //如果missedIt的值被修改為true,則通過break退出循環
  19. if ( missedIt ) {
  20. //進入同步代碼塊前,將value的值賦給currValue
  21. int currValue = value;
  22. //在一個任意對象上執行同步語句,目的是為了讓該線程在進入和離開同步代碼塊時,
  23. //將該線程中的所有變量的私有拷貝與共享內存中的原始值進行比較,
  24. //從而發現沒有用volatile標記的變量所發生的變化
  25. Object lock = new Object();
  26. synchronized ( lock ) {
  27. //不做任何事
  28. }
  29. //離開同步代碼塊後,將此時value的值賦給valueAfterSync
  30. int valueAfterSync = value;
  31. print("in run() - see value=" + currValue +", but rumor has it that it changed!");
  32. print("in run() - valueAfterSync=" + valueAfterSync);
  33. break;
  34. }
  35. }
  36. print("leaving run()");
  37. }
  38. public void workMethod() throws InterruptedException {
  39. print("entering workMethod()");
  40. print("in workMethod() - about to sleep for 2 seconds");
  41. Thread.sleep(2000);
  42. //僅在此改變value的值
  43. value = 50;
  44. print("in workMethod() - just set value=" + value);
  45. print("in workMethod() - about to sleep for 5 seconds");
  46. Thread.sleep(5000);
  47. //僅在此改變missedIt的值
  48. missedIt = true;
  49. print("in workMethod() - just set missedIt=" + missedIt);
  50. print("in workMethod() - about to sleep for 3 seconds");
  51. Thread.sleep(3000);
  52. print("leaving workMethod()");
  53. }
  54. /*
  55. *該方法的功能是在要打印的msg信息前打印出程序執行到此所化去的時間,以及打印msg的代碼所在的線程
  56. */
  57. private void print(String msg) {
  58. //使用java.text包的功能,可以簡化這個方法,但是這裏沒有利用這一點
  59. long interval = System.currentTimeMillis() - creationTime;
  60. String tmpStr = " " + ( interval / 1000.0 ) + "000";
  61. int pos = tmpStr.indexOf(".");
  62. String secStr = tmpStr.substring(pos - 2, pos + 4);
  63. String nameStr = " " + Thread.currentThread().getName();
  64. nameStr = nameStr.substring(nameStr.length() - 8, nameStr.length());
  65. System.out.println(secStr + " " + nameStr + ": " + msg);
  66. }
  67. public static void main(String[] args) {
  68. try {
  69. //通過該構造函數可以獲取實時時鐘的當前時間
  70. Volatile vol = new Volatile();
  71. //稍停100ms,以讓實時時鐘稍稍超前獲取時間,使print()中創建的消息打印的時間值大於0
  72. Thread.sleep(100);
  73. Thread t = new Thread(vol);
  74. t.start();
  75. //休眠100ms,讓剛剛啟動的線程有時間運行
  76. Thread.sleep(100);
  77. //workMethod方法在main線程中運行
  78. vol.workMethod();
  79. } catch ( InterruptedException x ) {
  80. System.err.println("one of the sleeps was interrupted");
  81. }
  82. }
  83. }

按照以上的理論來分析,由於value變量不是volatile的,因此它在main線程中的改變不會被Thread-0線程(在main線程中新開啟的線程)馬上看到,因此Thread-0線程中的while循環不會直接退出,它會繼續判斷missedIt的值,由於missedIt是volatile的,當main線程中改變了missedIt時,Thread-0線程會立即看到該變化,那麽if語句中的代碼便得到了執行的機會,由於此時Thread-0依然沒有看到value值的變化,因此,currValue的值為10,繼續向下執行,進入同步代碼塊,因為進入前後要將該線程內的變量值與共享內存中的原始值對比,進行校準,因此離開同步代碼塊後,Thread-0便會察覺到value的值變為了50,那麽後面的valueAfterSync的值便為50,最後從break跳出循環,結束Thread-0線程。


意料之外的問題

但實際的執行結果如下:

技術分享

從結果中可以看出,Thread-0線程並沒有進入while循環,說明Thread-0線程在value的值發生變化後,missedIt的值發生變化前,便察覺到了value值的變化,從而退出了while循環。這與理論上的分析不符,我便嘗試註釋掉value值發生改變與missedIt值發生改變之間的線程休眠代碼Thread.sleep(5000),以確保Thread-0線程在missedIt的值發生改變前,沒有時間察覺到value值的變化。但執行的結果與上面大同小異(可能有一兩行順序不同,但依然不會打印出if語句中的輸出信息)。


問題分析

在JDK1.7~JDK1.3之間的版本上輸出結果與上面基本大同小異,只有在JDK1.2上才得到了預期的結果,即Thread-0線程中的while循環是從if語句中退出的,這說明Thread-0線程沒有及時察覺到value值的變化。

這裏需要註意:volatile是針對JIT帶來的優化,因此JDK1.2以前的版本基本不用考慮,另外,在JDK1.3.1開始,開始運用HotSpot虛擬機,用來代替JIT。因此,是不是HotSpot的問題呢?這裏需要再補充一點:

JIT或HotSpot編譯器在server模式和client模式編譯不同,server模式為了使線程運行更快,如果其中一個線程更改了變量boolean flag 的值,那麽另外一個線程會看不到,因為另外一個線程為了使得運行更快所以從寄存器或者本地cache中取值,而不是從內存中取值,那麽使用volatile後,就告訴不論是什麽線程,被volatile修飾的變量都要從內存中取值。《內存柵欄》

但看了這個帖子http://segmentfault.com/q/1010000000147713(也有人遇到同樣的問題了)說,嘗試了HotSpot的server和client兩種模式,以及JDK1.3的classic,都沒有效果,只有JDK1.2才能得到預期的結果。

哎!看來自己知識還是比較匱乏,看了下網友給出的答案,對於非volatile修飾的變量,盡管jvm的優化,會導致變量的可見性問題,但這種可見性的問題也只是在短時間內高並發的情況下發生,CPU執行時會很快刷新Cache,一般的情況下很難出現,而且出現這種問題是不可預測的,與jvm, 機器配置環境等都有關。

姑且先這麽理解吧!一點點積累。。。


正確的分析在這裏:http://blog.csdn.net/ns_code/article/details/17382679



這裏附上分析結果時參考的帖子及文章

http://segmentfault.com/q/1010000000147713

http://www.iteye.com/problems/98213

http://www.oldcaptain.cc/articles/2013/08/21/1377092100971.html

轉: 【Java並發編程】之五:volatile變量修飾符—意料之外的問題(含代碼)