Java多線程通訊之wait,notify的區(qū)別詳解

更新時間：2018年07月24日 09:39:20 作者：LoseMyFuture

這篇文章主要介紹了Java多線程通訊之wait,notify的區(qū)別詳解，非常不錯，具有一定的參考借鑒借鑒價值,需要的朋友可以參考下

下面通過代碼給大家介紹java多線程通訊之wait notify的區(qū)別，具體內(nèi)容如下所示：

class Res{
 public String username;
 public String sex;
}
class Out extends Thread{
 Res res;
 public Out(Res res){
  this.res=res;
 }
 @Override
 public void run() {
  //寫操作
  int count=0;
  while (true){
//   synchronized (res.getClass()){
    if(count==0){//偶數(shù)
     res.username="小明";
     res.sex="男";
    } else {//奇數(shù)
     res.username="小紅";
     res.sex="女";
    }
    count=(count+1)%2;
//   }
   }
 }
}
class Input extends Thread{
 Res res;
 public Input(Res res){
  this.res=res;
 }
 @Override
 public void run() {
  while (true){
//   synchronized (res.getClass()){
    System.out.println(res.username+","+res.sex);
//   }
  }
 }
}
public class OutInputThread {
 public static void main(String[] args) {
  Res res = new Res();
  Out out = new Out(res);
  Input input = new Input(res);
  out.start();
  input.start();
 }
}
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女

出現(xiàn)以上結(jié)果？？消費者一直消費或者生產(chǎn)者一直生產(chǎn)

解決方法：生產(chǎn)者生產(chǎn)完成后消費者方可消費，否者不可消費，消費者未消費或者未消費完生產(chǎn)者不可生產(chǎn)，一次生產(chǎn)一次消費。其實也就是保證對res共享資源的操作同一時刻僅有同一個線程進行操作，

wait、notify、notifyAll方法

wait、notify、notifyAll是三個定義在Object類里的方法，可以用來控制線程的狀態(tài)。

這三個方法最終調(diào)用的都是jvm級的native方法。隨著jvm運行平臺的不同可能有些許差異。

如果對象調(diào)用了wait方法就會使持有該對象的線程把該對象的控制權(quán)交出去，然后處于等待狀態(tài)。當前線程從運行變?yōu)樽枞?，釋放所的資源

如果對象調(diào)用了notify方法就會通知某個正在等待這個對象的控制權(quán)的線程可以繼續(xù)運行。讓持有該鎖的線程從阻塞態(tài)變?yōu)榫途w。

如果對象調(diào)用了notifyAll方法就會通知所有等待這個對象控制權(quán)的線程繼續(xù)運行。

注意:一定要在線程同步中使用,并且是同一個鎖的資源

通過以下方式即可完成需求。

生產(chǎn)者獲取res.getClass鎖后，如果flag為true生產(chǎn)者通過調(diào)用res.getClass.wait進行等待，此時其他線程可獲取該鎖，如果flag為false，進行生產(chǎn)，然后設置flag為true保證資源消費后方可再生產(chǎn)，接著通過notify通知其他喚醒其他線程。

class Res{
 public String username;
 public String sex;
 //true 生產(chǎn)者等待，消費者可消費 false生產(chǎn)者可以生產(chǎn)，消費者不可消費
 public boolean flag=false;
}
class Out extends Thread{
 Res res;

 public Out(Res res){
  this.res=res;
 }
 @Override
 public void run() {
  //寫操作
  int count=0;
  while (true){
   synchronized (res.getClass()){
    if(res.flag){
     try {
      res.getClass().wait();//讓當前線程從運行變?yōu)樽枞?，并且釋放所的資源
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
    if(count==0){//偶數(shù)
     res.username="小明";
     res.sex="男";
    } else {//奇數(shù)
     res.username="小紅";
     res.sex="女";
    }
    count=(count+1)%2;
    res.flag=true;
    res.getClass().notify();
   }
   }

 }
}
class Input extends Thread{
 Res res;
 public Input(Res res){
  this.res=res;
 }

 @Override
 public void run() {
  while (true){
   synchronized (res.getClass()){
    if(!res.flag){
     try {
      res.getClass().wait();
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
    System.out.println(res.username+","+res.sex);
    res.flag=false;
    res.getClass().notify();
   }
  }
 }
}
public class OutInputThread {
 public static void main(String[] args) {
  Res res = new Res();
  Out out = new Out(res);
  Input input = new Input(res);
  out.start();
  input.start();
 }
}

輸出如下：