快捷導(dǎo)航

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

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

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

下面通過(guò)代碼給大家介紹java多線(xiàn)程通訊之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() {
  //寫(xiě)操作
  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é)果？？消費(fèi)者一直消費(fèi)或者生產(chǎn)者一直生產(chǎn)

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

wait、notify、notifyAll方法

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

這三個(gè)方法最終調(diào)用的都是jvm級(jí)的native方法。隨著jvm運(yùn)行平臺(tái)的不同可能有些許差異。

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

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

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

注意:一定要在線(xiàn)程同步中使用,并且是同一個(gè)鎖的資源

通過(guò)以下方式即可完成需求。

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

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

 public Out(Res res){
  this.res=res;
 }
 @Override
 public void run() {
  //寫(xiě)操作
  int count=0;
  while (true){
   synchronized (res.getClass()){
    if(res.flag){
     try {
      res.getClass().wait();//讓當(dāng)前線(xiàn)程從運(yùn)行變?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();
 }
}

輸出如下：

小明,男
小紅,女
小明,男
小紅,女
小明,男
小紅,女
小明,男
小紅,女

如果去掉notify會(huì)怎樣？去掉一個(gè)？去掉兩個(gè)？

去掉一個(gè)生產(chǎn)者可以打印多個(gè)（但是也不多），去掉消費(fèi)者僅可打印一個(gè)，去掉兩個(gè)可能不打印，也可能打印1個(gè)，所以wait、notify必須成對(duì)使用

wait（用于同步中）與sleep區(qū)別?

都是做休眠，wait需要notify

對(duì)于sleep方法，我們首先要知道該方法是屬于Thread類(lèi)中的。而wait方法，則是屬于Object類(lèi)中的。

sleep方法導(dǎo)致了程序暫停執(zhí)行指定的時(shí)間，讓出cpu該其他線(xiàn)程，但是他的監(jiān)控狀態(tài)依然保持者，當(dāng)指定的時(shí)間到了又會(huì)自動(dòng)恢復(fù)運(yùn)行狀態(tài)。

在調(diào)用sleep方法的過(guò)程中，線(xiàn)程不會(huì)釋放對(duì)象鎖。

而當(dāng)調(diào)用wait方法的時(shí)候，線(xiàn)程會(huì)放棄對(duì)象鎖，進(jìn)入等待此對(duì)象的等待鎖定池，只有針對(duì)此對(duì)象調(diào)用notify方法后本線(xiàn)程才進(jìn)入對(duì)象鎖定池準(zhǔn)備獲取對(duì)象鎖進(jìn)入運(yùn)行狀態(tài)。

總結(jié)

以上所述是小編給大家介紹的Java多線(xiàn)程通訊之wait,notify的區(qū)別詳解，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: