Java并发工具类（一）CountDownLatch

妖狐艹你老母 2022-03-20 09:54 260阅读 0赞

## Java并发工具类（一） CountDownLatch ##

在J.U.C并发包中提供了一些工具类，可以供我们在日常的开发中，根据不同的情况去进行一些相关的并发控制，具体的类有：

> CountDownLatch  
> Semaphore  
> Exchanger  
> CyclicBarrier

### CountDownLatch ###

#### 概念 ####

计时器必须大于等于0,只是等于0的时候,计时器就是0,调用await()方法时,不会阻塞当前线程,`CountDownLatch`不可能重新初始化或者修改`CountDownLatch`对象的内部计数器的值,`CountDownLatch`具有不可逆性。

#### 扩展 ####

在笔者的实现中进行了扩展，在加入了`Thread.sleep(3000)`和`countDownLatch.await(10000, TimeUnit.MILLISECONDS)`之后我们可以通过控制时间长短，来分情况讨论具体事件的发生。

public static void main(String[] args) { 
            final CountDownLatch countDownLatch = new CountDownLatch(3);
            new Thread("老板") { 
                public void run() { 
                    try { 
                        Thread.sleep(3000);
                        System.out.println(Thread.currentThread().getName() + "开始吃饭。。。");
                        countDownLatch.countDown();
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
    
                ;
            }.start();
            new Thread("经理") { 
                public void run() { 
                    try { 
                        Thread.sleep(3000);
                        System.out.println(Thread.currentThread().getName() + "开始吃饭。。。");
                        countDownLatch.countDown();
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
    
                ;
            }.start();
            new Thread("总监") { 
                public void run() { 
                    try { 
                        Thread.sleep(3000);
                        System.out.println(Thread.currentThread().getName() + "开始吃饭。。。");
                        countDownLatch.countDown();
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
    
                ;
            }.start();
            System.out.println("等待领导开始动筷子,小弟才能开始吃饭。。。");
            try { 
                countDownLatch.await(10000, TimeUnit.MILLISECONDS);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
            System.out.println("小弟可以吃饭了。。。");
        }

#### 执行结果 ####

等待领导开始动筷子,小弟才能开始吃饭。。。
    老板开始吃饭。。。
    经理开始吃饭。。。
    总监开始吃饭。。。
    小弟可以吃饭了。。。

### CountDownLatch对比join ###

相同点：都是为了控制线程的执行顺序
    不同点：join更侧重于线程单一顺序执行，CountDownLatch更侧重于保证要执行的线程在线面一些（或一个）线程执行之后；join更灵活，CountDownLatch性能可能会更好。

### 完整代码和相关依赖请见GitHub ###

[https://github.com/dwyanewede/project-learn/tree/master/src/main/java/com/learn/demo/concurrent][https_github.com_dwyanewede_project-learn_tree_master_src_main_java_com_learn_demo_concurrent]

### 相关文章推荐 ###

Java并发工具类（二）CyclicBarrier [https://blog.csdn.net/shang\_xs/article/details/87077098][https_blog.csdn.net_shang_xs_article_details_87077098]  
Java并发工具类（三）Exchanger [https://blog.csdn.net/shang\_xs/article/details/87078321][https_blog.csdn.net_shang_xs_article_details_87078321]  
Java并发工具类（四）Semaphore [https://blog.csdn.net/shang\_xs/article/details/87090443][https_blog.csdn.net_shang_xs_article_details_87090443]

[https_github.com_dwyanewede_project-learn_tree_master_src_main_java_com_learn_demo_concurrent]: https://github.com/dwyanewede/project-learn/tree/master/src/main/java/com/learn/demo/concurrent
[https_blog.csdn.net_shang_xs_article_details_87077098]: https://blog.csdn.net/shang_xs/article/details/87077098
[https_blog.csdn.net_shang_xs_article_details_87078321]: https://blog.csdn.net/shang_xs/article/details/87078321
[https_blog.csdn.net_shang_xs_article_details_87090443]: https://blog.csdn.net/shang_xs/article/details/87090443