黑马程序员技术交流社区

标题: 多线程的等待唤醒机制小问题 [打印本页]
作者: 孟子飞宏    时间: 2015-1-13 08:09
标题: 多线程的等待唤醒机制小问题
本帖最后由 孟子飞宏 于 2015-1-13 08:11 编辑
  1. 我写下面错误的代码的结果看图1<div class="blockcode"><blockquote>/*
  2. 线程间通讯：
  3. 多个线程在处理同一资源，但是任务却不同。


  6. */
  7. class Resource
  8. {
  9.         String name;
  10.         String sex;
  11.         boolean flag = false;
  12. }
  13. class Input implements Runnable
  14. {
  15.         Resource r;
  16.         Input(Resource r)
  17.         {
  18.                 this.r = r;
  19.         }
  20.         public void run()
  21.         {
  22.                 int x = 0;
  23.                 while(true)
  24.                 {
  25.                         synchronized(r)
  26.                         {
  27.                                 if(r.flag)
  28.                                 {
  29.                                         try
  30.                                         {
  31.                                                 r.wait();
  32.                                         }
  33.                                         catch (InterruptedException e)
  34.                                         {
  35.                                         }
  36.                                 }
  37.                                 else
  38.                                 {
  39.                                         if(x==0)
  40.                                         {
  41.                                                 r.name = "mike";
  42.                                                 r.sex = "nan";
  43.                                         }
  44.                                         else
  45.                                         {
  46.                                                 r.name = "丽丽";
  47.                                                 r.sex = "女";
  48.                                         }
  49.                                        
  50.                                        
  51.                                         r.notify();
  52.                                         r.flag = true;
  53.                                 }
  54.                         }
  55.                         x=(x+1)%2;
  56.                 }
  57.                
  58.                
  59.         }
  60. }
  61. class Output implements Runnable
  62. {
  63.         Resource r;
  64.         Output(Resource r)
  65.         {
  66.                 this.r = r;
  67.         }
  68.         public void run()
  69.         {
  70.                 while(true)
  71.                 {
  72.                         synchronized(r)
  73.                         {
  74.                                 if(!r.flag)
  75.                                 {
  76.                                         try
  77.                                         {
  78.                                                 r.wait();
  79.                                         }
  80.                                         catch (InterruptedException e)
  81.                                         {
  82.                                         }
  83.                                 }
  84.                                 {
  85.                                         System.out.println(r.name+"..."+r.sex);
  86.                                        
  87.                                         r.notify();
  88.                                         r.flag = false;
  89.                                 }
  90.                                 
  91.                         }
  92.                 }
  93.         }
  94. }
  95. class ResourceDemo2
  96. {
  97.         public static void main(String[] args)
  98.         {
  99.                 //创建资源
  100.                 Resource r = new Resource();
  101.                 //创建任务
  102.                 Input in = new Input(r);
  103.                 Output out = new Output(r);
  104.                 //创建线程
  105.                 Thread t1 = new Thread(in);
  106.                 Thread t2 = new Thread(out);
  107.                 //开启线程
  108.                 t1.start();
  109.                 t2.start();

  111.         }
  112. }
复制代码

正确代码：
  1. /*
  2. 线程间通讯：
  3. 多个线程在处理同一资源，但是任务却不同。


  6. */
  7. class Resource
  8. {
  9.         String name;
  10.         String sex;
  11.         boolean flag = false;
  12. }
  13. class Input implements Runnable
  14. {
  15.         Resource r;
  16.         Input(Resource r)
  17.         {
  18.                 this.r = r;
  19.         }
  20.         public void run()
  21.         {
  22.                 int x = 0;
  23.                 while(true)
  24.                 {
  25.                         synchronized(r)
  26.                         {
  27.                                 if(r.flag)
  28.                                 {
  29.                                         try
  30.                                         {
  31.                                                 r.wait();
  32.                                         }
  33.                                         catch (InterruptedException e)
  34.                                         {
  35.                                         }
  36.                                 }
  37. //                                else
  38. //                                {
  39.                                         if(x==0)
  40.                                         {
  41.                                                 r.name = "mike";
  42.                                                 r.sex = "nan";
  43.                                         }
  44.                                         else
  45.                                         {
  46.                                                 r.name = "丽丽";
  47.                                                 r.sex = "女";
  48.                                         }
  49.                                        
  50.                                        
  51.                                         r.notify();
  52.                                         r.flag = true;
  53. //                                }
  54.                         }
  55.                         x=(x+1)%2;
  56.                 }
  57.                
  58.                
  59.         }
  60. }
  61. class Output implements Runnable
  62. {
  63.         Resource r;
  64.         Output(Resource r)
  65.         {
  66.                 this.r = r;
  67.         }
  68.         public void run()
  69.         {
  70.                 while(true)
  71.                 {
  72.                         synchronized(r)
  73.                         {
  74.                                 if(!r.flag)
  75.                                 {
  76.                                         try
  77.                                         {
  78.                                                 r.wait();
  79.                                         }
  80.                                         catch (InterruptedException e)
  81.                                         {
  82.                                         }
  83.                                 }
  84.                                 {
  85.                                         System.out.println(r.name+"..."+r.sex);
  86.                                        
  87.                                         r.notify();
  88.                                         r.flag = false;
  89.                                 }
  90.                                
  91.                         }
  92.                 }
  93.         }
  94. }
  95. class ResourceDemo2
  96. {
  97.         public static void main(String[] args)
  98.         {
  99.                 //创建资源
  100.                 Resource r = new Resource();
  101.                 //创建任务
  102.                 Input in = new Input(r);
  103.                 Output out = new Output(r);
  104.                 //创建线程
  105.                 Thread t1 = new Thread(in);
  106.                 Thread t2 = new Thread(out);
  107.                 //开启线程
  108.                 t1.start();
  109.                 t2.start();

  111.         }
  112. }
复制代码


：

错误.PNG (48.16 KB, 下载次数: 0)

图1

图1

正确.PNG (23.23 KB, 下载次数: 0)

正确.PNG
作者: 孟子飞宏    时间: 2015-1-13 08:12
也就37,38,53行把else注释就正确了，不知道为什么



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