溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Java項(xiàng)目中如何等待與喚醒線程

發(fā)布時(shí)間：2020-11-20 15:35:22 來源：億速云 閱讀：177 作者：Leah 欄目：編程語言

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)Java項(xiàng)目中如何等待與喚醒線程，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

DEMO1： wait() 與 notify()

public class Test {

 static class ThreadOne extends Thread {

  private Callback mCallback;

  @Override
  public void run() {
   work();
   if (mCallback != null) {
    mCallback.onResult(false);
   }
  }

  // 耗時(shí) 3s
  private void work() {
   System.out.println(" 正在查詢數(shù)據(jù)庫 1");
   long startTime = System.currentTimeMillis();
   while (true) {
    if (System.currentTimeMillis() - startTime < 3000) {
     continue;
    }
    break;
   }
  }

  public void setCallback(Callback callback) {
   mCallback = callback;
  }

  public interface Callback {
   void onResult(boolean result);
  }
 }

 static class ThreadTest extends Thread {

  private Object mLock = new Object();

  private ThreadOne mThreadOne;

  @Override
  public void run() {
   workOne();
   System.out.println(" 根據(jù)結(jié)果繼續(xù)做其他事情 ");
  }

  private void workOne() {
   mThreadOne = new ThreadOne();
   mThreadOne.setCallback(new ThreadOne.Callback() {
    @Override
    public void onResult(boolean result) {
     System.out.println(" 查詢數(shù)據(jù)庫 1 結(jié)束，:" + (result &#63; " 有數(shù)據(jù) " : " 無數(shù)據(jù) "));
     synchronized (mLock) {
      mLock.notify();
      System.out.println("--ThreadTest 結(jié)束等待 --");
     }
    }
   });
   mThreadOne.start();
   try {
    synchronized (mLock) {
     System.out.println("--ThreadTest 進(jìn)入等待 --");
     mLock.wait();
    }
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }

 public static void main(String[] var0) {
  ThreadTest threadTest = new ThreadTest();
  threadTest.start();
 }
}

DEMO1 輸出：

--ThreadTest 進(jìn)入等待--
正在查詢數(shù)據(jù)庫 1
查詢數(shù)據(jù)庫 1 結(jié)束，: 無數(shù)據(jù)
--ThreadTest 結(jié)束等待--
根據(jù)結(jié)果繼續(xù)做其他事情

注意：
使用 wait() 和 notify() 必須在獲得同步鎖后才能調(diào)用，若直接調(diào)用會(huì)報(bào) java.lang.IllegalMonitorStateException 錯(cuò)誤，因?yàn)闋顟B(tài)由同步鎖保護(hù)。

wait() 不同于 sleep() 的是 wait() 會(huì)釋放同步鎖。

因?yàn)?wait() 和 notify() 是基于同步鎖實(shí)現(xiàn)的，每個(gè)對(duì)象都有自己的同步鎖，所以 wait() 和 notify() 是 Object 的方法，而不是 Thread。

DEMO2，wait() 與 notifyAll()：

public class Test {

 private static Object mLock = new Object();

 static class MyThread extends Thread {

  String mName;
  Callback mCallback;

  public MyThread(String name){
   mName = name;
  }

  @Override
  public void run() {
   work();
   if (mCallback != null) {
    mCallback.onResult(false);
   }
  }

  // 耗時(shí) 3s
  private void work() {
   System.out.println(mName + " 等待 ");
   try {
    synchronized (mLock) {
     mLock.wait();
    }
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }

  public void setCallback(Callback callback) {
   mCallback = callback;
  }

  public interface Callback {
   void onResult(boolean result);
  }
 }

 static class ThreadTest extends Thread {



  @Override
  public void run() {
   work("db1");
   work("db2");
   work("db3");

   try {
    sleep(2000);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }

   synchronized (mLock) {
    System.out.println(" 喚醒全部 ");
    mLock.notifyAll();
   }
  }

  private void work(String name) {
   final MyThread myThread = new MyThread(name);
   myThread.setCallback(new MyThread.Callback() {
    @Override
    public void onResult(boolean result) {
     System.out.println(myThread.mName + " 回來了 ");
    }
   });
   myThread.start();
  }
 }

 public static void main(String[] var0) {
  ThreadTest threadTest = new ThreadTest();
  threadTest.start();
 }
}

DEMO2 輸出：

db1 等待
db3 等待
db2 等待
喚醒全部
db3 回來了
db1 回來了
db2 回來了

同一個(gè)對(duì)象的 wait() 方法可多次在不同的線程中調(diào)用，可讓不同的線程進(jìn)入等待（阻塞），可以一個(gè)一個(gè) notify()，也可以調(diào)用 notifyAll() 一次性全部喚醒。

上述就是小編為大家分享的Java項(xiàng)目中如何等待與喚醒線程了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手