脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → JAVA 线程通信

JAVA 线程通信相关知识汇总

 更新时间：2020年06月16日 16:39:19   作者：追  
这篇文章主要介绍了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 线程通信的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • Spring 缓存抽象示例详解

    Spring 缓存抽象示例详解

    Spring框架自身并没有实现缓存解决方案，但是从3.1开始定义了org.springframework.cache.Cache和org.springframework.cache.CacheManager接口，提供对缓存功能的声明，能够与多种流行的缓存实现集成。这篇文章主要介绍了Spring 缓存抽象 ,需要的朋友可以参考下
    2018-09-09
  • 使用指定的JDK启动IDEA的三种方法

    使用指定的JDK启动IDEA的三种方法

    今天小编就为大家分享一篇关于使用指定的JDK启动IDEA的三种方法，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
    2018-12-12
  • java常用工具类 UUID、Map工具类

    java常用工具类 UUID、Map工具类

    这篇文章主要为大家详细介绍了Java常用工具类，包括UUID工具类、Map工具类，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-05-05
  • 详解SpringBoot如何使用JWT实现身份认证和授权

    详解SpringBoot如何使用JWT实现身份认证和授权

    JSON Web Token（JWT）是一种用于在网络应用之间安全传递信息的开放标准,本文主要为大家介绍了如何在Spring Boot中使用JWT实现身份认证和授权,需要的可以了解下
    2023-10-10
  • 解读spark添加二方包导致依赖冲突排查问题

    解读spark添加二方包导致依赖冲突排查问题

    这篇文章主要介绍了spark添加二方包导致依赖冲突排查问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-06-06
  • 高内聚低耦合法则实例解析

    高内聚低耦合法则实例解析

    这篇文章主要介绍了高内聚低耦合法则实例代码解析，具有一定借鉴价值,需要的朋友可以参考下。
    2017-12-12
  • Spring Boot企业常用的starter示例详解

    Spring Boot企业常用的starter示例详解

    这篇文章主要给大家介绍了关于Spring Boot企业常用starter的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用Spring Boot具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-12-12
  • Java基础之位运算知识总结

    Java基础之位运算知识总结

    最近接触到了java位运算,之前对位运算的了解仅仅停留在表现结果上,乘2除以2,对背后的原理并不了解,现在学习记录一下,需要的朋友可以参考下
    2021-05-05
  • Java使用路径通配符加载Resource与profiles配置使用详解

    Java使用路径通配符加载Resource与profiles配置使用详解

    这篇文章主要介绍了Java使用路径通配符加载Resource与profiles配置使用详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-06-06
  • 解决Tomcat启动报异常java.lang.ClassNotFoundException问题

    解决Tomcat启动报异常java.lang.ClassNotFoundException问题

    这篇文章主要介绍了解决Tomcat启动报异常java.lang.ClassNotFoundException问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2023-01-01

最新评论