java多线程之countDownlatch

CountDownLatch类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。比如有一个任务A,它要等待其他4个任务执行完毕之后才能执行,此时就可以利用CountDownLatch来实现这种功能了(类似join()方法)。

public class TreadCountDownLatch {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(2);
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("我是子线程"+Thread.currentThread().getName()+"开始执行任务...");
                try {
                    Thread.sleep(10);
                    System.out.println("我是子线程"+Thread.currentThread().getName()+"执行结束...");
                    countDownLatch.countDown();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("我是子线程"+Thread.currentThread().getName()+"开始执行任务...");
                try {
                    Thread.sleep(10);
                    System.out.println("我是子线程"+Thread.currentThread().getName()+"执行结束...");
                    countDownLatch.countDown();//每次调用减1
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        }).start();
        countDownLatch.await();//阻塞当前线程 ,直到计数为0时,阻塞状态变为运行状态
        System.out.println("我是主线程"+Thread.currentThread().getName()+"继续执行...");
    }
}

 执行结果:

 


版权声明:本文为renjf_spring原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。