一个简单的生产者和消费者模型

import java.util.LinkedList;

public class ProducerConsumerExample {

    public static void main(String[] args) throws InterruptedException {
        final Buffer buffer = new Buffer(5); // 创建一个缓冲区，容量为5

        // 创建一个生产者线程
        Thread producerThread = new Thread(() -> {
            try {
                int value = 0;
                while (true) {
                    buffer.put(value++); // 生产一个数据到缓冲区
                    Thread.sleep(1000); // 等待1秒钟
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 创建一个消费者线程
        Thread consumerThread = new Thread(() -> {
            try {
                while (true) {
                    int value = buffer.take(); // 从缓冲区中取出一个数据
                    System.out.println("Consumed: " + value);
                    Thread.sleep(2000); // 等待2秒钟
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 启动生产者和消费者线程
        producerThread.start();
        consumerThread.start();

        // 等待线程结束
        producerThread.join();
        consumerThread.join();
    }

    // 缓冲区类
    static class Buffer {
        private final LinkedList<Integer> queue; // 用链表实现缓冲区
        private final int capacity; // 缓冲区容量

        public Buffer(int capacity) {
            this.queue = new LinkedList<>();
            this.capacity = capacity;
        }

        // 生产一个数据
        public void put(int value) throws InterruptedException {
            synchronized (queue) {
                while (queue.size() == capacity) { // 缓冲区已满，等待消费者消费
                    queue.wait();
                }
                queue.add(value);
                queue.notifyAll(); // 通知消费者可以消费了
            }
        }

        // 消费一个数据
        public int take() throws InterruptedException {
            synchronized (queue) {
                while (queue.isEmpty()) { // 缓冲区为空，等待生产者生产
                    queue.wait();
                }
                int value = queue.remove();
                queue.notifyAll(); // 通知生产者可以生产了
                return value;
            }
        }
    }
}