java多线程生产者与消费者(java实现生产者消费者问题)

假设送奶工送牛奶（生产者）和用户喝牛奶（消费者），以及放牛奶的箱子（缓冲区）为一个完整的生产者和消费者案例
此案例中包含四个类：

奶箱类（Box）生产者类（Producer）消费者类（Customer）测试类（BoxDemo）

使用wait()方法时，一定记得唤醒线程！
（如果没有唤醒，输出将会一直在送第一瓶牛奶）
wait()方法和notify()方法需要锁对象，即需要在同步中使用
（不然会报异常）

package Test_14;

public class Box {

    private int milk;
    //对奶箱加一个状态判断
    private boolean state = false;
    //wait()方法和notify()方法需要锁对象，即需要在同步中使用
    public  synchronized void put(int milk){
        //如果有牛奶，则等待消费（抛出异常）
        if (state){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //如果没有牛奶，则生产牛奶
        this.milk = milk;
        System.out.println("送奶工把第"+this.milk+"瓶奶放入奶箱");
        //生产完毕，修改状态
        state = true;
        //**唤醒其他线程**
        notifyAll();
    }
    public  synchronized void get(){
        //如果没有牛奶，则等待生产
        if (!state){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //如果有牛奶，则消费
        System.out.println("用户拿到第"+this.milk+"瓶奶");
        //消费完毕，修改状态
        state = false;
        //唤醒其他线程
        notifyAll();
    }
}

生产者类：实现Runnable()接口，重写run()方法，调用put操作

package Test_14;

public class Producer implements Runnable{
    private Box b;
    public Producer(Box b) {
        this.b = b;
    }

    @Override
    public void run() {
        for (int i = 1;i<=20;i++){
            b.put(i);
        }
    }
}

消费者类：实现Runnable()接口，重写run()方法，调用get操作

package Test_14;

public class Customer implements Runnable{
    private Box b;

    public Customer(Box b) {
        this.b = b;
    }

    @Override
    public void run() {
        while (true){
            b.get();
        }
    }
}

测试类：有main()方法，创建线程并启动

package Test_14;

public class BoxDemo {
    public static void main(String[] args) {
        Box b= new Box();

        Producer p = new Producer(b);
        Customer c= new Customer(b);

        Thread t1 = new Thread(p);
        Thread t2 = new Thread(c);

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