生产者与消费者模式-阻塞 wait,notify
2024-08-26 16:58:48
设计思路：生产者push ，消费者 拿，篮子装，syncstack先进后出，while 判断 index=0 wait, 当 Producer生产了 并push到篮子里 notify（唤醒） 消费者。
wait：发生了阻塞事件-篮子已经满了，并且不知道阻塞多长时间，要用wait
public class ProducerConsumer {
public static void main(String[] args) {
SyncStack ss = new SyncStack();
Producer p = new Producer(ss);
Consumer c = new Consumer(ss);
new Thread(p).start();
new Thread(p).start();
new Thread(p).start();
new Thread(c).start();
}
}
class WoTou {//馒头和馒头的属性
int id;
WoTou(int id) {
this.id = id;
}
public String toString() {
return "WoTou : " + id;
}
}
class SyncStack {//创建一个装馒头的“篮子”
int index = 0;
WoTou[] arrWT = new WoTou[6];
public synchronized void push(WoTou wt) {//放馒头方法
while(index == arrWT.length) {//一定要用while循环语句而不要用if，如果是if再wait阻塞被打断 报interruptedException printStackTrace后会直接执行notifyall 而不会反过来头判断篮子里馒头满了没有
try {
this.wait();//wait阻塞
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notifyAll();
arrWT[index] = wt;
index ++;
}
public synchronized WoTou pop() {
while(index == 0) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notifyAll();
index--;
return arrWT[index];
}
}
class Producer implements Runnable {
SyncStack ss = null;
Producer(SyncStack ss) {
this.ss = ss;
}
public void run() {
for(int i=0; i<20; i++) {
WoTou wt = new WoTou(i);
ss.push(wt);
System.out.println("生产了：" + wt);
try {
Thread.sleep((int)(Math.random() * 200));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Consumer implements Runnable {
SyncStack ss = null;
Consumer(SyncStack ss) {
this.ss = ss;
}
public void run() {
for(int i=0; i<20; i++) {
WoTou wt = ss.pop();
System.out.println("消费了: " + wt);
try {
Thread.sleep((int)(Math.random() * 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
最新文章
- css 设置圆角
- Codeforces Round #389 (Div. 2, Rated, Based on Technocup 2017 - Elimination Round 3) C
- 位运算（&）实现分享弹窗上的图标动态显示/隐藏
- 【bzoj1036】 ZJOI2008—树的统计Count
- 用JS写的无缝滚动特效
- memcached在linux安装
- GitHub开源：升讯威ADO.NET增强组件 sheng.ADO.NET.Plus V1.3
- MySQL unique 注意
- EJB开发第一个无状态会话bean、开发EJB客户端
- linux yum提示Loaded plugins: fastestmirror, security错误的解决方法
- P1462 通往奥格瑞玛的道路 最短路
- 阿里云 docker连接总报超时 registry.cn-hangzhou.aliyuncs.com (Client.Timeout exceeded while awaiting headers
- （reverse） Text Reverse hdu1062
- 如何使用less(变量,混合,匹配,运算,嵌套...)
- OBV15 案例2
- Ubuntu上安装MySQL
- Twisted 安装
- Hadoop 和 Spark 的关系
- symfony学习笔记1—简介
- linux convert命令安装及使用