黑马程序员技术交流社区

标题: 线程通信问题 [打印本页]
作者: て淡莣了陌生    时间: 2013-4-27 16:50
标题: 线程通信问题
本帖最后由 て淡莣了陌生 于 2013-4-28 08:36 编辑

class Demo1_Notify {
        
        public static void main(String[] args) {
                final Printer p = new Printer();
               
                new Thread(){
                        public void run() {
                                while(true)
                                        try {
                                                p.print1();
                                        } catch(Exception e) {
                                                e.printStackTrace();        
                                        }
                        }        
                }.start();
               
                new Thread(){
                        public void run() {
                                for(;;)
                                        try {
                                                p.print2();
                                        } catch(Exception e) {
                                                e.printStackTrace();        
                                        }
                        }        
                }.start();
               
                new Thread(){
                        public void run() {
                                for(;;)
                                        try {
                                                p.print3();
                                        } catch(Exception e) {
                                                e.printStackTrace();        
                                        }
                        }        
                }.start();
        }
               
}

class Printer {
        private int flag = 1;        

        public synchronized void print1() throws Exception {                        
                if (flag != 1)        
                        wait();
                System.out.print("好");        
                System.out.print("好");        
                System.out.print("学");        
                System.out.print("习");        
                System.out.print("\r\n");        
                flag = 2;               
                notifyAll();                        
        }
        
        public synchronized void print2() throws Exception {
                if (flag != 2)        
                        wait();
                System.out.print("天");        
                System.out.print("天");        
                System.out.print("向");        
                System.out.print("上");        
                System.out.print("\r\n");
                flag = 3;                        
                notifyAll();                        
        }
        
        public synchronized void print3() throws Exception {
                if (flag != 3)               
                        wait();
                System.out.print("A");        
                System.out.print("l");        
                System.out.print("r");        
                System.out.print("e");        
                System.out.print("a");        
                System.out.print("d");        
                System.out.print("\r\n");
                flag = 1;                        
                notifyAll();                        
        }
        
}

这段代码执行后为什么没有按照顺序来打印呢,研究了大半天了都没找出哪里出了问题,哪位大神能指点一下迷津啊,谢谢了啊!!!
作者: java冬冬    时间: 2013-4-27 17:10
本帖最后由 java冬冬 于 2013-4-27 18:21 编辑

代码修改如下：{:soso_e152:}
  1. class Demo1_Notify {

  3. public static void main(String[] args) {
  4. final Printer p = new Printer();

  6. new Thread(){
  7. public void run() {
  8. while(true)
  9. try {
  10. p.print1();
  11. } catch(Exception e) {
  12. e.printStackTrace();
  13. }
  14. }
  15. }.start();

  17. new Thread(){
  18. public void run() {
  19. for(;;)
  20. try {
  21. p.print2();
  22. } catch(Exception e) {
  23. e.printStackTrace();
  24. }
  25. }
  26. }.start();

  28. new Thread(){
  29. public void run() {
  30. for(;;)
  31. try {
  32. p.print3();
  33. } catch(Exception e) {
  34. e.printStackTrace();
  35. }
  36. }
  37. }.start();
  38. }

  40. }

  42. class Printer {
  43. private int flag = 1;

  45. public synchronized void print1() throws Exception {
  46. while (flag != 1)
  47. wait();
  48. System.out.print("好");
  49. System.out.print("好");
  50. System.out.print("学");
  51. System.out.print("习");
  52. System.out.print("\r\n");
  53. flag = 2;
  54. notifyAll();
  55. }

  57. public synchronized void print2() throws Exception {
  58. while (flag != 2)
  59. wait();
  60. System.out.print("天");
  61. System.out.print("天");
  62. System.out.print("向");
  63. System.out.print("上");
  64. System.out.print("\r\n");
  65. flag = 3;
  66. notifyAll();
  67. }

  69. public synchronized void print3() throws Exception {
  70. while(flag != 3)
  71. wait();
  72. System.out.print("A");
  73. System.out.print("l");
  74. System.out.print("r");
  75. System.out.print("e");
  76. System.out.print("a");
  77. System.out.print("d");
  78. System.out.print("\r\n");
  79. flag = 1;
  80. notifyAll();
  81. }

  83. }

复制代码
运行结果：


作者: 杨同旺    时间: 2013-4-27 17:54
本帖最后由 杨同旺 于 2013-4-27 17:55 编辑

把以上代码中的if,全部改为while,便能解决问题,

