Java CountDownLatch与CyclicBarrier及Semaphore使用教程

 更新时间:2023年01月04日 08:34:48   作者:欲无缘  
对于并发执行,Java中的CountDownLatch是一个重要的类。为了更好的理解CountDownLatch这个类,本文将通过例子和源码带领大家深入解析CountDownLatch与CyclicBarrier及Semaphore的原理,感兴趣的可以学习一下

CountDownLatch

CountDownLatch是一个倒数的计数器阀门,初始化时阀门关闭,指定计数的数量,当数量倒数减到0时阀门打开,被阻塞线程被唤醒。

public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
    // 总数是6,必须要执行任务的时候,再使用    !
    CountDownLatch countDownLatch = new CountDownLatch(6);
    for (int i = 1; i <=6 ; i++) {    
        new Thread(()->{
        System.out.println(Thread.currentThread().getName()+" Go out");
        countDownLatch.countDown(); // 数量-1
        },String.valueOf(i)).start();
    }  
    countDownLatch.await(); // 等待计数器归零,然后再向下执行
    System.out.println("Close Door");
    }
}

原理

countDownLatch.countDown();//数量-1

countDownLatch.await();//等待

每次有线程调用 countDown() 数量-1,假设计数器变为0,countDownLatch.await() 就会被唤醒,继续执行!

CyclicBarrier

CyclicBarrier是一个可循环的屏障,它允许多个线程在执行完相应的操作后彼此等待共同到达一个point,等所有线程都到达后再继续执行。

CyclicBarrier也可以像CountDownLatch一样适用于多个子任务并发执行,当所有子任务都执行完后再继续接下来的工作。

public class CyclicBarrierDemo {
    public static void main(String[] args) {
         // 召唤龙珠的线程
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{
            System.out.println("召唤神龙成功!");
        });
        for (int i = 1; i <=7 ; i++) {
            final int temp = i;
            // lambda能操作到 i 吗
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"收集"+temp+"个龙珠");
                try {
                cyclicBarrier.await(); // 等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

Semaphore

Semaphore翻译过来是信号量的意思,它的作用是控制多个线程对同一个资源的访问线程数量。比如在停车场停车,里面有10个车位,当这10个车位被停满的时候其他的车只能等待(堵塞)里面有车驶出(release)然后再进入。

public class SemaphoreDemo {
    public static void main(String[] args) {
        // 线程数量:停车位! 限流!
        Semaphore semaphore = new Semaphore(3);
        for (int i = 1; i <=6 ; i++) {
            new Thread(()->{
            // acquire() 得到
            try {
                semaphore.acquire();
                System.out.println(Thread.currentThread().getName()+"抢到车位");
                TimeUnit.SECONDS.sleep(2);
                System.out.println(Thread.currentThread().getName()+"离开车位");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                semaphore.release(); // release() 释放
            }
        },String.valueOf(i)).start();
        }
    }
}

semaphore.acquire();获得,假设如果已经满了,等待,等待被释放为止!

semaphore.release();释放,会将当前的信号量释放 + 1,然后唤醒等待的线程!

作用: 多个共享资源互斥的使用!并发限流,控制最大的线程数!

到此这篇关于Java CountDownLatch与CyclicBarrier及Semaphore使用教程的文章就介绍到这了,更多相关Java CountDownLatch内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • mybatis中关于mapper的使用以及注意事项

    mybatis中关于mapper的使用以及注意事项

    这篇文章主要介绍了mybatis中关于mapper的使用以及注意事项,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-06-06
  • java中简单的截取分割字符串实例

    java中简单的截取分割字符串实例

    下面小编就为大家带来一篇java中简单的截取分割字符串实例。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-03-03
  • 使用Swagger时Controller中api接口显示不全的问题分析及解决

    使用Swagger时Controller中api接口显示不全的问题分析及解决

    swagger是一个十分好用的api接口管理、测试框架,现在越来越多的人使用这个做接口的测试和管理,但经常遇到Controller中的api接口显示不全的问题,所以本文给大家详细分析了问题以及解决方法,需要的朋友可以参考下
    2024-02-02
  • 解决JPA @OneToMany及懒加载无效的问题

    解决JPA @OneToMany及懒加载无效的问题

    这篇文章主要介绍了解决JPA @OneToMany及懒加载无效的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-10-10
  • Java导出Word文档的实现方法详解

    Java导出Word文档的实现方法详解

    这篇文章主要给大家介绍了关于Java导出Word文档的实现方法,在日常的开发工作中,我们时常会遇到导出Word文档报表的需求,比如公司的财务报表、医院的患者统计报表、电商平台的销售报表等等,需要的朋友可以参考下
    2023-08-08
  • springboot单元测试两种方法实例详解

    springboot单元测试两种方法实例详解

    这篇文章主要介绍了springboot单元测试两种方法实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • 浅谈Java当作数组的几个应用场景

    浅谈Java当作数组的几个应用场景

    数组可以存放多个同一类型的数据,可以存储基本数据类型,引用数据类型(对象),下面这篇文章主要给大家介绍了关于Java当作数组的几个应用场景,需要的朋友可以参考下
    2022-11-11
  • SpringBoot 基于 MongoTemplate 的工具类过程详解

    SpringBoot 基于 MongoTemplate 的工具类过程详解

    MongoDB是一个高性能,开源,无模式的文档型数据库,是当前NoSql数据库中比较热门的一种,这篇文章主要介绍了SpringBoot基于MongoTemplate的工具类,需要的朋友可以参考下
    2023-09-09
  • Spring Boot接口支持高并发具体实现代码

    Spring Boot接口支持高并发具体实现代码

    这篇文章主要给大家介绍了关于Spring Boot接口支持高并发具体实现的相关资料,在SpringBoot项目中通常我们没有处理并发问题,但是使用项目本身还是支持一定的并发量,需要的朋友可以参考下
    2023-08-08
  • 关于spring事务传播行为非事务方式的理解

    关于spring事务传播行为非事务方式的理解

    这篇文章主要介绍了对spring事务传播行为非事务方式的全面理解,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11

最新评论