采用synchronized鎖以及wait notify方法實(shí)現(xiàn)

1.首先創(chuàng)建消費(fèi)的產(chǎn)品對(duì)象

class Person{
    private int foodNum = 0;
    private Object synObj = new Object();
    private final int MAX_NUM = 5;
    public void produce() throws InterruptedException{
        synchronized (synObj){
            while (foodNum == 5){
                System.out.println("box is full，size = " + foodNum);
                synObj.wait();
            }
            foodNum++;
            System.out.println("produce success foodNum = " + foodNum);
            synObj.notifyAll();
        }

    }

    public void consume() throws InterruptedException{
        synchronized (synObj){
            while (foodNum == 0){
                  System.out.println("box is empty,size = " + foodNum);
                  synObj.wait();
            }
            foodNum--;
            System.out.println("consume success foodNum = " + foodNum);
            synObj.notifyAll();
        }

    }
}

2.定義生產(chǎn)者消費(fèi)者方法

//生產(chǎn)者
class Producer implements Runnable{
    private Person person;
    private String producerName;
    public Producer(String producerName, Person person){
        this.producerName = producerName;
        this.person = person;
    }
    @Override
    public void run(){
        while (true){
            try{
                person.produce();
            } catch (InterruptedException e){
                e.printStackTrace();
            }
        }
    }
}

//消費(fèi)者
class Consumer implements Runnable{
    private Person person;
    private String consumerName;
    public Consumer(String consumerName, Person person){
        this.consumerName = consumerName;
        this.person = person;
    }
    @Override
    public void run(){
        try{
            person.consume();
        } catch (InterruptedException e){
            e.printStackTrace();
        }
    }
}

3.創(chuàng)建方法調(diào)用生產(chǎn)者和消費(fèi)者

public class WaitAndNotify{
    public static void main(String[] args) throws IOException{
        Person person = new Person();
        new Thread(new Consumer("消費(fèi)者一", person)).start();
        new Thread(new Consumer("消費(fèi)者二", person)).start();
        new Thread(new Consumer("消費(fèi)者三", person)).start();

        new Thread(new Producer("生產(chǎn)者一", person)).start();
        new Thread(new Producer("生產(chǎn)者一", person)).start();
        new Thread(new Producer("生產(chǎn)者一", person)).start();

    }
}