public class ListAdd2 {private volatile static List list = new ArrayList(); public void add(){list.add("bjsxt");}public int size(){return list.size();}public static void main(String[] args) {final ListAdd2 list2 = new ListAdd2();// 1 實例化出來一個 lock// 當使用wait 和 notify 的時候 ， 一定要配合著synchronized關鍵字去使用final Object lock = new Object();Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {try {synchronized (lock) {for(int i = 0; i <10; i++){list2.add();System.out.println("當前線程：" + Thread.currentThread().getName() + "添加了一個元素..");Thread.sleep(500);if(list2.size() == 5){System.out.println("已經發出通知..");lock.notify();}} }} catch (InterruptedException e) {e.printStackTrace();}}}, "t1");Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (lock) {if(list2.size() != 5){try {System.out.println("t2進入...");lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("當前線程：" + Thread.currentThread().getName() + "收到通知線程停止..");}}}, "t2"); t2.start();t1.start();}}

輸出結果

t2進入... 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 已經發出通知.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t2收到通知線程停止..

可以看出來wait方法會讓出鎖的使用權，而notify不會讓出來
現在引入了CountDownLatch方法

CountDownLatch是通過“共享鎖”實現的。在創建CountDownLatch中時，會傳遞一個int類型參數count，該參數是“鎖計數器”的初始狀態，表示該“共享鎖”最多能被count線程同時獲取。當某線程調用該CountDownLatch對象的await()方法時，該線程會等待“共享鎖”可用時，才能獲取“共享鎖”進而繼續運行。而“共享鎖”可用的條件，就是“鎖計數器”的值為0！而“鎖計數器”的初始值為count，每當一個線程調用該CountDownLatch對象的countDown()方法時，才將“鎖計數器”-1；通過這種方式，必須有count個線程調用countDown()之后，“鎖計數器”才為0，而前面提到的等待線程才能繼續運行！

CountDownLatch的兩個主要方法

// 使當前線程在鎖存器倒計數至零之前一直等待，除非線程被中斷。
void await()

// 遞減鎖存器的計數，如果計數到達零，則釋放所有等待的線程。
void countDown()

package heihei;import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; /*** wait notfiy 方法，wait釋放鎖，notfiy不釋放鎖* @author alienware**/ public class ListAdd2 {private volatile static List list = new ArrayList(); public void add(){list.add("bjsxt");}public int size(){return list.size();}public static void main(String[] args) {final ListAdd2 list2 = new ListAdd2();final CountDownLatch countDownLatch = new CountDownLatch(1);Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {try {for(int i = 0; i <10; i++){list2.add();System.out.println("當前線程：" + Thread.currentThread().getName() + "添加了一個元素..");Thread.sleep(500);if(list2.size() == 5){System.out.println("已經發出通知..");countDownLatch.countDown();}} } catch (InterruptedException e) {e.printStackTrace();}}}, "t1");Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {//synchronized (lock) {if(list2.size() != 5){try {countDownLatch.await();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("當前線程：" + Thread.currentThread().getName() + "收到通知線程停止..");throw new RuntimeException();}}, "t2"); t2.start();t1.start();}}

這樣做的話輸出結果是

當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 已經發出通知.. 當前線程：t1添加了一個元素.. 當前線程：t2收到通知線程停止.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素..

順序正確

總結

以上是生活随笔為你收集整理的notify和wait的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。