給出一個問題,如下: 解決方案如下: 執行這段代碼發現問題,就是同一張票號可能被多個售票視窗出售,惹禍的代碼就是if else語句塊。 解決方法就是在需要同步的代碼段用synchronized(Object){你要同步的代碼}即可。 修改後代碼如下: 執行這段代碼發現出票正常了。 線程1正執行需要做 ...
給出一個問題,如下:
解決方案如下:
1 public class Demo_5 { 2 3 public static void main(String[] args) { 4 //創建一個視窗 5 TicketWindow tw1=new TicketWindow(); 6 7 //使用三個線程同時啟動 8 Thread t1=new Thread(tw1); 9 Thread t2=new Thread(tw1); 10 Thread t3=new Thread(tw1); 11 12 t1.start(); 13 t2.start(); 14 t3.start(); 15 } 16 17 } 18 19 //售票視窗類 20 class TicketWindow implements Runnable{ 21 private int nums=2000; //一共2000張票 22 23 @Override 24 public void run() { 25 while(true){ 26 27 if(nums>0){ //先判斷是否還有票 28 //Thread.currentThread().getName()得到當前線程的名字 29 System.out.println(Thread.currentThread().getName()+"在售出第"+nums+"張票"); //顯示售票信息 30 31 //出票的速度是一秒出一張 32 try { 33 Thread.sleep(1000); 34 } catch (InterruptedException e) { 35 e.printStackTrace(); 36 } 37 38 nums--; 39 }else{ 40 break; //售票結束 41 } 42 43 } 44 } 45 }
執行這段代碼發現問題,就是同一張票號可能被多個售票視窗出售,惹禍的代碼就是if else語句塊。
解決方法就是在需要同步的代碼段用synchronized(Object){你要同步的代碼}即可。
修改後代碼如下:
1 public class Demo_5 { 2 3 public static void main(String[] args) { 4 //創建一個視窗 5 TicketWindow tw1=new TicketWindow(); 6 7 //使用三個線程同時啟動 8 Thread t1=new Thread(tw1); 9 Thread t2=new Thread(tw1); 10 Thread t3=new Thread(tw1); 11 12 t1.start(); 13 t2.start(); 14 t3.start(); 15 } 16 17 } 18 19 //售票視窗類 20 class TicketWindow implements Runnable{ 21 private int nums=2000; //一共2000張票 22 23 @Override 24 public void run() { 25 while(true){ 26 //認為if else這段代碼要保證其原子性(同步代碼塊) 27 synchronized (this) { 28 29 if(nums>0){ //先判斷是否還有票 30 //Thread.currentThread().getName()得到當前線程的名字 31 System.out.println(Thread.currentThread().getName()+"在售出第"+nums+"張票"); //顯示售票信息 32 33 //出票的速度是一秒出一張 34 try { 35 Thread.sleep(1000); 36 } catch (InterruptedException e) { 37 e.printStackTrace(); 38 } 39 40 nums--; 41 }else{ 42 break; //售票結束 43 } 44 45 } 46 } 47 } 48 }
執行這段代碼發現出票正常了。
線程1正執行需要做同步處理的代碼,線程2,3,4……blocked,被放入了線程等待池,就好像某人上廁所前先把門關上(上鎖),完事之後再出來(解鎖),然後別人就可以繼續使用了。