黑马程序员技术交流社区

标题: 生产消费者模式 [打印本页]
作者: 梁小刀11    时间: 2015-2-8 15:40
标题: 生产消费者模式
  1. package produtor_consumer;

  3. public class APP {
  4. public static void main(String[] args) {
  5.         movie m=new movie();
  6.         player p=new player(m);
  7.         watcher w=new watcher(m);
  8.          new Thread(p).start();
  9.          new Thread(w).start();
  10.         }
  11. }


  14. class movie {
  15.         private String str;
  16.         private boolean flag=true;
  17.        
  18. public synchronized void play(String str){
  19.         if(!flag){
  20.                 try {
  21.                         this.wait();
  22.                 } catch (InterruptedException e) {
  23.                        
  24.                         e.printStackTrace();
  25.                 }
  26.         }
  27.         try {
  28.                 Thread.sleep(500);
  29.         } catch (InterruptedException e) {
  30.                 // TODO Auto-generated catch block
  31.                 e.printStackTrace();
  32.         }
  33.         System.out.println("生产了-->"+str);
  34.         this.str=str;
  35.         this.notify();
  36.         this.flag=false;
  37.        
  38. }
  39. public  synchronized void  watch(){
  40.         if(flag){
  41.                 try {
  42.                         this.wait();
  43.                 } catch (InterruptedException e) {
  44.                         // TODO Auto-generated catch block
  45.                         e.printStackTrace();
  46.                 }
  47.         }
  48.         try {
  49.                 Thread.sleep(200);
  50.         } catch (InterruptedException e) {
  51.                 // TODO Auto-generated catch block
  52.                 e.printStackTrace();
  53.         }
  54.         System.out.println("消费了-->"+str);
  55.         this.notify();
  56.         this.flag=true;
  57. }

  59. }



  63. class player implements Runnable {
  64.     private movie m;

  66.         public player(movie m) {
  67.                 super();
  68.                 this.m = m;
  69.         }

  71.         @Override
  72.         public  void run() {
  73.         for(int i=0;i<200;i++){
  74.                 if(0==i%2){
  75.                
  76.                         m.play("左青龙");
  77.                 }else{
  78.                         m.play("右白虎");
  79.                 }
  80.         }
  81.                
  82.         }
  83.    
  84. }

  86. class watcher implements Runnable {
  87. private movie m;
  88.         public watcher(movie m) {
  89.         super();
  90.         this.m = m;
  91. }
  92.         @Override
  93.         public void run() {
  94.                 for(int i=0;i<20;i++){
  95.                         m.watch();
  96.                 }
  97.                
  98.         }
  99.        
  100.        

  102. }
复制代码






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