黑马程序员技术交流社区

标题: 多线程的生产者和消费者问题 [打印本页]
作者: 黑马-小龙    时间: 2013-1-27 23:49
标题: 多线程的生产者和消费者问题
本帖最后由 张向辉 于 2013-1-29 12:14 编辑
  1. package cn.itcast.string;

  3. public class ProducerAndConsumer {

  5.         /**
  6.          * 演示生产者与消费者例子
  7.          * @param args
  8.          */
  9.         public static void main(String[] args) {
  10.                 BreadBar bb = new BreadBar();//创建包子柜台对象
  11.         
  12.                 Chef chef = new Chef(bb);
  13.                
  14.                 Consumer cs = new Consumer(bb);

  16.                 chef.start();
  17.                 cs.start();
  18.         }

  20. }

  22. //这里是包子柜台类
  23. class BreadBar{
  24.         private int count ;//定义一个私有的包子数量属性
  25.         
  26.         //设置包子数量的getCount()方法
  27.         public void setCount(int count){
  28.                 this.count = count;
  29.         }
  30.         //获取包子数的方法
  31.         public int getCount(){
  32.                 return count;
  33.         }
  34.         
  35.         //定义一个吃包子的的eat()方法
  36.         public void eat(){
  37.                 System.out.println("正在吃包子。。。。");
  38.                 count -= count;
  39.         }
  40.         
  41.         //定义一个做包子的make()方法
  42.         public void make(){
  43.                 System.out.println("师傅，给我做几笼包子！！！！");
  44.                 count += count;
  45.         }
  46. }
  47. //厨师类
  48. class Chef extends Thread{
  49.         private BreadBar breadBar;//定义一个包子柜台的属性
  50.         
  51.         public Chef(BreadBar bb) {
  52.                 // TODO Auto-generated constructor stub
  53.         }

  55.         //重写线程类的run()方法
  56.         public void run(){
  57.                 synchronized(breadBar){
  58.                         while(true) {//死循环：while(true)。只要没包子就做，不怕累死；
  59.                                 if(breadBar.getCount() < 0){
  60.                                         breadBar.make();
  61.                                         this.notify();
  62.                                 }
  63.                                 else{
  64.                                         try {
  65.                                                 this.wait();
  66.                                         } catch (InterruptedException e) {
  67.                                                 // TODO Auto-generated catch block
  68.                                                 e.printStackTrace();
  69.                                         }
  70.                                 }                                       
  71.                         }
  72.                 }
  73.         }        
  74. }

  76. //顾客类
  77. class Consumer extends Thread{
  78.         private BreadBar breadBar;//定义一个包子柜台的属性
  79.         
  80.         public Consumer(BreadBar bb) {
  81.                 // TODO Auto-generated constructor stub
  82.         }

  84.         //重写线程类的run()方法
  85.         public void run(){
  86.                 synchronized(breadBar){
  87.                         while(true) {//死循环：while(true)。只要没包子就做，不怕累死；
  88.                                 if(breadBar.getCount() > 0){
  89.                                                 breadBar.eat();
  90.                                 }
  91.                                 else{
  92.                                         try {
  93.                                                 this.wait();
  94.                                         } catch (InterruptedException e) {
  95.                                                 // TODO Auto-generated catch block
  96.                                                 e.printStackTrace();
  97.                                         }
  98.                                         this.notify();
  99.                                 }                                       
  100.                         }
  101.                 }
  102.         }        
  103. }
复制代码
写了一个小时，麻烦大神帮我看看啊 ！！！！
作者: 逍林游    时间: 2013-1-28 11:07
[code]public class ProducerAndConsumer {

                /**
                 * 演示生产者与消费者例子
                 * @param args
                 */
                public static void main(String[] args) {
                        BreadBar bb = new BreadBar();//创建包子柜台对象
                
                        Chef chef = new Chef(bb);
                        
                        Consumer cs = new Consumer(bb);

                        new Thread(chef).start();
                        new Thread(cs).start();
                        
                }

        }

        //这里是包子柜台类
        class BreadBar{
                private  static int count = 0 ;//定义一个私有的包子数量属性
                
                
                //定义一个吃包子的的eat()方法
                public synchronized void eat(){
                                    if(count<0)  
                                    try{wait();}catch(Exception e){}
                        
                                    System.out.println("正在吃包子。。。。");
                                count --;
                                if(count<0)
                                notify();
                           
                        
                }
                
                //定义一个做包子的make()方法
                public synchronized void make(){
                                        if(count > 0)
                                        try{wait();}catch(Exception e){}
                       
                                System.out.println("师傅，给我做几笼包子！！！！");
                                count ++;
                                if(count >=1)
                                notify();
                               
                }
        }
        //厨师类
        class Chef implements Runnable {
                private BreadBar breadBar;//定义一个包子柜台的属性
                
                public Chef(BreadBar bb) {
                        // TODO Auto-generated constructor stub
                        breadBar = bb;
                }

                //重写线程类的run()方法
                public void run(){
                        while(true){
                        breadBar.make();
                        }
                }        
        }

        //顾客类
        class Consumer implements Runnable{
                private BreadBar breadBar;//定义一个包子柜台的属性
                
                public Consumer(BreadBar bb) {
                        // TODO Auto-generated constructor stub
                        breadBar = bb;
                }

                //重写线程类的run()方法
                public void run(){
                        while(true){
                        breadBar.eat();
                        }
                }        
        }



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