Java程序设计之消费者跟生产者

public class Break {    public static final int MAX = 10;  //最多一次性煮十个面包    Stack<Integer> stack = new Stack<Integer>();    public static int food_count = 0; //统计食物的个数        //做面包    public synchronized void make_food(int number){        stack.push(number);        food_count++;    }        //吃食物    public synchronized int eat_food(){        food_count--;        return stack.pop();    }}

public class Kitchen {    private Break food ;    public static int people1_eatnumber = 0;//第一个人吃的面包数量    public static int people2_eatnumber = 0;//第二个人吃的面包数量    public static final int TOTOAL_NUM = 100;//总共做的面包数量    public static int icount = 1;//统计做过的面包数量        public Kitchen(Break food){        this.food = food;    }        //做面包的方法    public synchronized void make(){        if(food.food_count<10){//锅是不是满了            food.make_food(Kitchen.icount);            System.out.println("做完了第"+Kitchen.icount+"个食物。");            Kitchen.icount++;            notifyAll();//食物有了，找两个人来吃面包        }else{            System.out.println("锅已经装满，一次性装十个，等待两人吃食物。");            try {                wait();            } catch (InterruptedException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }//进入阻塞状态,等待消费者唤醒        }    }        //吃面包的方法    public synchronized void eat(){        if(food.food_count>0){            int temp = food.eat_food();//吃掉面包的编号            System.out.println(Thread.currentThread().getName()+"吃掉了第"+temp+"个食物");            if(Thread.currentThread().getName().equals("一号")){                people1_eatnumber++;            }else{                people2_eatnumber++;            }            notifyAll();  //唤醒继续做面包        }else{            System.out.println("食物吃完了，等待重新烹饪。");            try {                wait();            } catch (InterruptedException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }    }}

public class consumer implements Runnable {    Kitchen kitchen;        public consumer(Kitchen kitchen){        this.kitchen = kitchen;    }    @Override    public void run() {        // TODO Auto-generated method stub        while(true){            if(kitchen.icount>100&&Break.food_count<=0){                break;            }            try{                kitchen.eat();                Thread.sleep(100);            }catch(Exception e){                e.printStackTrace();            }        }    }}

public class product implements Runnable {    private Kitchen kitchen;    public product(Kitchen kitchen){        this.kitchen = kitchen;    }    @Override    public void run() {        // TODO Auto-generated method stub        while(true){            //结束这个线程            if(Kitchen.icount > 100){                break;            }            try{                                kitchen.make();                Thread.sleep(100);                }catch(Exception e){                e.printStackTrace();            }        }        System.out.println("厨房食物材料已经做完。");    }}

public class test {    public static void main(String[] args){        Break brake = new Break();        Kitchen kitchen = new Kitchen(brake);        product p = new product(kitchen);        consumer c1 = new consumer(kitchen);        consumer c2 = new consumer(kitchen);                Thread food = new Thread(p,"食物");        Thread people1 = new Thread(c1,"一号");        Thread people2 = new Thread(c2,"二号");                food.start();        people1.start();        people2.start();                try{            food.join();            people1.join();            people2.join();        }catch(Exception e){            e.printStackTrace();        }                System.out.println("一号吃了"+Kitchen.people1_eatnumber);        System.out.println("二号吃了"+Kitchen.people2_eatnumber);    }}