Java基础教程——线程通信
2024-09-07 21:50:45
线程通信：等待、唤醒
| Object方法 | 这些方法在拥有资源时才能调用 |
|---|---|
| notify | 唤醒某个线程。唤醒后不是立马执行，而是等CPU分配 |
| wait | 等待，释放锁，不占用CPU资源 |
| notifyAll | 唤醒全部等待的线程 |
重点：资源的有效利用
生产一个，消费一个；再生产一个，再消费一个
以热干面为例（生产者消费者问题）：
class 热干面 {
int isOK = 0;
}
class 生产者 implements Runnable {
热干面 m;
public 生产者(热干面 m) {
this.m = m;
}
public void 做面() {
try {
synchronized (m) {
if (m.isOK > Desk.BUFFER_MAX) {
System.out.println("+等需要做了再做");
m.wait();
System.out.println("+开始做");
}
m.isOK++;
System.out.println("+做面" + m.isOK);
m.notify();
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void run() {
while (true) {
try {
Thread.sleep(Desk.做面时间);
} catch (InterruptedException e) {
e.printStackTrace();
}
做面(); // 生产面
}
}
}
class 消费者 implements Runnable {
热干面 m;
public 消费者(热干面 m) {
this.m = m;
}
public void 吃面() {
try {
synchronized (m) {// # 锁住面对象
if (m.isOK <= 0) {
System.out.println("------等面");
m.wait();// 等待,释放锁
System.out.println("------有面了");
}
System.out.println("------吃面:" + m.isOK);
m.isOK--;
m.notify();// 唤醒另一个线程,但是,俩线程等CPU执行权
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void run() {
while (true) {
try {
Thread.sleep(Desk.吃面时间);
} catch (InterruptedException e) {
e.printStackTrace();
}
吃面();
}
}
}
class Desk {// 为了管理对象、模拟现实场景，可以不要
public static final int 做面时间 = 100;
public static final int 吃面时间 = 100;
public static final int BUFFER_MAX = 1;
热干面 msg = new 热干面();
生产者 m = new 生产者(msg);
消费者 c = new 消费者(msg);
Thread t1 = new Thread(m); // 生产者线程
Thread t2 = new Thread(c); // 消费者线程
public void fn() {
t1.start();
t2.start();
}
}
public class 生产者消费者问题 {
public static void main(String[] args) {
Desk d = new Desk();
d.fn();
}
}
最新文章
- Docket学习--Docker入门
- HTML头部
- Spark 2.6.1 源代码在 eclipse 的配置
- Beaglebone Black – 智能家居控制系统 LAS - 插座组装
- json小例子
- WebGrid Enterprise免费下载
- 指定 ubuntu server ip
- 【LeetCode】38 - Count and Say
- Python 调用C++
- laravel框架——表单验证
- ProgressBar( 进度条) 组件
- Android Java 与 C++ 恒调用，路径、文件名、延长的最大长度
- Android异步消息机制
- RepeatMasker使用中的问题
- Linux中的Buffer 与 Cache
- 接触JS的变量
- [JSOI2007]合金
- String的lastIndexOf（）用于获取字符串中某个子字符串最后一次出现的位置
- 第六章 使用 Bootstrap Typeahead 组件（百度下拉效果）（续）
- NGS概念大科普（转）