Java实现生产者消费者问题与读者写者问题详解
Java语言在多线程编程中提供了对同步机制的良好支持，解决生产者/消费者问题的方法可分为两类：（1）采用某种机制保护生产者和消费者之间的同步；（2）在生产者和消费者之间建立一个管道。以下是 Java 实现生产者消费者问题与读者写者问题详解的知识点：
一、生产者消费者问题
生产者消费者问题是研究多线程程序时绕不开的经典问题之一，它描述是有一块缓冲区作为仓库，生产者可以将产品放入仓库，消费者则可以从仓库中取走产品。
二、解决生产者/消费者问题的方法
解决生产者/消费者问题的方法可分为两类：（1）采用某种机制保护生产者和消费者之间的同步；（2）在生产者和消费者之间建立一个管道。
三、wait() / notify()方法
wait() / notify()方法是基类Object的两个方法，也就意味着所有Java类都会拥有这两个方法，这样，我们就可以为任何对象实现同步机制。wait()方法：当缓冲区已满/空时，生产者/消费者线程停止自己的执行，放弃锁，使自己处于等待状态，让其他线程执行。notify()方法：当生产者/消费者向缓冲区放入/取出一个产品时，向其他等待的线程发出可执行的通知，同时放弃锁，使自己处于等待状态。
四、BlockingQueue阻塞队列方法
BlockingQueue阻塞队列方法提供了一个阻塞队列，可以用于生产者消费者问题的解决。
五、Semaphore方法
Semaphore方法提供了一个计数 semaphore，可以用于生产者消费者问题的解决。
六、PipedInputStream / PipedOutputStream
PipedInputStream / PipedOutputStream提供了一个管道缓冲区，可以用于生产者消费者问题的解决。
七、Java实现生产者消费者问题的实例
以下是一个使用wait() / notify()方法实现生产者消费者问题的实例：
```java
package test;
public class Hosee {
private static Integer count = 0;
private final Integer FULL = 10;
private static String LOCK = "LOCK";
class Producer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (Exception e) {
e.printStackTrace();
}
synchronized (LOCK) {
while (count == FULL) {
try {
LOCK.wait();
} catch (Exception e) {
e.printStackTrace();
}
}
count++;
System.out.println(Thread.currentThread().getName() + "生产者生产，目前总共有" + count);
LOCK.notifyAll();
}
}
}
}
class Consumer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
synchronized (LOCK) {
while (count == 0) {
try {
LOCK.wait();
} catch (Exception e) {
TODO: handle exception
e.printStackTrace();
}
}
count--;
System.out.println(Thread.currentThread().getName() + "消费者消费，目前总共有" + count);
LOCK.notifyAll();
}
}
}
}
public static void main(String[] args) throws Exception {
// ...
}
}
```
八、总结
Java语言在多线程编程中提供了对同步机制的良好支持，解决生产者/消费者问题的方法可分为两类：（1）采用某种机制保护生产者和消费者之间的同步；（2）在生产者和消费者之间建立一个管道。wait() / notify()方法、BlockingQueue阻塞队列方法、Semaphore方法和PipedInputStream / PipedOutputStream等方法都是解决生产者消费者问题的有效方法。
2025-08-24 10:08:35
159KB
1
我们在开发过程中经常会遇到需要从一个地方不断获取数据然后又需要交给另一个线程对数据进行二次加工的情况，这种场景适合使用生产者-消费者模式。
2021-12-09 12:04:52
165KB
1
const unsigned short SIZE_OF_BUFFER = 20;//有界缓冲区长度
int g_buffer[SIZE_OF_BUFFER];//开辟缓冲区，用数组表示，可以看成是一个循环队列
unsigned short ProductID = 0;//新生产出来的产品的产品号
unsigned short ConsumeID = 0;//被消耗的产品的产品号
unsigned short in = 0;//产品进缓冲区时的缓冲区下标，用于记录生产者的指针位置
unsigned short out = 0;//产品出缓冲区时的缓冲区下标，用于记录消费者的指针位置
bool g_continue = 1;//控制程序运行：1表示继续运行，0表示停止运行
2021-06-09 18:43:00
6KB
1
主要介绍了Java实现Kafka生产者消费者代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2021-04-08 15:22:12
85KB
1