java線程并發(fā)countdownlatch類使用示例
package com.yao;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* CountDownLatch是個計數(shù)器,它有一個初始數(shù),
* 等待這個計數(shù)器的線程必須等到計數(shù)器倒數(shù)到零時才可繼續(xù)。
*/
public class CountDownLatchTest {
/**
* 初始化組件的線程
*/
public static class ComponentThread implements Runnable {
// 計數(shù)器
CountDownLatch latch;
// 組件ID
int ID;
// 構造方法
public ComponentThread(CountDownLatch latch, int ID) {
this.latch = latch;
this.ID = ID;
}
public void run() {
// 初始化組件
System.out.println("Initializing component " + ID);
try {
Thread.sleep(500 * ID);
} catch (InterruptedException e) {
}
System.out.println("Component " + ID + " initialized!");
//將計數(shù)器減一
latch.countDown();
}
}
/**
* 啟動服務器
*/
public static void startServer() throws Exception {
System.out.println("Server is starting.");
//初始化一個初始值為3的CountDownLatch
CountDownLatch latch = new CountDownLatch(3);
//起3個線程分別去啟動3個組件
ExecutorService service = Executors.newCachedThreadPool();
service.submit(new ComponentThread(latch, 1));
service.submit(new ComponentThread(latch, 2));
service.submit(new ComponentThread(latch, 3));
service.shutdown();
//等待3個組件的初始化工作都完成
latch.await();
//當所需的三個組件都完成時,Server就可繼續(xù)了
System.out.println("Server is up!");
}
public static void main(String[] args) throws Exception {
CountDownLatchTest.startServer();
}
}
相關文章
Java數(shù)據(jù)結構之鏈表、棧、隊列、樹的實現(xiàn)方法示例
這篇文章主要介紹了Java數(shù)據(jù)結構之鏈表、棧、隊列、樹的實現(xiàn)方法,結合實例形式分析了Java數(shù)據(jù)結構中鏈表、棧、隊列、樹的功能、定義及使用方法,需要的朋友可以參考下2019-03-03idea64.exe.vmoptions文件如何設置調(diào)整VM配置文件
這篇文章主要介紹了idea64.exe.vmoptions文件如何設置調(diào)整VM配置文件問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-04-04IDEA 中創(chuàng)建并部署 JavaWeb 程序的方法步驟(圖文)
本文主要介紹了IDEA 中創(chuàng)建并部署 JavaWeb 程序的方法步驟,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2022-02-02解釋為什么Java中“1000==1000”為false而”100==100“為true
在日常編程中,我們經(jīng)常遇到一些看似簡單卻隱藏著復雜邏輯的問題,這篇文章主要介紹了解釋為什么Java中“1000==1000”為false而”100==100“為true,需要的朋友可以參考下2024-01-01