免费观看又色又爽又黄的小说免费_美女福利视频国产片_亚洲欧美精品_美国一级大黄大色毛片

Java項目中如何等待與喚醒線程

這期內容當中小編將會給大家帶來有關Java項目中如何等待與喚醒線程,文章內容豐富且以專業的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。

包河ssl適用于網站、小程序/APP、API接口等需要進行數據傳輸應用場景,ssl證書未來市場廣闊!成為成都創新互聯的ssl證書銷售渠道,可以享受市場價格4-6折優惠!如果有意向歡迎電話聯系或者加微信:18982081108(備注:SSL證書合作)期待與您的合作!

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);
   }
  }

  // 耗時 3s
  private void work() {
   System.out.println(" 正在查詢數據庫 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(" 根據結果繼續做其他事情 ");
  }

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

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

DEMO1 輸出:

--ThreadTest 進入等待--
正在查詢數據庫 1
查詢數據庫 1 結束,: 無數據
--ThreadTest 結束等待--
根據結果繼續做其他事情

注意:
使用 wait() 和 notify() 必須在獲得同步鎖后才能調用,若直接調用會報 java.lang.IllegalMonitorStateException 錯誤,因為狀態由同步鎖保護。

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

因為 wait() 和 notify() 是基于同步鎖實現的,每個對象都有自己的同步鎖,所以 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);
   }
  }

  // 耗時 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 回來了

同一個對象的 wait() 方法可多次在不同的線程中調用,可讓不同的線程進入等待(阻塞),可以一個一個 notify(),也可以調用 notifyAll() 一次性全部喚醒。

上述就是小編為大家分享的Java項目中如何等待與喚醒線程了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關知識,歡迎關注創新互聯行業資訊頻道。

標題名稱:Java項目中如何等待與喚醒線程
文章位置:http://m.newbst.com/article28/gpjjjp.html

成都網站建設公司_創新互聯,為您提供網站設計搜索引擎優化網站制作電子商務App開發品牌網站制作

廣告

聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯

成都seo排名網站優化