最近フラワーコーヒーを購入しました。豆はコーヒーマシンから出てきたもので、花は先週陽朔への旅行中に買ったキンモクセイの花でした。
コーヒーの味は少し軽めで、キンモクセイの香りが多めです。
本題に入りましょう:
この記事では、 wait() Notice() NoticeAll() を学習しましょう。
DEMO1: wait() と Notice()
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 ? " 有数据 " : " 无数据 ")); 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() は、wait() が同期ロックを解放するという点で sleep() とは異なります。
wait() と Notify() は同期ロックに基づいて実装されているため、各 object は独自の同期ロックを持っているため、wait() と Notify() は Thread ではなく Object のメソッドです。
DEMO2、wait() および NoticeAll():
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() メソッドを異なるスレッドで複数回呼び出すことができ、異なるスレッドを待機 (ブロック) させることができます。 1つずつnotify()を実行することも、notifyAll()を呼び出してすべてを一度に起動することもできます。
【関連する推奨事項】
以上がJava マルチスレッドの基本に関するサンプル チュートリアルを共有するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。