CyclicBarrier（应对并发问题的工具类）

news/2024/12/22 9:10:34/

CyclicBarrier

5.3.1 概述以及基本使用

CyclicBarrier的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障

才会开门，所有被屏障拦截的线程才会继续运行。

例如：公司召集5名员工开会，等5名员工都到了，会议开始。我们创建5个员工线程，1个开会线程，几乎同时启动，使用CyclicBarrier保证5名员工线程全部执行后，再执行开会线程。

CyclicBarrier的相关方法

java">public CyclicBarrier(int parties, Runnable barrierAction)   // 用于在线程到达屏障时，优先执行barrierAction，方便处理更复杂的业务场景
public int await()											// 每个线程调用await方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞

案例演示：模拟员工开会

实现步骤：

  1. 创建一个员工线程类(EmployeeThread),该线程类中需要定义一个CyclicBarrier类型的形式参数
  2. 创建一个开会线程类(MettingThread)
  3. 测试类
    1. 创建CyclicBarrier对象
    2. 创建5个EmployeeThread线程对象，把第一步创建的CyclicBarrier对象作为构造方法参数传递过来
    3. 启动5个员工线程

员工线程类

java">public class EmployeeThread extends Thread {// CyclicBarrier类型的成员变量private CyclicBarrier cyclicBarrier ;public EmployeeThread(CyclicBarrier cyclicBarrier) {        // 使用构造方法对CyclicBarrier进行初始化this.cyclicBarrier = cyclicBarrier ;}@Overridepublic void run() {try {// 模拟开会人员的随机到场Thread.sleep((int) (Math.random() * 1000));System.out.println(Thread.currentThread().getName() + " 到了! ");cyclicBarrier.await();} catch (Exception e) {e.printStackTrace();}}}

开会线程类

java">public class MettingThread extends Thread {@Overridepublic void run() {System.out.println("好了，人都到了，开始开会......");}}

测试类

java">public class CyclicBarrierDemo01 {public static void main(String[] args) {// 创建CyclicBarrier对象CyclicBarrier cyclicBarrier = new CyclicBarrier(5 , new MettingThread()) ;// 创建5个EmployeeThread线程对象，把第一步创建的CyclicBarrier对象作为构造方法参数传递过来EmployeeThread thread1 = new EmployeeThread(cyclicBarrier) ;EmployeeThread thread2 = new EmployeeThread(cyclicBarrier) ;EmployeeThread thread3 = new EmployeeThread(cyclicBarrier) ;EmployeeThread thread4 = new EmployeeThread(cyclicBarrier) ;EmployeeThread thread5 = new EmployeeThread(cyclicBarrier) ;// 启动5个员工线程thread1.start();thread2.start();thread3.start();thread4.start();thread5.start();}}

5.3.2 使用场景

使用场景：CyclicBarrier可以用于多线程计算数据，最后合并计算结果的场景。

比如：现在存在两个文件，这个两个文件中存储的是某一个员工两年的工资信息(一年一个文件)，现需要对这两个文件中的数据进行汇总；使用两个线程读取2个文件中的数据，当两个文

件中的数据都读取完毕以后，进行数据的汇总操作。

分析：要想在两个线程读取数据完毕以后进行数据的汇总，那么我们就需要定义一个任务类(该类需要实现Runnable接口)；两个线程读取完数据以后再进行数据的汇总，那么我们可以将

​ 两个线程读取到的数据先存储到一个集合中，而多线程环境下最常见的线程集合类就是ConcurrentHashMap，而这个集合需要被两个线程都可以进行使用，那么我们可以将这个集

​ 合作为我们任务类的成员变量，然后我们在这个任务类中去定义一个CyclicBarrier对象，然后在定义一个方法(count)，当调用这个count方法的时候需要去开启两个线程对象，

​ 使用这两个线程对象读取数据，把读取到的数据存储到ConcurrentHashMap对象，当一个线程读取数据完毕以后，调用CyclicBarrier的awit方法(告诉CyclicBarrier我已经

​ 到达了屏障)，然后在任务类的run方法对ConcurrentHashMap的数据进行汇总操作；

