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
RFID技术的日益成熟为图书馆读者定位提供了可靠的技术支持。分析了RFID和WIFI-RFID两种室内定位技术在图书馆内应用方案的特点,讨论了利用无线AP与RFID模块的结合,配合含有RFID标签的读者证件,快速定位读者物理位置。通过对读者的位置数据进行读者行为分析,实现智能图书馆的多个应用。
2024-01-10 11:56:09
844KB
1
煤炭是中国的基础能源，煤炭开采、加工、利用的效率和排放决定了中国的能源效率及其对环境的影响程度。洗选加工、按质利用是煤炭综合利用的成功之道。我国每年煤炭开采、洗选加工副产的低热值煤超过7亿吨，这些劣质燃料难以在常规煤粉锅炉或其他燃烧设备中燃用，只能采用循环流化床锅炉燃烧，这是我国循环流化床锅炉技术发展的动力。循环流化床燃烧中，炉内添加石灰石可低成本脱硫；循环流化床锅炉内部特有的低温燃烧和快速床中特殊的气固流动结构营造出的还原性气氛，可将NOx生成浓度控制在较低水平，从而实现低成本污染物控制，促进循环流化床燃烧技术迅速发展。 20世纪80年代初，我国开始循环流化床燃烧技术的研究。通过对化工流态化理论和实践的借鉴，揭示了循环流化床燃烧中的气固两相流动特性及其对传热和燃烧的影响规律，建立了物料循环系统整体性能的工业实现方法，创建了普适的循环流化床锅炉设计理论体系，自主研发了性能优异的系列循环流化床锅炉，简约型循环流化床锅炉的性能达到了国际先进水平，完全替代了引进设备和引进技术，产品大量出口海外。 循环流化床燃烧在低成本污染物控制方面具备显著优势，但在发电效率方面与电力行业的期
2023-12-09 17:44:13
169KB
1
#include
#include
#include "fstream.h"
//全局变量
int readcount=0; //读者数目
int writecount=0; //写者数目
/*
关键代码段是指一个小代码段，在代码能够执行前，它必须独占对某些共享资源的访问权。
这是让若干行代码能够“以原子操作方式”来使用资源的一种方法。
*/
CRITICAL_SECTION RP_Write; //临界区
CRITICAL_SECTION cs_Write;
CRITICAL_SECTION cs_Read;
struct ThreadInfo //线程信息
{ int Threadhao; //线程序号
char ThreadClass; //线程类别
double ThreadStartTime; //线程开始时间
double ThreadRunTime; //线程读写持续时间
};
void ReaderFun(char* file);//读者优先函数
void R_ReaderThread(void *p);//处理读者优先读者线程
void R_WriterThread(void *p);//处理读者优先写者线程
void WriterFun(char* file);
void W_ReaderThread(void *p);
void W_WriterThread(void *
这个程序可以供大家参考，完全可以正确运行，得到自己想要的结果。
2023-04-26 16:59:51
1.33MB
1
读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题读者写者问题
2023-01-07 08:42:03
3KB
1
该书详细描述了信号量、pv操作等操作系统中的重要知识点，利用多个常见pv操作案例如读者写者、生产者消费者等问题阐述pv操作和信号量的问题
2022-11-25 21:08:39
7.71MB
1