Java多线程编程实例：生产者-消费者模型

原创ゝ一纸荒年。 2024-12-08 22:45 17阅读 0赞

在Java多线程编程中，生产者-消费者模型是一种常见的并发模式。它通过两个角色（生产者和消费者）进行协作，以达到资源的有效利用。

下面是一个简单的生产者-消费者模型的Java实现：

```java
import java.util.concurrent.*;

public class ProducerConsumerExample {
    private final Queue<String> queue = new ArrayBlockingQueue<>(10);

// 生产者线程
    public void producerThread() {
        while (true) {
            String product = generateProduct(); // 生成产品
            System.out.println("Producer produced: " + product);
            queue.add(product); // 将产品添加到队列中
            try {
                Thread.sleep(500); // 模拟生产间隔
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        while (true) {
            String product = queue.poll(); // 从队列中获取产品
            System.out.println("Consumer consumed: " + product);
            if (product == null) { // 如果没有产品，关闭消费者线程
                System.out.println("No more products. Consumer thread stopping.");
                break;
            }
            try {
                Thread.sleep(1000); // 模拟消费间隔
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

private String generateProduct() { // 生成产品示例，实际生产中可以使用随机数等方法
        return "Product " + System.currentTimeMillis(); // 返回当前时间的产品标识
    }

public static void main(String[] args) {
        ProducerConsumerExample example = new ProducerConsumerExample();

// 创建并启动生产者线程
        Thread producerThread = new Thread(example::producerThread));
        producerThread.start();

// 创建并启动消费者线程
        Thread consumerThread = new Thread(example::consumerThread));
        consumerThread.start();
    }
}
```

这个例子中，生产者线程负责生成产品并将其添加到队列中。消费者线程则从队列中获取产品进行消费。

注意，这只是一个基础的实现，实际应用中可能需要处理更多的异常情况和优化代码。