Java中傳統的線程通信個人見解

還有一個經驗，把同步代碼或在和鎖放到共同使用的數據上，而不是放在線程內，這樣的好處是什麼呢：首先是更符合面向對象的思想。其次是這種設計結構非常容易實現線程的同步，並且增加線程訪問共同數據的時候不用每次都在線程內增加同步代碼。有利於擴展和維護。

首先看一個例子，子線程先循環10次，主線程再循環100次，接著子線程循環10次，主線程再循環100次，如此循環往復50次；

實現代碼如下：

1. public class TraditionalThreadConnection {
3. /**
4. * @param args
5. */
6. public static void main(String[] args) {
8. final Service service = new Service();
9. //子線程
10. new Thread(new Runnable(){
12. @Override
13. public void run() {
14. for(int i = 1;i<=50;i++){
15. service.subThread(i);
16. }
17. }
19. }).start();
20. //主線程
21. for(int i = 1;i<=50;i++){
22. service.mainThread(i);
23. }
24. }
27. }
28. class Service{
29. /* 是否該子線程運行的標志 */
30. private boolean isSub = true;
31. public synchronized void subThread(int loop){
32. //首先是判斷是否該子線程運行，不是就等待
33. while(!isSub){
34. try {
35. this.wait();
36. } catch (InterruptedException e) {
37. e.printStackTrace();
38. }
39. }
40. for(int i=1;i<=10;i++){
41. System.out.println("sub-thread-" + i + ",loop--" + loop);
42. }
43. isSub = false;
44. //子線程運行完之後叫醒主線程
45. this.notify();
46. }
47. public synchronized void mainThread(int loop){
48. while(isSub){
49. try {
50. this.wait();
51. } catch (InterruptedException e) {
52. e.printStackTrace();
53. }
54. }
55. for(int i=1;i<=100;i++){
56. System.out.println("main-thread-" + i + ",loop--" + loop);
57. }
58. isSub = true;
59. this.notify();
60. }
61. }

還有一點要注意的地方，就在判斷是否等待的地方為什麼用到while而不是if:原因是這樣的，因為使用wait的時候有可能在沒有調用notify的時候自己就喚醒了，開始去執行代碼了，這叫做假喚醒。使用while就可以避免偽喚醒帶來的災難，還可以判斷一下是否可以去執行代碼。