關于Java 線程的一個問題

newcih

前幾天，在敲到一個代碼，碰到如下情況：

1.         @Override
   
2.                 public void run()
   
3.                 {
   
4.                         while(true)       
   
5.                         {
   
6. // 注釋句在此                        System.out.println(flag);
   
7.                                         if (flag)       
   
8.                                         {
   
9.                                                 System.out.println("flag is true");       
   
10.                                                 // 當標識位為true時，執(zhí)行到這里，轉為false
    
11.                                                 flag = false;
    
12.                                         }
    
13.                         }
    
14.                 }

復制代碼

情況是，我在外部改變flag的值，每隔0.5秒就在外部將flag設置為true。結果這段代碼中注釋句去掉注釋的話，會有"flag is true"的輸出，但是注釋加上的話，就永遠不會輸出"flag is true"
有誰可以給出個合理解釋嗎？

全部代碼如下：

1. 
   
2. class MyThread extends Thread
   
3. {
   
4.         // 設置標識位
   
5.         private boolean flag = false;
   
6.         public void setFlag()
   
7.         {
   
8.                 flag = true;       
   
9.         }
   
10.         // 線程執(zhí)行
    
11.         @Override
    
12.                 public void run()
    
13.                 {
    
14.                         while(true)       
    
15.                         {
    
16. //                                        System.out.println(flag);
    
17.                                         if (flag)       
    
18.                                         {
    
19.                                                 System.out.println("flag is true");       
    
20.                                                 // 當標識位為true時，執(zhí)行到這里，轉為false
    
21.                                                 flag = false;
    
22.                                         }
    
23.                         }
    
24.                 }
    
25. 
    
26.         public static void main(String[] args)
    
27.         {
    
28.                 MyThread t = new MyThread();
    
29.                 t.start();
    
30.                 // 每隔0.5秒設置標識位為true
    
31.                 while (true)
    
32.                 {
    
33.                         try{
    
34.                                 Thread.sleep(500);       
    
35.                         } catch (InterruptedException e)       
    
36.                         {}
    
37. 
    
38.                         t.setFlag();
    
39.                 }
    
40.         }
    
41. }
    

復制代碼

jeppeter

我只修改了一個地方就可以使你的代碼運行成功了。

1. public class MyThread extends Thread {
   
2.     [color=Red]private volatile boolean flag = false;[/color]
   
3.     public void setFlag() {
   
4.         flag = true;
   
5.     }
   
6.     // 線程執(zhí)行
   
7.     @Override
   
8.     public void run() {
   
9.         while (true) {
   
10.             if (flag) {
    
11.                 System.out.println("flag is true");
    
12.                 flag = false;
    
13.             }
    
14.         }
    
15.     }
    
16. 
    
17.     public static void main(String[] args) {
    
18.         MyThread t = new MyThread();
    
19.         t.start();
    
20.         while (true) {
    
21.             try {
    
22.                 Thread.sleep(500);
    
23.             } catch (InterruptedException e)
    
24.             {}
    
25. 
    
26.             t.setFlag();
    
27.         }
    
28.     }
    
29. }

復制代碼

jeppeter

我只修改了一個地方就可以使你的代碼運行成功了,就是flag添加了volatile屬性。

1. public class MyThread extends Thread {
   
2.     private volatile boolean flag = false;
   
3.     public void setFlag() {
   
4.         flag = true;
   
5.     }
   
6.     // 線程執(zhí)行
   
7.     @Override
   
8.     public void run() {
   
9.         while (true) {
   
10.             if (flag) {
    
11.                 System.out.println("flag is true");
    
12.                 flag = false;
    
13.             }
    
14.         }
    
15.     }
    
16. 
    
17.     public static void main(String[] args) {
    
18.         MyThread t = new MyThread();
    
19.         t.start();
    
20.         while (true) {
    
21.             try {
    
22.                 Thread.sleep(500);
    
23.             } catch (InterruptedException e)
    
24.             {}
    
25. 
    
26.             t.setFlag();
    
27.         }
    
28.     }
    
29. }

復制代碼

arch_yzs

上面的代碼 是不具備線程安全性的.  "結果這段代碼中注釋句去掉注釋的話，會有"flag is true"的輸出，但是注釋加上的話，就永遠不會輸出"flag is true" "
你看到的這個輸出結果是不可控的, 這里一共有兩個線程 : 1 main方法, 2 t.start()
兩個線程可以同時操作 對象t的 flag屬性, 有可能main方法剛剛調用完 t.setFlag()方法 第二個線程就執(zhí)行了 flag = false , 而main方法中的第二次循環(huán)還沒有來得及第二次調用setFlag()方法 . t.start()線程的第二次循環(huán)就已經(jīng)執(zhí)行到了if(flag),而此時 flag = false. 所以不輸出 flag is true. (跟你睡眠0.5秒與否關系不大,只是不睡眠,打印flag is true的可能性會比較大)
輸出結果會受 兩個線程的執(zhí)行進度影響, 而我們幾乎無法控制這兩個線程的執(zhí)行進度,即使你對線程設定了執(zhí)行優(yōu)先級. 所以最后的輸出結果是完全不可預期的,你看到的結果只是一個現(xiàn)象,可能同樣的代碼你放到不同的機器上結果又會不同.跟你的注釋句也沒什么關系. 至于你問為什么會看到這樣的輸出結果, 只能說 不可控 什么輸出結果都有可能.
所以最好使用synchronized來控制線程同步,保證某些代碼不會被 不同線程同時執(zhí)行, 比如這里 對flag值的操作