原因是由于,先打印print1,此时print3等待,

当print1打印完成后,print3恰好被唤醒,此时print3将不会返回去再判断if,而是不再判断直接就打印了,

所以,需要加上while,print3在打印之前,将会回去判断一下while(flag!=3),结果就正确了.
作者: Miss小强    时间: 2013-4-27 18:07
本帖最后由 黄玉昆 于 2013-4-27 19:50 编辑

楼上的说的对，补充点：
为什么要用while，那时因为会出现假唤醒的现象，本来没有被notify，
被唤醒了之后没有判断标记，就容易出问题；
给你一个我写的吧：
  1. package cn.itcast.concurrent;
  2. import java.util.concurrent.locks.Condition;
  3. import java.util.concurrent.locks.Lock;
  4. import java.util.concurrent.locks.ReentrantLock;
  5. public class Business {
  6.         /*  *
  7.          * 需求：
  8.          *     有三个线程：一个主线程，两个子线程A,B；
  9.          *     主线程循环20次，A线程循环30次，B循环40次；
  10.          *     如此交替50次；即主---》A---》B；
  11.          * 思路：
  12.          *      可以定义一个锁，在一个锁上获得三个condition分别代表主，A，B；
  13.          *      定义一个int变量：作为一个标记，来标识三个线程是否可以执行；
  14.          *      1---》主 2---》A 3---》B；
  15.          */
  16.         private Lock lock = new ReentrantLock();
  17.         private int flag = 1;
  18.         private Condition main_condition = lock.newCondition();
  19.         private Condition a_condition = lock.newCondition();
  20.         private Condition b_condition = lock.newCondition();
  21.         public void main(int i) {
  22.                 lock.lock();
  23.                 try {
  24.                         while (flag != 1) {
  25.                                 main_condition.await();
  26.                         }
  27.                         for (int j = 0; j < 20; j++) {
  28.                                 System.out.println(Thread.currentThread().getName() + "main loop" + j + "of" + i);
  29.                         }
  30.                         flag=2;
  31.                         a_condition.signal();
  32.                 } catch (InterruptedException e) {
  33.                         e.printStackTrace();
  34.                 }
  35.                 finally {
  36.                         lock.unlock();
  37.                 }
  38.         }
  39.         public void subA(int i) {
  40.                 lock.lock();
  41.                 try{
  42.                         while(flag!=2){
  43.                                 a_condition.await();
  44.                         }
  45.                         for (int j = 0; j < 20; j++) {
  46.                                 System.out.println(Thread.currentThread().getName() + "A loop" + j + "of" + i);
  47.                         }
  48.                         flag=3;
  49.                         b_condition.signal();
  50.                 } catch (InterruptedException e) {
  51.                         e.printStackTrace();
  52.                 }
  53.                 finally{
  54.                         lock.unlock();
  55.                 }
  56.         }
  57.         public void subB(int i) {
  58.                 lock.lock();
  59.                 try{
  60.                         while(flag!=3){
  61.                                 b_condition.await();
  62.                         }
  63.                         for (int j = 0; j < 20; j++) {
  64.                                 System.out.println(Thread.currentThread().getName()  + "B loop" + j + "of" + i);
  65.                         }
  66.                         flag=1;
  67.                         main_condition.signal();
  68.                 } catch (InterruptedException e) {
  69.                         e.printStackTrace();
  70.                 }
  71.                 finally{
  72.                         lock.unlock();
  73.                 }
  74.         }
  75. }
复制代码
作者: Miss小强    时间: 2013-4-27 18:07
本帖最后由 黄玉昆 于 2013-4-27 19:52 编辑
  1. package cn.itcast.concurrent;
  2. public class ThreeThreadcommunicati {

  4.         public static void main(String[] args) {
  5.                 final Business business = new Business();
  6.                 new Thread(new Runnable() {
  7.                         @Override
  8.                         public void run() {
  9.                                 for (int i = 0; i < 50; i++) {
  10.                                         business.subA(i);
  11.                                 }
  12.                         }
  13.                 }).start();
  14.                 new Thread(new Runnable() {
  15.                         @Override
  16.                         public void run() {
  17.                                 for (int i = 0; i < 50; i++) {
  18.                                         business.subB(i);
  19.                                 }
  20.                         }
  21.                 }).start();
  22.                 for (int i = 0; i < 50; i++) {
  23.                         business.main(i);
  24.                 }
  25.         }
  26. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2