JAVA并发编程之 - CountDownLatch使用场景分析

yy736044583 发布于2019-08-19 10:17 / 2384人阅读

摘要：今天我们来聊一聊的使用场景。使用场景在某些业务情况下，要求我们等某个条件或者任务完成后才可以继续处理后续任务。同时在线程完成时也会触发一定事件。方便业务继续向下执行。第个毒贩如果当前已经没有可以毒贩，立刻返回被干掉了干掉一个。

作者 : 毕来生
微信: 878799579

前言

在 java.util.concurrent 包中提供了多种并发容器类来改进同步容器的性能。今天我们来聊一聊CountDownLatch 的使用场景。看看它到底是怎么玩耍的。

CountDownLatch 是干什么的？

CountDownLatch 一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。

CountDownLatch原理

CountDownLatch是通过一个计数器来实现的，计数器的初始化值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就相应得减1。当计数器到达0时，表示所有的线程都已完成任务，然后在闭锁上等待的线程就可以恢复执行任务。

使用场景

在某些业务情况下，要求我们等某个条件或者任务完成后才可以继续处理后续任务。同时在线程完成时也会触发一定事件。方便业务继续向下执行。这个时候我们的CountDownLatch就隆重登场啦。常用核心方法为

    /**
     * 递减计数器的计数，如果计数达到0，则释放所有等待的线程。
     * 如果当前计数大于0，则将计数减少。
     * 如果新的计数为0，会重启所有等待线程
     * 如果当前计数等于0，则不做任何操作
     **/
    public void countDown() {
        sync.releaseShared(1);
    }
    /**
     * 1、当前线程在倒数至0之前会一直等待
     * 2、除非线程被中断或超出了指定的时间。
     * 3、如果当前计数为0，立刻返回为true
     * 4、如果当前计数等于0，则不做任何操作
     * 5、如果当前线程在进入此方法时已经设置了该线程的中断状态，
     *      或者在等待时被中断，则抛出InterruptedException
     **/
    public boolean await(long timeout, TimeUnit unit)
            throws InterruptedException {
        return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
    }

实战演练

package org.bilaisheng.juc;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @Author: bilaisheng
 * @Wechat: 878799579
 * @Date: 2019/1/2 23:30
 * @Todo: CountDownLatch demo。
 * @Version : JDK11 , IDEA2018
 */
public class CountDownLatchTest {

    // 举个例子：有十个毒贩在和警察激战
    public static void main(String[] args) throws InterruptedException {

        // 开始计数器
        final CountDownLatch start = new CountDownLatch(1);
        // 结束计数器
        final CountDownLatch end = new CountDownLatch(10);

        final ExecutorService executorService = Executors.newFixedThreadPool(10);

        for (int i = 1; i <= 10; i++) {
            // 这个变量纯粹为了掩饰到底哪个倒霉先被干掉。
            final String criminal = "第"+i+"个毒贩";
            Runnable task = new Runnable() {
                @Override
                public void run() {
                    try {
                        // 如果当前已经没有可以毒贩，立刻返回
                        start.await();
                        Thread.sleep(500);
                        System.out.println(criminal + "被干掉了！");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        // 干掉一个。毒贩活着的数量就减1
                        end.countDown();
                    }
                }
            };
            executorService.submit(task);
        }

        // 抓捕开始
        start.countDown();
        //  全都被干掉了（计数器为0)
        end.await();
        // 任务完成：收工回家
        executorService.shutdown();
    }
}

闭锁可以延迟线程的进度直到其到达终止状态,闭锁可以用来确保某些活动直到其他活动都完成才继续执行:

确保某个计算在其需要的所有资源都被初始化之后才继续执行;

确保某个服务在其依赖的所有其他服务都已经启动之后才启动;

等待直到某个操作所有参与者都准备就绪再继续执行。

喜欢就关注我吧

超融合服务器混合云 java并发编程编程语言场景使用场景易语言编程之

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/75765.html

高并发

摘要：表示的是两个，当其中任意一个计算完并发编程之是线程安全并且高效的，在并发编程中经常可见它的使用，在开始分析它的高并发实现机制前，先讲讲废话，看看它是如何被引入的。电商秒杀和抢购，是两个比较典型的互联网高并发场景。干货：深度剖析分布式搜索引擎设计分布式，高可用，和机器学习一样，最近几年被提及得最多的名词，听名字多牛逼，来，我们一步一步来击破前两个名词，今天我们首先来说说分布式。探究...

supernavy 2019-07-25 14:10 评论0 收藏0
高并发

摘要：表示的是两个，当其中任意一个计算完并发编程之是线程安全并且高效的，在并发编程中经常可见它的使用，在开始分析它的高并发实现机制前，先讲讲废话，看看它是如何被引入的。电商秒杀和抢购，是两个比较典型的互联网高并发场景。干货：深度剖析分布式搜索引擎设计分布式，高可用，和机器学习一样，最近几年被提及得最多的名词，听名字多牛逼，来，我们一步一步来击破前两个名词，今天我们首先来说说分布式。探究...

ddongjian0000 2019-06-24 17:56 评论0 收藏0
高并发

摘要：表示的是两个，当其中任意一个计算完并发编程之是线程安全并且高效的，在并发编程中经常可见它的使用，在开始分析它的高并发实现机制前，先讲讲废话，看看它是如何被引入的。电商秒杀和抢购，是两个比较典型的互联网高并发场景。干货：深度剖析分布式搜索引擎设计分布式，高可用，和机器学习一样，最近几年被提及得最多的名词，听名字多牛逼，来，我们一步一步来击破前两个名词，今天我们首先来说说分布式。探究...

wangdai 2019-08-15 13:49 评论0 收藏0
Java并发编程之CountDownLatch源码解析

摘要：一导语最近在学习并发编程原理，所以准备整理一下自己学到的知识，先写一篇的源码分析，之后希望可以慢慢写完整个并发编程。了解了的构造函数之后，我们再来看它的核心代码，首先是。一、导语最近在学习并发编程原理，所以准备整理一下自己学到的知识，先写一篇CountDownLatch的源码分析，之后希望可以慢慢写完整个并发编程。二、什么是CountDownLatch CountDownLatc...

arashicage 2019-08-16 16:45 评论0 收藏0
Java多线程编程实战：模拟大量数据同步

摘要：所以得出结论需要分配较多的线程进行读数据，较少的线程进行写数据。注意多线程编程对实际环境和需求有很大的依赖，需要根据实际的需求情况对各个参数做调整。背景最近对于 Java 多线程做了一段时间的学习，笔者一直认为，学习东西就是要应用到实际的业务需求中的。否则要么无法深入理解，要么硬生生地套用技术只是达到炫技的效果。不过笔者仍旧认为自己对于多线程掌握不够熟练，不敢轻易应用到生产代码中...

elliott_hu 2019-08-16 15:04 评论0 收藏0