911精品国产亚洲日本美国韩国 ,777亚洲精品乱码久久久久久 ,亚洲一级毛片免费观看

線程--CountDownLatch

Posted on 2009-12-23 23:20 啥都寫點閱讀(469) 評論(0) 編輯收藏所屬分類: J2SE

本例介紹第二種同步裝置：CountDownLatch，它維護一個計數器，等待這個CountDownLatch的線程必須等到計數器為0時才可以繼續。本例模擬服務器的啟動，假設啟動一個服務器需要初始化3個組件，當3個組件初始化完畢時，服務器才算成功啟動。

構造CountDownLatch對象時，需要制定計數器的初始值，該值必須大于等于0，一旦對象被創建，其初始值將不能被改變。

CountDownLatch的await方法使當前線程進入等待狀態，直到計數器為0.

CountDownLatch的countDown方法使計數器減1.

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

* CountDownLatch是個計數器，它有一個初始數，

* 等待這個計數器的線程必須等到計數器倒數到零時才可繼續。

public class CountDownLatchTest {

/**

* 初始化組件的線程

public static class ComponentThread implements Runnable {

// 計數器

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!");

//將計數器減一

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就可繼續了

System.out.println("Server is up!");

}

public static void main(String[] args) throws Exception {

CountDownLatchTest.startServer();

}

-- 學海無涯

Cyh的博客

導航

公告

常用鏈接

隨筆檔案(25)

文章分類(219)

文章檔案(220)

新聞檔案(66)

相冊

收藏夾(7)

最新隨筆

搜索

最新評論

閱讀排行榜

線程--CountDownLatch