实现步骤:

  1. 定义一个任务类CyclicBarrierThreadUse(实现了Runnable接口)
  2. 定义成员变量：CyclicBarrier ，ConcurrentHashMap
java">private CyclicBarrier cyclicBarrier = new CyclicBarrier(2 , this) ;
private ConcurrentHashMap<Integer , String> concurrentHashMap = new ConcurrentHashMap<Integer , String>() ;
  1. 定义一个方法count方法，在count方法中开启两个线程对象(可以使用匿名内部类的方式实现)
  2. 在run方法中对ConcurrentHashMap中的数据进行汇总
  3. 编写测试类CyclicBarrierThreadUseDemo
  4. 创建CyclicBarrierThreadUse对象，调用count方法

任务类代代码：

java">public class CyclicBarrierThreadUse implements Runnable {// 当前我们两个线程到达了屏障点以后，我们需要立即对数据进行汇总, 因此我们需要使用第二个构造方法// 并且我们当前这个类就是一个任务类，因此我们可以直接传递参数thisprivate CyclicBarrier cyclicBarrier = new CyclicBarrier(2 , this) ;private ConcurrentHashMap<Integer , String> concurrentHashMap = new ConcurrentHashMap<Integer , String>() ;  // 存储两个线程所读取的数据public void count() {// 定义一个方法count方法，在count方法中开启两个线程对象(可以使用匿名内部类的方式实现)// 线程1new Thread(new Runnable() {@Overridepublic void run() {// 读取数据BufferedReader bufferedReader = null ;try {bufferedReader = new BufferedReader(new FileReader("D:\\salary\\2017-salary.txt")) ;String line = null ;while((line = bufferedReader.readLine()) != null) {concurrentHashMap.put(Integer.parseInt(line) , "") ;            // 小的问题，工资信息不能重复}} catch (Exception e) {e.printStackTrace();} finally {if(bufferedReader != null) {try {bufferedReader.close();} catch (IOException e) {e.printStackTrace();}}}// 模拟任务的执行时间try {TimeUnit.SECONDS.sleep(5) ;System.out.println(Thread.currentThread().getName() + "---------------------线程读取数据完毕....");cyclicBarrier.await() ;         //通知cyclicBarrier当前线程已经到达了屏障点} catch (Exception e) {e.printStackTrace();}}}).start();// 线程2new Thread(new Runnable() {@Overridepublic void run() {// 读取数据BufferedReader bufferedReader = null ;try {bufferedReader = new BufferedReader(new FileReader("D:\\salary\\2019-salary.txt")) ;String line = null ;while((line = bufferedReader.readLine()) != null) {concurrentHashMap.put(Integer.parseInt(line) , "") ;            // 小的问题，工资信息不能重复}} catch (Exception e) {e.printStackTrace();} finally {if(bufferedReader != null) {try {bufferedReader.close();} catch (IOException e) {e.printStackTrace();}}}// 模拟任务的执行时间try {TimeUnit.SECONDS.sleep(10) ;System.out.println(Thread.currentThread().getName() + "---------------------线程读取数据完毕....");cyclicBarrier.await() ;         //通知cyclicBarrier当前线程已经到达了屏障点} catch (Exception e) {e.printStackTrace();}}}).start();}@Overridepublic void run() {// 获取concurrentHashMap中的数据进行汇总Enumeration<Integer> enumeration = concurrentHashMap.keys();        // 获取concurrentHashMap中所有的键/*** 这个Enumeration的使用和我们之前所学习过的迭代器类似* boolean hasMoreElements(); 判断集合中是否存在下一个元素* E nextElement();           获取元素*/int result = 0 ;while(enumeration.hasMoreElements()) {Integer integer = enumeration.nextElement();result += integer ;}// 输出System.out.println(result);}}

测试类代码：

