최근에 꽃커피를 샀어요. 원두는 커피머신에서 나왔는데 꽃은 지난주 양숴 여행 때 사온 계수나무 꽃이에요.
커피 맛은 조금 더 가볍고 계수나무 향이 더 많이 납니다.
요점:
이 글에서는 wait() inform() informAll() 을 공부할 것입니다.
DEMO1: wait() 및 inform()
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() 및 inform() 사용은 다음과 같아야 합니다. in 동기화 잠금을 획득한 후에만 호출할 수 있습니다. 직접 호출하면 state가 동기화 잠금으로 보호되므로 java.lang.IllegalMonitorStateException 오류가 보고됩니다.
wait()는 wait()가 동기화 잠금을 해제한다는 점에서 sleep()과 다릅니다.
wait() 및 inform()은 동기화 잠금을 기반으로 구현되므로 각 객체 에는 자체 동기화 잠금이 있으므로 wait() 및 inform()은 Object의 메서드가 아닌 Object의 메서드입니다. 실.
DEMO2, wait() 및 informAll():
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() 메서드는 다른 스레드에서 여러 번 호출될 수 있습니다. , 다른 스레드가 대기(차단)할 수 있도록 허용합니다. 통지()를 하나씩 수행하거나 통지All()을 호출하여 한 번에 모두 깨울 수 있습니다.
[관련 추천]
3.Java 스레드 동기화 및 동기화 방법에 대한 자세한 설명
위 내용은 Java 멀티스레딩의 기본 사항에 대한 예제 튜토리얼 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!