基本使用

import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch;public class ListAdd2 {private volatile static List list = new ArrayList(); public void add(){list.add("cxf");}public int size(){return list.size();}public static void main(String[] args) {final ListAdd2 list2 = new ListAdd2();這個1代表發一次。。如果是2，countDown()執行兩次才會通知。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() {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添加了一個元素.. Exception in thread "t2" java.lang.RuntimeExceptionat java.lang.Thread.run(Thread.java:748) 已經發出通知.. 當前線程：t1添加了一個元素.. 當前線程：t2收到通知線程停止.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素.. 當前線程：t1添加了一個元素..Process finished with exit code 0

總結

new??CountDownLatch(1);//這個1代表發一次通知。。如果是2，需要調用countDown()兩次才會通知。

?

總結

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

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