多线程实例01--包子买卖

1.创建一个实体类

package Th05;

public class Baozi5 {

    int id ;

    Baozi5 (int id){
        this.id = id;
    }
    
    public String toString(){
        return "包子：" + id;
    }
}

2.创建工厂

package Th05;

public class Factory5 {

    Baozi5[] num = new Baozi5[10];
    int index = 0;

    public synchronized void addBaozi(Baozi5 m){

        try {
            while( index == num.length){
                System.out.println("_______________生产满咯_____________");
                this.wait();
            }
            this.notify();
        }catch (InterruptedException e) {
            e.printStackTrace();
        }
        num[index] = m;
        index++;
        System.out.println("生产了"+ m + "共" + index + "个包子");
    }
    
    public synchronized Baozi5 popBaozi(){
        try{
            while(index == 0) {
                System.out.println("_____________卖光咯_____________");
                this.wait();
            }
            this.notify();
        }catch(Exception e){
            e.printStackTrace();
        }
        index--;
        System.out.println("消费了"+ num[index] +"共"+ index +"个包子");
        return num[index];
    }

    
}

3.买包子

package Th05;

public class Procuder5 implements Runnable{

    Factory5 fa = new Factory5();
    
    Procuder5 (Factory5 fa){
        this.fa = fa;
    }

    public void run() {
        for(int i=0; i<10; i++){
            Baozi5 b = new Baozi5(i);
            fa.addBaozi(b);
            try {
                Thread.sleep((int) (Math.random() * 500));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
    }
    
    
}

4.卖包子

package Th05;

public class Customer5 implements Runnable{

    Factory5 fa = new Factory5();
    
    Customer5(Factory5 fa){
        this.fa = fa;
    }

    public void run() {
        for(int i=0; i<20; i++){
            Baozi5 b = fa.popBaozi();
            
            try {
                Thread.sleep((int) (Math.random() * 1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }


}

5.测试

package Th05;

public class Test {

    public static void main(String[] args){
        Factory5 f = new Factory5();
        Procuder5 p = new Procuder5(f);
        Customer5 c = new Customer5(f);
        
        Thread t1 = new Thread(p);
        Thread t2 = new Thread(c);

        t1.start();
        t2.start();
    }
}