java.util.concurrent.CountDownLatch

古城微笑少年丶 2022-06-06 10:13 143阅读 0赞

## java.util.concurrent.CountDownLatch ##

### 概述 ###

CountDownLatch被用来同步一个或多个任务，强制它们等待由其它任务执行的一组操作完成。  
可以向CountDownLatch对象设置一个初始计数值，任何在这个对象上调用await()方法的线程都将被阴塞，直到这个计数值等于0。其它线程在执行完毕时，可以通过调用countDown()方法来减少CountDownLatch对象的初始计数值。  
CountDownLatch的典型用法是将一个程序分为n个互相独立的可解决任务，并创建数值为n的CountDownLatch对象。

以上内容参考Java编程思想第四版

### 代码示例： ###

public static void main(String[] args) {
    
            /** * 设置CountDownLatch的初始计数值为2， * 表明需要调用两次countDown()方法来唤醒被await()方法阻塞的线程 */
            final CountDownLatch countDownLatch = new CountDownLatch(2);
    
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("进入线程1，等待其它线程处理完成。。。。。。");
                    try {
                        /** * 通知主线程阻塞，需要等待同一组操作中的其它线程执行完毕， * 并调用countDown()方法对CountDownLatch的初始计数值进行修改， * 直到初始计数值等于0的时候才开始继续执行 */
                        countDownLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("其它线程处理完毕，t1线程继续执行");
                }
            });
    
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("t2线程开始初始化动作");
                    try {
                        // 休眠3秒钟，模拟线程处理业务的过程
                        Thread.sleep(3000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("t2线程执行完成");
    
                    // 调用countDown()方法通知被await()方法阴塞的线程
                    /** * countDown()方法每调用一次，CountDownLatch的初始计数值就会减少1， * 当初始计数值等于0的时候，被await()阴塞的线程便可以继续执行了 */
                    countDownLatch.countDown();
                    /** * 由于CountDownLatch的初始计数值等于2，所以countDown()需要调用两次来唤醒被await()方法阻塞的线程 */
                    countDownLatch.countDown();
                }
            });
    
            // 启动线程
            t1.start();
            t2.start();
    
        }

#### CountDownLatch应用场景 ####

待设计

源代码链接：  
[https://github.com/myNameIssls/javase-study/blob/master/javase-multithreading/src/main/java/cn/tyrone/javase/concurrent/CountDownLatchDemo.java][https_github.com_myNameIssls_javase-study_blob_master_javase-multithreading_src_main_java_cn_tyrone_javase_concurrent_CountDownLatchDemo.java]

[https_github.com_myNameIssls_javase-study_blob_master_javase-multithreading_src_main_java_cn_tyrone_javase_concurrent_CountDownLatchDemo.java]: https://github.com/myNameIssls/javase-study/blob/master/javase-multithreading/src/main/java/cn/tyrone/javase/concurrent/CountDownLatchDemo.java

java.util.concurrent.CountDownLatch

发表评论取消回复

还没有评论，来说两句吧...

相关阅读