生产者消费者解决方式

方式一：

public class TestProductor {
    public static void main(String[] args) {
        Storage storage = new Storage();

        new Thread(new Producer(storage),"p1").start();
        new Thread(new Consumer(storage),"c1").start();
    }

}


//生产者
class Producer implements Runnable{
    private Storage storage;
    public Producer(){

    }

    public Producer(Storage storage){
        this.storage = storage;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            try {
                Thread.sleep(100);
                storage.put();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}



//消费者
class Consumer implements Runnable{

    private Storage storage;

    public Consumer(Storage storage){
        this.storage = storage;
    }
    public Consumer(){
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            try {
                Thread.sleep(100);
                storage.pop();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}


//仓库
class Storage{
    // 仓库容量
    private final int MAX_SIZE = 10;
    // 仓库存储的载体
    private LinkedList<Object> list = new LinkedList<>();

    public void put() {
        synchronized (list) {
            while (list.size()+1  > MAX_SIZE) {
                System.out.println("【生产者" + Thread.currentThread().getName()
                        + "】仓库已满,");
                try {
                    list.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            list.add(new Object());
            System.out.println("【生产者" + Thread.currentThread().getName()
                    + "】生产一个产品，现库存" + list.size());
            list.notifyAll();
        }
    }

    public void pop() {
        synchronized (list) {
            while (list.size() == 0) {
                 System.out.println("【消费者" + Thread.currentThread().getName()
                        + "】仓库为空，消费了0个产品");
                try {
                    list.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            list.remove();
            System.out.println("【消费者" + Thread.currentThread().getName()
                    + "】消费一个产品，现库存：" + list.size());
            list.notifyAll();
        }
    }
}

方式二：信号灯法

//生产者消费者：标志位
public class TestPC2 {
    public static void main(String[] args) {
        CubbyHole cubbyHole = new CubbyHole("橘子");
        new Thread(new Producers(cubbyHole),"p1").start();
        new Thread(new Consumers(cubbyHole),"c1").start();
    }
}

class Consumers implements Runnable {

    CubbyHole cubbyHole = new CubbyHole();

    public Consumers(CubbyHole cubbyHole) {
        this.cubbyHole = cubbyHole;
    }

    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            cubbyHole.pop();
        }
    }
}

class Producers implements Runnable {
    CubbyHole cubbyHole = new CubbyHole();

    public Producers(CubbyHole cubbyHole) {
        this.cubbyHole = cubbyHole;
    }

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


class CubbyHole {
    // 仓库容量
     boolean flag = true;
     String apple;

    public CubbyHole(String apple) {
        this.apple = apple;
    }
    public CubbyHole() {
    }

    public synchronized void put() {
        if (!flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("生产者生产了" + apple);
        this.notifyAll();
        this.apple = apple;
        this.flag = !this.flag;
    }

    public synchronized void pop() {
        if (flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("消费者消费了" + apple);
        this.notifyAll();
        this.flag = !this.flag;
    }
}