JDK5.0新特性系列---11.5.2线程 同步装置之CountDownLatch
2011-12-17 23:35
337 查看
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* CountDownLatch维护一个计数器,等待这个CountDownLatch的线程必须等到计数器为0时才可以继续.
* 以下实例模拟服务器的启动,假设启动一个服务器需要初始化3个组件,当3个组件初始化完毕后,服务器才算成功启动.
*/
/**
* 使用CountDownLatch的关键技术点如下:
* 1.构造CountDownLatch对象时,需要指定计数器的初始值,该值必须大于等于0,一旦对象被创建,其初始值将不能被改变.
* 2.CountDownLatch的await方法使当前线程进入等待状态,直到计数器为0
* 3.CountDownLatch的 和countDown方法使计数器减1.
*/
public class CountDownLatchTest {
/** 初始化组件的线程 */
public static class ComponentThread implements Runnable {
CountDownLatch latch; //计数器
int ID; //组件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(); //将计数器减1
}
}
/** 启动服务器 */
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();
latch.await();//等待3个组件的初始化工作都完成
System.out.println("Server is up!");//当所需的三个组件都完成时,Server就可以继续了
}
public static void main(String... args) throws Exception {
CountDownLatchTest.startServer();
}
}
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* CountDownLatch维护一个计数器,等待这个CountDownLatch的线程必须等到计数器为0时才可以继续.
* 以下实例模拟服务器的启动,假设启动一个服务器需要初始化3个组件,当3个组件初始化完毕后,服务器才算成功启动.
*/
/**
* 使用CountDownLatch的关键技术点如下:
* 1.构造CountDownLatch对象时,需要指定计数器的初始值,该值必须大于等于0,一旦对象被创建,其初始值将不能被改变.
* 2.CountDownLatch的await方法使当前线程进入等待状态,直到计数器为0
* 3.CountDownLatch的 和countDown方法使计数器减1.
*/
public class CountDownLatchTest {
/** 初始化组件的线程 */
public static class ComponentThread implements Runnable {
CountDownLatch latch; //计数器
int ID; //组件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(); //将计数器减1
}
}
/** 启动服务器 */
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();
latch.await();//等待3个组件的初始化工作都完成
System.out.println("Server is up!");//当所需的三个组件都完成时,Server就可以继续了
}
public static void main(String... args) throws Exception {
CountDownLatchTest.startServer();
}
}
相关文章推荐
- JDK5.0 特性线程 同步装置之CountDownLatch 同步装置之CyclicBarrier 线程 BlockingQueue
- 11.5.2线程 同步装置之CountDownLatch
- 11.5线程----同步装置之CountDownLatch
- JDK5.0新特性系列---11.5.1线程 同步装置之Semaphore
- JDK5.0新特性系列---11.5.3线程 同步装置之CyclicBarrier
- JDK5.0新特性系列---11.5.4线程 同步装置之Exchanger
- Java/Android多线程并发、同步,线程之间通信,主、子线程的一些问题(CountDownLatch、CyclicBarrier和Semaphore)
- 12____java线程同步工具类之同步计数器(CountDownLatch)
- java 线程 CountDownLatch 同步工具
- Java多线程之~~~使用CountDownLatch来同步多个线程实现一个任务
- JDK5.0新特性系列---11.4线程 Condition
- java线程同步之CountDownLatch
- 采用Thread.join()或CountDownLatch来实现线程间同步
- 多线程系列十一-同步CountDownLatch、CyclicBarrier和Semaphore
- 线程同步辅助-CountDownLatch(搬迁至此)
- (二)juc线程高级特性——CountDownLatch / Callable / Lock
- 两种常用的线程计数器CountDownLatch和循环屏障CyclicBarrier
- Java多线程协作CountDownLatch,主线程等待子线程结束
- CountDownLatch--一组线程完成后其他线程才执行(一)
- (12)java5的CountDownLatch、Exchanger同步工具