如何用Java多线程实现生产者消费者模式

在Java中，可以使用多线程和同步机制来实现生产者-消费者模式。以下是一个简单的示例，展示了如何使用java.util.concurrent包中的BlockingQueue来实现生产者-消费者模式：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class ProducerConsumerExample {
    public static void main(String[] args) {
        // 创建一个容量为10的阻塞队列
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(10);

        // 创建生产者线程
        Thread producerThread = new Thread(new Producer(queue));
        // 创建消费者线程
        Thread consumerThread = new Thread(new Consumer(queue));

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

class Producer implements Runnable {
    private final BlockingQueue<Integer> queue;

    public Producer(BlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            for (int i = 0; i < 20; i++) {
                System.out.println("生产者生产: " + i);
                queue.put(i); // 将元素放入队列，如果队列已满，则等待
                Thread.sleep(1000); // 模拟生产时间
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

class Consumer implements Runnable {
    private final BlockingQueue<Integer> queue;

    public Consumer(BlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            while (true) {
                Integer item = queue.take(); // 从队列中取出元素，如果队列为空，则等待
                System.out.println("消费者消费: " + item);
                Thread.sleep(1000); // 模拟消费时间
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个容量为10的阻塞队列queue，并创建了一个生产者线程producerThread和一个消费者线程consumerThread。生产者线程将整数放入队列，而消费者线程从队列中取出整数。当队列已满时，生产者线程会等待；当队列为空时，消费者线程会等待。

这个示例使用了java.util.concurrent.BlockingQueue接口及其实现类java.util.concurrent.LinkedBlockingQueue。BlockingQueue提供了线程安全的队列操作，可以简化生产者-消费者模式的实现。