JAVA 线程通信相关知识汇总
两个线程之间的通信
多线程环境下CPU会随机的在线程之间进行切换，如果想让两个线程有规律的去执行，那就需要两个线程之间进行通信，在Object类中的两个方法wait和notify可以实现通信。
wait方法可以使当前线程进入到等待状态，在没有被唤醒的情况下，线程会一直保持等待状态。
notify方法可以随机唤醒单个在等待状态下的线程。
来实现这样的一个功能：
让两个线程交替在控制台输出一行文字
定义一个Print类，有两个方法print1和print2，分别打印一行不同的内容
package com.sutaoyu.volatlt;
public class Print {
private int flag = 1;
public void print1() {
synchronized(this) {
if(flag != 1) {
try {
//让当前线程进入等入状态
this.wait();
}catch(InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("monkey");
flag = 2;
//随机的唤醒单个等待的线程
this.notify();
}
}
public void print2() {
synchronized(this) {
if(flag != 2) {
try {
this.wait();
}catch (InterruptedException e){
e.printStackTrace();
}
}
System.out.println("1024");
flag = 1;
this.notify();
}
}
}
定义线程测试类，开启两个线程，分别运行Print类中print1和print2方法
package com.sutaoyu.volatlt;
public class NotifyTest01 {
public static void main(String[] args) {
Print p = new Print();
Thread t1 = new Thread() {
public void run() {
while(true) {
p.print1();
}
}
};
Thread t2 = new Thread() {
public void run() {
while(true) {
p.print2();
}
}
};
t1.start();
t2.start();
}
}
三个及三个以上的线程之间的通信
改造上面代码在Print类中添加一个print3方法，再开启第三个线程来执行这个方法。
另外需要修改的地方是：
1.因为notifyAll方法可以唤醒所有等待状态的线程，所有用notifyAll方法来替代notify方法
2.当线程被唤醒后，需要先判断一下flag的值，if不会重新判断flag值，而while会重新判断flag的值，所以将Print中的if判断修改为while判断。
package com.sutaoyu.volatlt;
public class Print {
private int flag = 1;
public void print1() {
synchronized(this) {
while(flag != 1) {
try {
//让当前线程进入等入状态
this.wait();
}catch(InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("monkey");
flag = 2;
//随机的唤醒单个等待的线程
this.notifyAll();
}
}
public void print2() {
synchronized(this) {
while(flag != 2) {
try {
this.wait();
}catch (InterruptedException e){
e.printStackTrace();
}
}
System.out.println("1024");
flag = 3;
this.notifyAll();
}
}
public void print3() {
synchronized(this) {
while(flag != 3) {
try {
this.wait();
}catch(InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("888");
flag = 1;
this.notifyAll();
}
}
}
package com.sutaoyu.volatlt;
public class NotifyTest01 {
public static void main(String[] args) {
Print p = new Print();
Thread t1 = new Thread() {
public void run() {
while(true) {
p.print1();
}
}
};
Thread t2 = new Thread() {
public void run() {
while(true) {
p.print2();
}
}
};
Thread t3 = new Thread() {
public void run() {
while(true) {
p.print3();
}
}
};
t1.start();
t2.start();
t3.start();
}
}
线程通信注意事项
在print1,2,3方法中同步代码块中使用哪个对象作为锁，那在调用wait和notify方法时一定要调用这个对象上的wait和notify方法。
上面程序使用this作为对象锁，在下面调用的都是this.wait()和this.notify()方法。
在多线程执行当中
wait方法释放对象锁，根据上面的代码示例，t1,t2,t3三个线程使用的是同一个对象锁，如果wait方法不释放锁的话，别的线程就不能获取到该锁，也就不能获取cpu的执行权了。
sleep和notify方法不释放对象锁，上面代码示例中，如果notify方法释放锁的话，别的线程就有可能获取到cpu的执行权，这样子就会导致当前notify方法后面的代码还未执行完毕就失去了cpu的执行权，从而导致一些问题，只有当线程执行完synchronized代码块后才会释放锁。
以上就是JAVA 线程通信相关知识汇总的详细内容，更多关于JAVA 线程通信的资料请关注脚本之家其它相关文章！
相关文章
springboot HandlerIntercepter拦截器修改request body数据的操作
这篇文章主要介绍了springboot HandlerIntercepter拦截器修改request body数据的操作，具有很好的参考价值，希望对大家有所帮助。2021-06-06
Java中区别.toString() ,(String),valueOf()方法
这篇文章主要介绍了Java中区别.toString() ,(String),valueOf()方法,需要的朋友可以参考下2017-01-01
这篇文章主要给大家介绍了关于Java匿名内部类的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-08-08
SWT(JFace) Wizard(Eclipse插件编程必备)
SWT(JFace)小制作：Wizard(Eclipse插件编程必备)2009-06-06
本文主要介绍了MyBatis各种类型查询数据参数绑定的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-06-06
这篇文章主要介绍了maven查看jar的pom引入来源,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2023-07-07
SpringBoot自带Tomcat，直接运行main方法里面的SpringApplication.run即可，并且访问时不需要带项目名，这篇文章主要介绍了Idea启动多个SpringBoot项目的3种方案,需要的朋友可以参考下2023-02-02
这篇文章主要给大家介绍了关于SpringBoot实现API接口的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-10-10
在项目开发中，一般文件存储很少再使用SFTP服务，但是也不排除合作伙伴使用SFTP来存储项目中的文件或者通过SFTP来实现文件数据的交互，这篇文章主要介绍了SpringBoot集成FTP与SFTP连接池2022-12-12
spring boot @PathVariable传递带反斜杠参数 / 的处理
这篇文章主要介绍了spring boot @PathVariable传递带反斜杠参数 / 的处理操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-02-02
最新评论