Java多线程_生产者消费者模式1

import java.util.LinkedList;

public class ProductorConsumerDemo {
    LinkedList<Integer> lists = new LinkedList<>(); // 定义存放物品的仓库
    int size = 10; // 定仓库的大小
    // 生产物品
    public synchronized void add(Integer i) { // 这里对临界资源的访问贯穿了整个方法，synchronized可以直接加到方法上
        if (lists.size() == size) { // 首先判断还能不能生产？ 也就是容量到了size吗？
            try {
                this.wait(); // 不需要的生产 ，就等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } else {
            lists.add(i); // 把生产出来的物品放进仓库
            this.notifyAll(); // 唤醒消费者线程来消费
        }

    }

    // 消费
    public synchronized int remove() {
        if (lists.size() == 0) { // 判断有没有物品
            try {
                this.wait(); // 如果没有物品就等待， 释放锁
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } else {
            int i = lists.removeFirst(); // 有物品，就拿走一个
            if (lists.size() == 0) // 如果拿到了最后一个
            {
                this.notifyAll(); // 通知生产者生产物品
            }
            return i;
        }
        return -1;
    }

    public static void main(String[] args) {
        ProductorConsumerDemo pcd = new ProductorConsumerDemo();
        new Thread(new Runnable() {
            int count = 1;

            @Override
            public void run() {
                while (true) {
                    int i = count++;
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    pcd.add(i);
                    System.out.println(Thread.currentThread().getName() + " 生产了第 " + i + " 个物品，还有" + pcd.lists);
                }
            }
        }, "生产者 ").start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    try {
                        Thread.sleep(110);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + " 消费了第 " + pcd.remove() + "个物品");
                }
            }
        }, "消费者 ").start();
    }
}