Java多線程之wait()和notify()

直接看測試代碼吧，細節之處，詳見注釋

1. package com.jadyer.thread.wait;
3. /**
4. * Java多線程之wait()和notify()的妙用
5. * @see =================================================================================================================
6. * @see 問題：同時啟動兩個線程和同時啟動四個線程，控制台打印結果是不同的
7. * @see 同時啟動兩個線程時，控制台會很規律的輸出1010101010101010
8. * @see 同時啟動四個線程時，控制台起初會規律的輸出10101010，一旦某一刻輸出一個負數，那麼後面的輸出就會"一錯再錯"
9. * @see 分析：對線程而言，任何一種情況，都是合理的
10. * @see 這裡假設其中的一種情況：tt22先執行，此時number=0，所以執行到了decrease()方法中的wait()方法，於是tt22被阻塞
11. * @see 接著tt44執行了，此時number=0，所以也執行到了decrease()方法中的wait()方法，於是tt44也被阻塞了
12. * @see 然後tt11執行了，此時number=0，www.linuxidc.com於是便執行到了increase()方法中的number++和notify()方法
13. * @see 重點在於tt11執行到notify()方法時，我們假設該方法喚醒了tt44線程，於是tt44開始執行decrease()方法中的number--
14. * @see 此時number=-1，然後執行到了decrease()方法中notify()方法，我們同樣假設該notify()方法喚醒的是tt22線程
15. * @see 同樣的道理，number又被減減了，於是number=-2，並被打印到控制台了，然後再假設tt22中的notify()方法喚醒的是tt11
16. * @see 如此的循環往復，就看到那種"一錯再錯"的效果了
17. * @see =================================================================================================================
18. * @see 修復：我們應當在wait()被喚醒的時候，再判斷一次，然後再決定是否讓該線程繼續wait()下去
19. * @see 因為，當某個線程被喚醒時，它不知道外界在其睡眠的期間發生了神馬，所以要再判斷一次。所以把if()改為while()判斷，即可
20. * @see =================================================================================================================
21. * @see 補充：如果只有兩個線程的話，一個是對number增加的線程，一個是對number減少的線程，此時用if()判斷是沒有問題的
22. * @see 因為無論線程如何的喚醒，它所喚醒的都是另一個線程，不存在第三個線程插進來搗亂的情況
23. * @see =================================================================================================================
24. * @author 宏宇
25. * @create Feb 22, 2012 3:20:05 PM
26. */
27. public class WaitNotifyTest {
28. public static void main(String[] args) {
29. Count count = new Count();
31. Thread tt11 = new Thread(new IncreaseThread(count));
32. Thread tt22 = new Thread(new DecreaseThread(count));
34. Thread tt33 = new Thread(new IncreaseThread(count));
35. Thread tt44 = new Thread(new DecreaseThread(count));
37. tt11.start();
38. tt22.start();
40. tt33.start();
41. tt44.start();
42. }
43. }
46. class IncreaseThread implements Runnable{
47. private Count count;
48. public IncreaseThread(Count count){
49. this.count = count;
50. }
51. @Override
52. public void run() {
53. for(int i=0; i<20; i++){
54. try {
55. Thread.sleep((long)(Math.random()*1000));
56. } catch (InterruptedException e) {
57. e.printStackTrace();
58. }
59. count.increase();
60. }
61. }
62. }
65. class DecreaseThread implements Runnable{
66. private Count count;
67. public DecreaseThread(Count count){
68. this.count = count;
69. }
70. @Override
71. public void run() {
72. for(int i=0; i<20; i++){
73. try {
74. Thread.sleep((long)(Math.random()*1000));
75. } catch (InterruptedException e) {
76. e.printStackTrace();
77. }
78. count.decrease();
79. }
80. }
81. }
84. class Count{
85. private int number;
87. public synchronized void increase(){
88. if(0 != number){
89. try {
90. //在同步方法(或者同步語句塊)中，被鎖定的對象可以調用wait()方法，這將導致當前線程被阻塞並釋放該對象的互斥鎖
91. //即解除了wait()方法所對應的當前對象的鎖定狀態，然後，其它的線程就有機會訪問該對象了
92. wait();
93. } catch (InterruptedException e) {
94. e.printStackTrace();
95. }
96. }
97. number++;
98. System.out.println(number);
99. //喚醒其它的由於調用了wait()方法而在等待同一個對象的線程
100. //該方法每次運行時，只能喚醒等待隊列中的一個線程，至於是哪一個線程被喚醒，則由線程調度器來決定，程序員無法控制
101. notify();
102. }
104. public synchronized void decrease(){
105. if(0 == number){
106. try {
107. wait();
108. } catch (InterruptedException e) {
109. e.printStackTrace();
110. }
111. }
112. number--;
113. System.out.println(number);
114. notify();
115. }
116. }