Java多线程之CountDownLatch
2013-08-20 22:05
429 查看
转 ' target='_blank'>http://blog.csdn.net/huang_xw/article/details/7090146[code=java] 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();
}
}
相关文章推荐
- Java多线程之CountDownLatch(一)
- Java:多线程等待所有线程结束(CountDownLatch/CyclicBarrier)
- Java多线程学习之 CountDownLatch 用法介绍
- Java多线程实战:FutureTask与CountDownLatch的完美结合
- Java多线程编程之CountDownLatch同步工具使用实例
- Java多线程之CountDownLatch
- Java多线程——6 并发流程控制CountDownLatch、CycliBarrier
- JAVA对多线程的两个有用的辅助类(CountDownLatch和AtomicBoolean)
- Java:多线程等待所有线程结束(CountDownLatch/CyclicBarrier) .
- 一直被忽略的java 多线程并发工具类 CountDownLatch、Semaphore
- java多线程组件一:CountDownLatch使用方法的总结
- Java多线程并发之CountDownLatch
- [Java并发]使用CountDownLatch和CyclicBarrier等待多线程完成
- Java基础:多线程之CountDownLatch、CyclicBarrier、Exchanger
- 【Java多线程与并发库】14.java5的CountDownLatch同步工具
- Java多线程知识点整理(CyclicBarrier、CountDownLatch、Callable、Future和FutureTask)
- Java多线程之~~~使用CountDownLatch来同步多个线程实现一个任务
- Java多线程:CountDownLatch、CyclicBarrier 和 Semaphore
- Java多线程20:多线程下的其他组件之CountDownLatch、Semaphore、Exchanger
- Java 多线程协调工具 CyclicBarrier 与CountDownLatch 学习