CountDownLatch 的使用

Posted 2021-11-27 bj-xiaodao

CountDownLatch

这个类使用起来比较简单.使用场景就是 你需要很多线程执行结束之后才执行最后的代码,那用这个就对了. 这个类底层是用aqs来实现的.

这类主要使用的方法

count.await();
count.countDown();

里面的API很少

结束线程await()

1.countDown

2.被阻塞的线程interrupt()

  private static CountDownLatch count = new CountDownLatch(1);
    public static void main(String[] args) throws InterruptedException {
        Thread t =Thread.currentThread();

        new Thread(()->{
            try {
                Thread.sleep(2000);
                t.interrupt();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }).start();

        System.out.println("阻塞....");
        count.await();
        System.out.println("=====");

    }
}

View Code

 就是比如你有几个线程需要跑批你的任务你可以在countDown初始化的时候把线程数方进入

每一个线程结束的时候调用coutDown -1 等所有线程都执行结束之后.可以进行汇总