java">public class CyclicBarrierThreadUseDemo01 {public static void main(String[] args) {// 创建任务类的对象CyclicBarrierThreadUse cyclicBarrierThreadUse = new CyclicBarrierThreadUse();// 调用count方法进行数据汇总cyclicBarrierThreadUse.count();}}


http://www.ppmy.cn/news/1471979.html

相关文章

富格林：躲闪黑幕有效规划出金

富格林：躲闪黑幕有效规划出金

富格林认为&#xff0c;现货黄金拥有诸多其他投资品种所无法比拟的交易优势&#xff0c;也正是如此&#xff0c;如今越来越多投资者相继涌入现货黄金投资市场中。但不少新手投资者发现了一些问题&#xff0c;自己做的单子为何无法盈利出金&#xff1f;这其中是否存在什么背后黑…
阅读更多...
【5600 字】大学生班级档案管理系统的设计与实现

【5600 字】大学生班级档案管理系统的设计与实现

论文模板免费&#xff0c;程序收费~ 大学生班级档案管理系统的设计与实现 摘要&#xff1a;随着信息技术的不断发展&#xff0c;高校的管理工作也逐渐走向信息化。班级档案管理作为高校管理的重要组成部分&#xff0c;对于提高教学质量、促进学生发展具有重要意义。本文设计并…
阅读更多...
C#udpClient组播

C#udpClient组播

一、0udpClient 控件&#xff1a; button&#xff08;打开&#xff0c;关闭&#xff0c;发送&#xff09;&#xff0c;textbox&#xff0c;richTextBox 打开UDP&#xff1a; UdpClient udp: namespace _01udpClient {public partial class Form1 : Form{public Form1(){Initi…
阅读更多...
初识 SpringMVC，运行配置第一个Spring MVC 程序

初识 SpringMVC，运行配置第一个Spring MVC 程序

1. 初识 SpringMVC&#xff0c;运行配置第一个Spring MVC 程序 文章目录 1. 初识 SpringMVC&#xff0c;运行配置第一个Spring MVC 程序1.1 什么是 MVC 2. Spring MVC 概述2.1 Spring MVC 的作用&#xff1a; 3. 运行配置第一个 Spring MVC 程序3.1 第一步&#xff1a;创建Mave…
阅读更多...
【深度学习】大语言模型系列-Transformer

【深度学习】大语言模型系列-Transformer

Transformer是一种深度学习模型&#xff0c;最初由Vaswani等人在2017年的论文《Attention is All You Need》中提出&#xff0c;它彻底革新了自然语言处理&#xff08;NLP&#xff09;领域。在此之前&#xff0c;循环神经网络&#xff08;RNNs&#xff09;及其变体&#xff0c;…
阅读更多...
策略模式与函数式编程应用

策略模式与函数式编程应用

策略模式 | 单一职责原则&#xff08;Single Responsibility Principle, SRP&#xff09;&#xff1a;islenone和islentwo分别根据特定条件返回电话号码 函数式编程&#xff1a; ‘’ if pd.isna(self.note1) else len(re.findall(r’\d, self.note1)) 重复代码&#xff1a; 当…
阅读更多...
【vuejs】directive 自定义指令的详解和使用总结

【vuejs】directive 自定义指令的详解和使用总结

1. Vue.js 指令概述 1.1 指令的作用和重要性 Vue.js 指令是连接视图和数据的声明式配置&#xff0c;它们允许开发者以一种非常直观和灵活的方式操作DOM。指令的作用在于简化模板中的操作&#xff0c;增强组件的可复用性和可维护性。例如&#xff0c;v-model 指令实现了数据双向…
阅读更多...
【Java Web】XML格式文件

【Java Web】XML格式文件

目录 一、XML是什么 二、常见配置文件类型 *.properties类型&#xff1a; *.xml类型&#xff1a; 三、DOM4J读取xml配置文件 3.1 DOM4J的使用步骤 3.2 DOM4J的API介绍 一、XML是什么 XML即可扩展的标记语言&#xff0c;由标记语言可知其基本语法和HTML一样都是由标签构成的文件…
阅读更多...
最新文章

Copyright @ 2022~2023