ITPub博客

首页 > Linux操作系统 > Linux操作系统 > 同步辅助类CountDownLatch的例子

同步辅助类CountDownLatch的例子

原创 Linux操作系统 作者:21ca 时间:2009-08-11 15:51:13 0 删除 编辑
就是使用一个计数器作为锁。在项目中遇到这样一种情形,要处理一批订单,处理完成之后需要报告成功多少,失败多少。为了采用多线程机制,即每个订单启动一个线程(用线程池管理),当所有订单完成之后,还要通知主线程进行统计报告,就想到了CountDownLatch。

下面是一个简单的例子。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchTest {
   
    static class SimpleThread extends Thread {

        private CountDownLatch latch;

        public SimpleThread(CountDownLatch latch){
            this.latch = latch;
        }
       
        @Override
        public void run() {
            System.out.println(this + " RUNNING.");
            latch.countDown();
        }
       
    }

    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(5);
       
        for(int i=0; i<5; i++) {
            new SimpleThread(latch).start();
        }
       
        //等待所有子线程处理完成。
        latch.await();
        System.out.println("Over");
    }
}

运行结果:
Thread[Thread-2,5,main] RUNNING.
Thread[Thread-0,5,main] RUNNING.
Thread[Thread-1,5,main] RUNNING.
Thread[Thread-4,5,main] RUNNING.
Thread[Thread-3,5,main] RUNNING.
Over

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/10742815/viewspace-611904/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2009-03-24

  • 博文量
    58
  • 访问量
    81401