Java多线程同步问题：生产者消费者模型

原创落日映苍穹つ 2024-09-28 01:24 56阅读 0赞

在Java中，生产者消费者模式通常通过阻塞队列（如`BlockingQueue`）和两个线程（生产者和消费者）来实现。下面是一个简单的例子：

1. 生产者类（Producer.java）

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

public class Producer {
    private final BlockingQueue<String> queue = new LinkedBlockingQueue<>();

public void produce() {
        // 生成产品并放入队列
        for (int i = 0; i < 10; i++) {
            queue.put("Product " + i);
        }

// 随机选择一个元素并消费
        String product = queue.take();
        System.out.println("Consumer consumed: " + product);
    }
}
```

2. 消费者类（Consumer.java）

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

public class Consumer {
    private final BlockingQueue<String> queue = new LinkedBlockingQueue<>();

public void consume() {
        // 从队列中消费产品
        while (!queue.isEmpty()) {
            String product = queue.poll();
            System.out.println("Consumer consumed: " + product);
        }
    }
}
```

运行这两个类，生产者会生成并放入队列10个产品。消费者则会在队列不为空的情况下持续从队列中消费产品。

这样的模型可以用于模拟资源有限的系统（如服务器），通过多线程来管理和控制这些资源。

Java多线程同步问题：生产者消费者模型

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Java多线程同步问题：生产者-消费者模型实例

相关 Java多线程同步问题——生产者与消费者实战

相关 Java多线程同步问题：生产者-消费者模型解析

相关 Java多线程同步问题——生产者消费者模型示例

相关 Java多线程同步：生产者消费者问题示例

相关 Java多线程同步问题：简单生产者-消费者例子

相关 Java多线程同步问题：生产者消费者模型

相关 Java多线程同步问题：生产者-消费者模型实例

相关多线程生产者消费者模型