Java多線程通訊之wait,notify的區別詳解

2024-07-14 08:41:48

字體：大中小

來源：轉載

供稿：網友

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

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){//偶數     res.username="小明";     res.sex="男";    } else {//奇數     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(); }}小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女

出現以上結果？？消費者一直消費或者生產者一直生產

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

wait、notify、notifyAll方法

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

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

如果對象調用了wait方法就會使持有該對象的線程把該對象的控制權交出去，然后處于等待狀態。當前線程從運行變為阻塞，釋放所的資源

如果對象調用了notify方法就會通知某個正在等待這個對象的控制權的線程可以繼續運行。讓持有該鎖的線程從阻塞態變為就緒。

如果對象調用了notifyAll方法就會通知所有等待這個對象控制權的線程繼續運行。

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

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

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

class Res{ public String username; public String sex; //true 生產者等待，消費者可消費 false生產者可以生產，消費者不可消費 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();//讓當前線程從運行變為阻塞，并且釋放所的資源     } catch (InterruptedException e) {      e.printStackTrace();     }    }    if(count==0){//偶數     res.username="小明";     res.sex="男";    } else {//奇數     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(); }}

輸出如下：