CountDownLatch同步工具類使用詳解
CountDownLatch 使用說明，供大家參考，具體內(nèi)容如下
CountDownLatch是一種java.util.concurrent包下一個(gè)同步工具類，它允許一個(gè)或多個(gè)線程等待直到在其他線程中一組操作執(zhí)行完成。
CountDownLatch的用法非常簡(jiǎn)單，下面的例子也是我在網(wǎng)上看到的，十分貼切，這里就貼出來
public class Test {
public static void main(String[] args) {
CountDownLatch begin = new CountDownLatch(1);
CountDownLatch end = new CountDownLatch(2);
for(int i=0; i<2; i++){
Thread thread = new Thread(new Player(begin,end));
thread.start();
}
try{
System.out.println("the race begin");
begin.countDown();
end.await();
System.out.println("the race end");
}catch(Exception e){
e.printStackTrace();
}
}
}
/**
* 選手
*/
class Player implements Runnable{
private CountDownLatch begin;
private CountDownLatch end;
Player(CountDownLatch begin,CountDownLatch end){
this.begin = begin;
this.end = end;
}
public void run() {
try {
begin.await();
System.out.println(Thread.currentThread().getName() + " arrived !");;
end.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
下面是運(yùn)行結(jié)果
可以看到 通過CountDownLatch 的使用 我們控制了線程的執(zhí)行順序。
在上面代碼中，我們使用到await()方法 和 countDown() 方法 。我們驗(yàn)證一下它們各自的作用。
首先 驗(yàn)證await() 方法。將main方法中的end.await() 注釋掉，下面是注釋掉后的運(yùn)行結(jié)果
可以看到主線程沒有等待代表選手的線程結(jié)束，直接宣布比賽結(jié)束了！剛開始就結(jié)束的比賽- -
這里可以看出，await() 方法具有阻塞作用
其次 我們來驗(yàn)證countDown方法，將代表選手線程中的end.countDown() 進(jìn)行注釋，下面是運(yùn)行結(jié)果
程序一直在運(yùn)行，所有選手都已經(jīng)到了終點(diǎn)，但是裁判就是不宣傳比賽結(jié)束，他在等什么呢？
我們猜測(cè)countDown() 方法具有喚醒阻塞線程的作用。
那我們也許會(huì)問，既然有喚醒阻塞線程的作用，那么我們只調(diào)用一次countDown() 方法不就是可以喚醒被阻塞的主線程了嗎？
我們?cè)囈幌?，取消上面coutDown()的注釋，再次創(chuàng)建一個(gè)選手，代碼如下
class Player2 implements Runnable{
private CountDownLatch begin;
private CountDownLatch end;
Player2(CountDownLatch begin,CountDownLatch end){
this.begin = begin;
this.end = end;
}
public void run() {
try {
begin.await();
System.out.println(Thread.currentThread().getName() + " arrived !");
// end.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
main 方法也修改如下，創(chuàng)建了兩個(gè)不同的選手
public static void main(String[] args)
{
CountDownLatch begin = new CountDownLatch(1);
CountDownLatch end = new CountDownLatch(2);
Thread thread = new Thread(new Player(begin, end));
thread.start();
Thread thread2 = new Thread(new Player2(begin, end));
thread2.start();
try
{
System.out.println("the race begin");
begin.countDown();
end.await();
System.out.println("the race end");
}
catch (Exception e)
{
e.printStackTrace();
}
}
運(yùn)行一下，下面是結(jié)果
主程序一直阻塞，沒有被喚醒，裁判上廁所上得有點(diǎn)久??！
這樣看來countDown() 并不是直接喚醒線程，有點(diǎn)像一個(gè)計(jì)數(shù)器，倒計(jì)時(shí)的那種。
查看API文檔，果然，我們?cè)跇?gòu)造函數(shù)中添加了參數(shù)2，就需要調(diào)用 2 次 countDown() 才能將 end.await() 阻塞的線程喚醒。
CountDownLatch end = new CountDownLatch(2);
總結(jié)一下，
1、CountDownLatch end = new CountDownLatch(N); //構(gòu)造對(duì)象時(shí)候 需要傳入?yún)?shù)N
2、end.await() 能夠阻塞線程 直到調(diào)用N次end.countDown() 方法才釋放線程
3、end.countDown() 可以在多個(gè)線程中調(diào)用 計(jì)算調(diào)用次數(shù)是所有線程調(diào)用次數(shù)的總和
下一篇博客，我將從源碼層面說明 CountDownLatch 的工作原理。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
java連接hdfs ha和調(diào)用mapreduce jar示例
這篇文章主要介紹了Java API連接HDFS HA和調(diào)用MapReduce jar包,需要的朋友可以參考下2014-03-03
Spring如何使用PropertyPlaceholderConfigurer讀取文件
這篇文章主要介紹了Spring如何使用PropertyPlaceholderConfigurer讀取文件,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
java控制Pdf自動(dòng)打印的小例子，需要的朋友可以參考一下2013-04-04
Java中遍歷數(shù)組使用foreach循環(huán)還是for循環(huán)？
這篇文章主要介紹了Java中遍歷數(shù)組使用foreach循環(huán)還是for循環(huán)？本文著重講解for語句的語法并給出使用實(shí)例,同時(shí)總結(jié)出盡量使用foreach語句遍歷數(shù)組,需要的朋友可以參考下2015-06-06
Spring 使用 feign時(shí)設(shè)置header信息的操作
這篇文章主要介紹了Spring 使用 feign時(shí)設(shè)置header信息的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-08-08
Java?Web開發(fā)常用框架Spring?MVC?Struts示例解析
這篇文章主要為大家介紹了Java?Web開發(fā)常用框架Spring?MVC?Struts示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-06-06
這篇文章主要介紹了java實(shí)現(xiàn)的冒泡排序算法,結(jié)合實(shí)例形式分析了冒泡排序算法的具體操作步驟與實(shí)現(xiàn)技巧,需要的朋友可以參考下2017-01-01
這篇文章主要介紹了java并發(fā)編程之cas詳解，涉及cas使用場(chǎng)景和cas用作原子操作等內(nèi)容，具有一定參考價(jià)值，需要的朋友可以了解下。2017-11-11
這篇文章主要介紹了SpringBoot jar包大小優(yōu)化問題及解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-11-11
IDEA搭建配置Java?Web項(xiàng)目的詳細(xì)步驟
這篇文章詳細(xì)介紹了如何使用IDEA創(chuàng)建和配置JavaWeb項(xiàng)目,包括項(xiàng)目結(jié)構(gòu)設(shè)置、WEB-INF目錄和jsp文件的創(chuàng)建,以及Tomcat的配置,是Java初學(xué)者的實(shí)用指南,需要的朋友可以參考下2024-10-10