CountLaunch Demo的测试

public class Test {
     //CountLaunch demo 指定6个线程执行完后才能达到条件，继续向下进行
    // 处理文件的数量
    private static final int threadCount = 6;

    public static void main(String[] args) throws InterruptedException {
    
        // 创建一个具有固定线程数量的线程池对象（推荐使用构造方法创建）
        ExecutorService threadPool = Executors.newFixedThreadPool(10);
        final CountDownLatch countDownLatch = new CountDownLatch(threadCount);
        for (int i = 0; i < threadCount; i++) {
    
            final int threadnum = i;
            threadPool.execute(() -> {
    
                try {
    
                    //处理文件的业务操作
                    Thread.sleep(2);
                    //......
                } catch (InterruptedException e) {
    
                    e.printStackTrace();
                } finally {
    
                    //表示一个文件已经被完成
                    countDownLatch.countDown();
                }

            });
        }
        countDownLatch.await();
        threadPool.shutdown();
        System.out.println("finish");
    }
}