Cyh的博客

Email:kissyan4916@163.com
posts - 26, comments - 19, trackbacks - 0, articles - 220

线程--CountDownLatch

Posted on 2009-12-23 23:20 啥都写点 阅读(460) 评论(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();
    }
}

 

                                                                                                       --    学海无涯