public class TextThread {
public static void main(String[] args) {
Basket bk = new Basket();
Producer p = new Producer(bk);
Consumer c = new Consumer(bk);
new Thread(p).start();
new Thread(c).start();
}
}
class ManTou {
int id;
ManTou(int id) {
this.id = id;
}
public String toString() {
return id+"号馒头";
}
}
class Basket {
static int index = 0;
ManTou[] mArray = new ManTou[6];
public synchronized void add(ManTou m) {
while (index == mArray.length) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notify();
mArray[index] = m;
index++;
}
public synchronized ManTou del() {
while (index == 0) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notify();
index--;
return mArray[index];
}
}
class Producer implements Runnable {
Basket bk = null;
Producer(Basket bk) {
this.bk = bk;
}
public void run() {
for (int i = 0; i < 10; i++) {
ManTou mt = new ManTou(i);
bk.add(mt);
System.out.println("生产了" + mt);
// try {
// Thread.sleep(500);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
}
}
}
class Consumer implements Runnable {
Basket bk = null;
Consumer(Basket bk) {
this.bk = bk;
}
public void run() {
for (int i = 0; i < 10; i++) {
ManTou mt = bk.del();
System.out.println("消费了" + mt);
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
生产了0号馒头
生产了1号馒头
生产了2号馒头
生产了3号馒头
生产了4号馒头
生产了5号馒头
生产了6号馒头
消费了5号馒头
消费了6号馒头
生产了7号馒头
消费了7号馒头
生产了8号馒头
消费了8号馒头
生产了9号馒头
消费了9号馒头
消费了4号馒头
消费了3号馒头
消费了2号馒头
消费了1号馒头
消费了0号馒头
分享到:
相关推荐
利用互斥锁和计数信号完成生产者消费者问题 一组生产者进程和一组消费者进程共享一个初始为空、大小为n的缓冲区,只有缓冲区没满时,生产者才把消息放入到缓冲区,否则必须等待;只有缓冲区不空时,消费者才能从中...
a: 创建一个线程 ...h: problem1 生产者消费者问题 (1生产者 1消费者 1缓冲区) problem1 more 生产者消费者问题 (1生产者 2消费者 4缓冲区) problem2 读者与写着问题 I: 信号量 semaphore 解决线程同步问题
C语言实现生产者消费者问题,分配具有n个缓冲区的缓冲池,作为共享资源。 定义两个资源型信号量empty 和full,empty信号量表示当前空的缓冲区数量,full表示当前满的缓冲区数量。 定义互斥信号量mutex,当某个进程...
生产者消费者问题总结 信号量概念总结 经典生产者-消费者问题 较为复杂的生产者-消费者问题 华南理工大学生产者和消费者问题 个人总结
设计目的:通过研究Linux 的进程机制和信号量实现生产者消费者问题的并发控制。说明:有界缓冲区内设有20 个存储单元,放入/取出的数据项设定为1‐20 这20 个整型数。设计要求:1)每个生产者和消费者对有界缓冲区...
多线程同步互斥 生产者消费者问题 MFC 实现
实验四、生产者消费者问题(15分) • 一个大小为3的缓冲区,初始为空 • 2个生产者 – 随机等待一段时间,往缓冲区添加数据, – 若缓冲区已满,等待消费者取走数据后再添加 – 重复6次 • 3个消费者 – ...
C++版,生产者消费者问题利用 多线程来解决,解决消费者与生产者同步、互斥问题,
java生产者消费者问题 java生产者消费者问题 java生产者消费者问题 java生产者消费者问题 java生产者消费者问题
java 生产者消费者问题(源码) java 生产者消费者问题(源码)
生产者消费者问题,描述一组生产者向一组消费者提供产品/消息。它们共享一个有界缓冲区,生产者向其中放产品/消息,消费者从中取产品/消息。只要缓冲区未满,生产者可放产品/消息,只要缓冲区有数据,消费者可取消息...
c语言用进程方法实现的生产者消费者问题,多个生产者消费者
windows下PV操作,多线程实现生产者消费者问题
设计目的:通过研究Linux 的进程机制和信号量实现生产者消费者问题的并发控制. 说明:有界缓冲区内设有20个存储单元,放入/取出的数据项设定为1-20这20个整型数. 设计要求:(1)每个生产者和消费者对有界缓冲区进行操作后...