Java多线程循环栅栏CyclicBarrier正确使用方法

 更新时间:2023年09月24日 09:49:37   作者:呆小鱼LQ  
这篇文章主要介绍了Java多线程循环栅栏CyclicBarrier正确使用方法详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

前言

本篇文章的代码示例已放到 github 上,Git地址为:advance(记录每一个学习过程),大家把代码下载下来之后,全局搜索一些关键代码,即可找到该文章的源码。

使用场景

想象一个这样的场景,我们在打王者荣耀/英雄联盟的时候,都会有一个匹配机制,需要10个人都加载完成后,大家才能一起进入游戏,不然会出现大家进入游戏的时间不一致的情况,这个时候就可以使用CyclicBarrier来实现。

基本原理

使用CyclicBarrier的线程被叫做参与方,它的内部维护了一个显式锁。参与方只需要执行await()就可以参与等待,此时这些线程会被暂停。当最后一个线程执行await()方法后,其他被暂停的线程都会被唤醒,而最后一个线程不会被暂停。

常用方法

//构造器,定义参与的线程数
CyclicBarrier cyclicBarrier = new CyclicBarrier(10);
//构造器,可以传入跳栅后需要执行的线程
public CyclicBarrier(int parties, Runnable barrierAction);
//将屏障重置为其初始状态
void reset()
//进行等待
int await()
//进行等待,同时具备超时时间
public int await(long timeout, TimeUnit unit)

使用示例

定义玩家运行程序

public class CyclicBarrierRunnable implements Runnable{
    private CyclicBarrier cyclicBarrier;
    private int number;
    public CyclicBarrierRunnable(CyclicBarrier cyclicBarrier, int number) {
        this.cyclicBarrier = cyclicBarrier;
        this.number = number;
    }
    @Override
    public void run() {
        System.out.println("玩家" + number + "号正在加载游戏...");
        try {
            TimeUnit.SECONDS.sleep(2);
            cyclicBarrier.await();
        } catch (Exception e) {
            System.out.println("线程执行出现问题");
        }
        System.out.println("玩家" + number + "号加载完成。");
    }
}

定义主程序

public class Main {
    public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(10);
        //获取参与方的总数
        System.out.println("参与方的总数为:" + cyclicBarrier.getParties());
        //获取此时等待的线程数
        System.out.println("此时等待的线程数为:" + cyclicBarrier.getNumberWaiting());
        for (int i = 0; i < 10; i++){
            CyclicBarrierRunnable runnable = new CyclicBarrierRunnable(cyclicBarrier, i);
            new Thread(runnable).start();
        }
    }
}

运行结果

执行说明

主线程每隔2秒会启动一个子线程执行,子线程打印“准备执行”后,会调用await()方法进行等待,从结果我们可以看出:当最后一个CyclicBarrier.await()方法被执行后,所有的等待线程同时被唤醒,同时开始执行。

内部原理

CyclicBarrier内部使用了一个条件变量trip来实现等待/通知。

CyclicBarrier内部实现使用了分代的概念用于表示CyclicBarrier实例是可以重复使用的。

除最后一个线程外的任何一个参与方都相当于一个等待线程,这些线程所使用的保护条件是:“当前分代内,尚未执行await方法的参与方个数为0”。await()方法每被执行一次,相应实例的parties值会减少1.最后一个线程相当于通知线程,它执行await()会使相应实例的parties的值变为0,此线程会先执行barrierAction.run(),然后再执行trip.signalAll()来唤醒所有等待线程。

注意事项

  • 使用reset()方法将屏障置为初始状态时,如果所有参与者目前都在屏障处等待,则将他们唤醒,同时抛出一个BrokenBarrierException异常

以上就是Java多线程循环栅栏CyclicBarrier正确使用方法的详细内容,更多关于Java多线程循环栅栏CyclicBarrier的资料请关注脚本之家其它相关文章!

相关文章

  • Spring boot详解fastjson过滤字段为null值如何解决

    Spring boot详解fastjson过滤字段为null值如何解决

    这篇文章主要介绍了解决Spring boot中fastjson过滤字段为null值的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-07-07
  • IDEA之IDEA连接gitlab协同开发方式

    IDEA之IDEA连接gitlab协同开发方式

    通过IDEA克隆GitLab项目实现代码协同开发相较于使用SourceTree, 通过IDEA连接GitLab进行代码协同开发更显便捷,方法包括通过VersionControl创建新项目,输入项目的git HTTP地址和本地路径,测试连接成功后克隆项目,修改代码后
    2024-11-11
  • 一文搞懂Java正则表达式的使用

    一文搞懂Java正则表达式的使用

    正则表达式,又称规则表达式,是一种文本模式。正则表达式使用单个字符串来描述、匹配一系列匹配某个句法规则的字符串,通常被用来检索、替换那些符合某个模式(规则)的文本。本文将通过示例为大家详细说说Java正则表达式的使用,感兴趣的可以了解一下
    2022-08-08
  • springboot项目访问图片的3种实现方法(亲测可用)

    springboot项目访问图片的3种实现方法(亲测可用)

    本文主要介绍了springboot项目访问图片的3种实现方法,通过springboot项目访问除项目根目录之外的其它目录的图片,具有一定的参考价值,感兴趣的可以了解一下
    2023-09-09
  • 浅谈MyBatis原生批量插入的坑与解决方案

    浅谈MyBatis原生批量插入的坑与解决方案

    本文主要介绍了浅谈MyBatis原生批量插入的坑与解决方案,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-10-10
  • mybatis-plus排除非表中字段的操作

    mybatis-plus排除非表中字段的操作

    这篇文章主要介绍了mybatis-plus排除非表中字段的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • 使用Maven中的scope总结

    使用Maven中的scope总结

    这篇文章主要介绍了使用Maven中的scope总结,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • 关于消息中间件RocketMQ的基本概念及功能

    关于消息中间件RocketMQ的基本概念及功能

    这篇文章主要介绍了关于消息中间件RocketMQ的基本概念及功能,RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等,需要的朋友可以参考下
    2023-05-05
  • 分析Java中Map的遍历性能问题

    分析Java中Map的遍历性能问题

    随着JDK 1.8 Streams API的发布,使得HashMap拥有了更多的遍历的方式,但应该选择那种遍历方式?反而成了一个问题。本文从几个方面来分析 HashMap各种遍历方式的优势与不足
    2021-06-06
  • Java集合之整体结构

    Java集合之整体结构

    Java中集合类是Java编程中使用最频繁、最方便的类。接下来通过本文给大家介绍Java集合之整体结构,一起看看吧
    2016-05-05

最新评论