黑马程序员技术交流社区

标题: 多线程_08_线程间通信 [打印本页]
作者: Tauruszzy    时间: 2015-5-14 11:50
标题: 多线程_08_线程间通信
线程间通信：多个线程操作同一个资源，但是操作的动作不一样。
知识点：
wait
notify
notifyAll
都使用在同步中，因为要对持有监视器（锁）的线程操作。因为只有同步才具有锁，所以要使用在同步中。

为什么这些操作线程的方法要定义在Object类中呢？
因为这些方法在操作同步中线程时都要标记他们所操作的线程持有的锁。
只有同一个锁上的被等待线程，可以被同一个锁上的notify唤醒。notify不可以唤醒不同锁中的线程。
也就是等待和唤醒必须是同一把锁。而锁可以是任意对象，任意对象都可以定义在Object类中，所以
这些方法要定义在Object类中。
作者: Tauruszzy    时间: 2015-5-14 11:52
示例代码：
  1. /*
  2. 线程之间通信：
  3. 多个线程操作同一个资源，但是操作的动作不同。
  4. */
  5. class Res
  6. {
  7.         String name;
  8.         String sex;
  9.         boolean flag=false;
  10. }

  12. class Input implements Runnable
  13. {
  14.         private Res r;
  15.         Input(Res r)
  16.         {
  17.                 this.r=r;
  18.         }
  19.         public void run()
  20.         {
  21.                 int x=0;
  22.                 while(true)
  23.                 {
  24.                         synchronized(r)
  25.                         {
  26.                                 if(r.flag)
  27.                                         try{r.wait();}catch(Exception e){}
  28.                                 if(x==0)
  29.                             {
  30.                                         r.name="mike";
  31.                                         r.sex="man";
  32.                                 }
  33.                                 else
  34.                                 {
  35.                                         r.name="丽丽";
  36.                                         r.sex="女女女";
  37.                                 }
  38.                                 x=(x+1)%2;
  39.                                 r.flag=true;
  40.                                 r.notify();
  41.                         }
  42.                        
  43.                 }
  44.                
  45.         }
  46. }

  48. class Output implements Runnable
  49. {
  50.         Res r;
  51.         Output(Res r)
  52.         {
  53.                 this.r=r;
  54.         }
  55.         public void run()
  56.         {
  57.                 while(true)
  58.                 {
  59.                         synchronized(r)
  60.                         {
  61.                                 if(!r.flag)
  62.                                         try{r.wait();}catch(Exception e){}
  63.                                 System.out.println(r.name+"....."+r.sex);
  64.                                 r.flag=false;
  65.                                 r.notify();
  66.                         }
  67.                 }
  68.         }
  69. }
  70. class  InputOutputDemo
  71. {
  72.         public static void main(String[] args)
  73.         {
  74.                 Res r=new Res();
  75.                 Input in=new Input(r);
  76.                 Output out=new Output(r);

  78.                 Thread t1=new Thread(in);
  79.                 Thread t2=new Thread(out);
  80.                
  81.                 t1.start();
  82.                 t2.start();

  84.         }
  85. }
复制代码
作者: Tauruszzy    时间: 2015-5-14 12:13
Tauruszzy 发表于 2015-5-14 11:52
示例代码：

上面代码的优化
  1. /*
  2. 线程之间通信：
  3. 多个线程操作同一个资源，但是操作的动作不同。
  4. */
  5. class Res
  6. {
  7.         private String name;
  8.         private String sex;
  9.         private boolean flag=false;
  10.         public synchronized void set(String name,String sex)
  11.         {
  12.                 if(flag)
  13.                         try{this.wait();}catch(Exception e){}

  15.                 this.name=name;
  16.                 this.sex=sex;

  18.                 flag=true;
  19.                 this.notify();
  20.         }
  21.         public synchronized void out()
  22.         {
  23.                 if(!flag)
  24.                         try{this.wait();}catch(Exception e){}

  26.                 System.out.println(name+"      "+sex);

  28.                 flag=false;
  29.                 notify();
  30.         }
  31. }

  33. class Input implements Runnable
  34. {
  35.         private Res r;
  36.         Input(Res r)
  37.         {
  38.                 this.r=r;
  39.         }
  40.         public void run()
  41.         {
  42.                 int x=0;
  43.                 while(true)
  44.                 {
  45.                                 if(x==0)
  46.                                         r.set("mike","man");
  47.                                 else
  48.                                         r.set("丽丽","女女女");
  49.                                 x=(x+1)%2;
  50.                 }
  51.                
  52.         }
  53. }

  55. class Output implements Runnable
  56. {
  57.         Res r;
  58.         Output(Res r)
  59.         {
  60.                 this.r=r;
  61.         }
  62.         public void run()
  63.         {
  64.                 while(true)
  65.                 {
  66.                         synchronized(r)
  67.                         {
  68.                                 r.out();
  69.                         }
  70.                 }
  71.         }
  72. }
  73. class  InputOutputDemo
  74. {
  75.         public static void main(String[] args)
  76.         {
  77.                 Res r=new Res();
  78.                 new Thread(new Input(r)).start();
  79.                 new Thread(new Output(r)).start();
  80.                 /*Input in=new Input(r);
  81.                 Output out=new Output(r);

  83.                 Thread t1=new Thread(in);
  84.                 Thread t2=new Thread(out);
  85.                
  86.                 t1.start();
  87.                 t2.start();
  88.                 */

  90.         }
  91. }
复制代码




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