本篇我們來研究一下 wait() notify() notifyAll() 。
DEMO1： wait() 與 notify()
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
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 輸出：
|
1
2
3
4
5
|
--ThreadTest 進入等待--正在查詢數據庫 1查詢數據庫 1 結束，: 無數據--ThreadTest 結束等待--根據結果繼續做其他事情 |
注意：
使用 wait() 和 notify() 必須在獲得同步鎖后才能調用，若直接調用會報 java.lang.IllegalMonitorStateException 錯誤，因為狀態由同步鎖保護。
wait() 不同于 sleep() 的是 wait() 會釋放同步鎖。
因為 wait() 和 notify() 是基于同步鎖實現的，每個對象都有自己的同步鎖，所以 wait() 和 notify() 是 Object 的方法，而不是 Thread。
DEMO2，wait() 與 notifyAll()：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
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() 一次性全部喚醒。
原文鏈接：http://hackeris.me/2017/05/07/thread_base_1/
