黑马程序员技术交流社区

标题: 多线程的等待唤醒机制 [打印本页]
作者: More    时间: 2014-7-13 06:39
标题: 多线程的等待唤醒机制
  1. class Res
  2. {
  3.         String name;
  4.         String sex;
  5.         boolean flag=false;
  6. }
  7. class Input implements Runnable
  8. {
  9.         //Object b=new Object();//这样定义对象  把obj作为锁但是Output上也定义了obj但是两者不是同一个对象
  10.         private int x=0;
  11.         private Res r;
  12.         Input(Res r){
  13.                 this.r=r;       
  14.         }
  15.         //Res r=new Res();//在Output中也创建了Res对象，这样相当于创建了两个对象，不符合本意
  16.         public void run(){//对name和sex进行赋值
  17.                 while(true)
  18.                 {
  19.                         //同步代码块
  20.                         synchronized(r)//将r作为锁  和Output是同一把锁
  21.                         {
  22.                                 if(r.flag){
  23.                                         try{r.wait();}catch(Exception e){}
  24.                                 }else{
  25.                                         if(x==0){
  26.                                                 r.name="mike";
  27.                                                 r.sex="man";
  28.                                         }else{
  29.                                                 r.name="丽丽";
  30.                                                 r.sex="女女女女";
  31.                                         }
  32.                                         x=(x+1)%2;
  33.                                         r.flag=true;
  34.                                         r.notify();
  35.                                 }
  36.                                
  37.                         }

  39.                 }
  40.         }
  41. }
  42. class Output implements Runnable
  43. {
  44.         private Res r;
  45.         //Object b=new Object();//这样定义对象  把obj作为锁但是Input上也定义了obj但是两者不是同一个对象
  46.         Output(Res r){
  47.                 this.r=r;       
  48.         }
  49.         //Res r=new Res();
  50.         public void run(){//提取name和sex的值
  51.                 while(true){
  52.                         synchronized(r){//将r作为锁  和Input是同一把锁
  53.                                 if(!r.flag){
  54.                                         try{r.wait();}catch(Exception e){}
  55.                                 }else{
  56.                                         System.out.println(r.name+"....."+r.sex);
  57.                                 }
  58.                                 r.flag=false;
  59.                                 r.notify();
  60.                                
  61.                         }
  62.                 }
  63.         }
  64. }
  65. class InputOutputDemo
  66. {
  67.         public static void main(String[] args)
  68.         {
  69.                 Res r=new Res();
  70.                 //Input Output使用同一个对象
  71.                 Input in=new Input(r);
  72.                 Output out=new Output(r);
  73.                 Thread t1=new Thread(in);
  74.                 Thread t2=new Thread(out);
  75.                 t1.start();
  76.                 t2.start();
  77.         }
  78. }
复制代码

输出时，为什么产生不了赋值一遍就打印一遍的效果？？



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