Java线程通信及线程虚假唤醒知识总结
更新时间：2021年06月28日 10:27:26 作者：少年做自己的英雄
今天给大家带来的是关于Java线程的相关知识,文章围绕着Java线程通信及线程虚假唤醒的知识展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下
线程通信
线程在内部运行时，线程调度具有一定的透明性，程序通常无法控制线程的轮换执行。但Java本身提供了一些机制来保证线程协调运行。
假设目前系统中有两个线程，分别代表存款和取钱。当钱存进去，立马就取出来挪入指定账户。这涉及到线程间的协作，使用到Object类提供的wait()、notify()、notifyAll()三个方法，其不属于Thread类，而属于Object，而这三个方法必须由监视器对象来调用：
- synchronized修饰的方法，因为该类的默认实例（this）就是同步监视器，因此可以在同步方法中直接调用
- synchronized修饰的同步代码块，同步监视器是synchronized括号里的对象，因此必须使用该对象来调用
三个方法解释如下：
- wait()：当前线程等待，释放当前对象锁，让出CPU，直到其他线程使用notify或者notifyAll唤醒该线程
- notify()：唤醒在此同步监视器上等待的单个线程，若存在多个线程，则随机唤醒一个。执行了notify不会马上释放锁，只有完全退出synchronized代码块或者中途遇到wait，呈wait状态的线程才可以去争取该对象锁
- notifyAll()：唤醒在此同步监视器上的所有线程，同上。
现在用两个同步方法分别代表存钱取钱
- 当余额为0时，进入存钱流程，执行存钱操作后，唤醒取钱线程
- 当余额为0时，进入取钱流程，发现num==0，进入阻塞状态，等待被唤醒
/**
* 存一块钱
*
* @throws InterruptedException
*/
public synchronized void increase() throws InterruptedException {
// 当余额为1，说明已经存过钱，等待取钱。存钱方法阻塞
if (num == 1) {
this.wait();
}
// 执行存钱操作
num++;
System.out.println(Thread.currentThread().getName() + ":num=" + num);
// 唤醒其他线程
this.notifyAll();
}
/**
* 取一块钱
*
* @throws InterruptedException
*/
public synchronized void decrease() throws InterruptedException {
// 当余额为0，说明已经取过钱，等待存钱。取钱方法阻塞
if (num == 0) {
this.wait();
}
num--;
System.out.println(Thread.currentThread().getName() + ":num=" + num);
this.notifyAll();
}
调用方法：
private int num = 0;
public static void main(String[] args) {
Test test = new Test();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.increase();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "存钱").start();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.decrease();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "取钱").start();
}
结果没有什么问题
线程虚假唤醒
上述线程通信看起来似乎没有什么问题，但若此时将存钱和取钱的人数各增加1，再看运行结果
private int num = 0;
public static void main(String[] args) {
Test test = new Test();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.increase();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "存钱1").start();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.decrease();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "取钱1").start();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.increase();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "存钱2").start();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
try {
test.decrease();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "取钱2").start();
}
产生的结果已经不是最初的只有0和1
造成这个结果的原因就是线程间的虚假唤醒
由于目前分别有多个取款和存款线程。假设其中一个存款线程执行完毕，并使用wait释放同步监视器锁定，那其余多个取款线程将同时被唤醒，此时余额为1，如果有10个同时取钱，那余额会变为-9，造成结果错误。
因此，每次线程从wait中被唤醒，都必须再次测试是否符合唤醒条件，如果不符合那就继续等待。
由于多个线程被同时唤醒，在if(xxxx){wait();}处 if判断只会执行一次，当下一个被唤醒的线程过来时，由于if已经判断过，则直接从wait后面的语句继续执行，因此将if换成while可解决该问题，下次被唤醒的线程过来，while重新判断一下，发现上一个被唤醒的线程已经拿到锁，因此这个被虚假唤醒的线程将继续等待锁。
/**
* 存一块钱
*
* @throws InterruptedException
*/
public synchronized void increase() throws InterruptedException {
while (num == 1) {// 防止每次进来的唤醒线程只判断一次造成虚假唤醒，替换成while
this.wait();
}
num++;
System.out.println(Thread.currentThread().getName() + ":num=" + num);
this.notifyAll();
}
/**
* 取一块钱
*
* @throws InterruptedException
*/
public synchronized void decrease() throws InterruptedException {
while (num == 0) {
this.wait();
}
num--;
System.out.println(Thread.currentThread().getName() + ":num=" + num);
this.notifyAll();
}
再次运行，结果正常：
到此这篇关于Java线程通信及线程虚假唤醒知识总结的文章就介绍到这了,更多相关Java线程通信及线程虚假唤醒内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
在Java中线程池是一种管理线程的机制,它可以创建一组线程并重复使用它们,避免了创建和销毁线程的开销,这篇文章主要给大家介绍了关于java创建线程池的7种实现方法,需要的朋友可以参考下2023-10-10
springboot整合websocket最基础入门使用教程详解
这篇文章主要介绍了springboot整合websocket最基础入门使用教程详解,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-03-03
解决SpringBoot运行Test时报错:SpringBoot Unable to find
这篇文章主要介绍了SpringBoot运行Test时报错：SpringBoot Unable to find a @SpringBootConfiguration，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-10-10
这篇文章主要为大家介绍了深入IDEA Debug问题透析详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-01-01
Springboot整合mybatis开启二级缓存的实现示例
在一级缓存中，是查询两次数据库的，显然这是一种浪费，既然SQL查询相同，就没有必要再次查库了，直接利用缓存数据即可，这种思想就是MyBatis二级缓存的初衷，本文就详细的介绍了Springboot整合mybatis开启二级缓存，感兴趣的可以了解一下2022-05-05
这篇文章主要为大家详细介绍了java简单实现计算器，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-12-12
这篇文章主要介绍了关于Idea清除缓存并重启解决的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-09-09
这篇文章主要介绍了 ArrayList和HashMap如何自己实现的相关资料,需要的朋友可以参考下2016-12-12
这篇文章主要介绍了SpringBoot 关于Feign的超时时间配置操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-09-09
项目中如果查询数据是直接到MySQL数据库中查询的话，会查磁盘走IO，效率会比较低，所以现在一般项目中都会使用缓存，目的就是提高查询数据的速度，将数据存入缓存中，也就是内存中，这样查询效率大大提高2022-11-11
最新评论