【JAVA高级】并发同步工具CyclicBarrier 的使用介绍

本文主要是介绍【JAVA高级】并发同步工具CyclicBarrier 的使用介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

📝个人主页🌹：个人主页
⏩收录专栏⏪：JAVA进阶
🌹🌹期待您的关注 🌹🌹，让我们共同进步！

CyclicBarrier 简介

CyclicBarrier 是 Java 中的另一个同步辅助类，它可以让一组线程互相等待，直到所有线程都达到一个屏障点后再继续执行。与
CountDownLatch 不同的是，CyclicBarrier
的计数器可以循环使用，当所有线程都到达屏障点后，计数器会重置，可以被复用。 所谓 Cyclic 即循环的意思，所谓 Barrier
即屏障的意思。所以综合起来，CyclicBarrier 指的就是循环屏障，虽然这个叫法很奇怪，但是却能很好地表达其含义

CyclicBarrier 的场景示意图：

单次屏障作用示意：

循环的屏障作用示意：

CyclicBarrier 的主要方法包括：

• 构造方法：CyclicBarrier(int parties) 构造一个 CyclicBarrier 对象，指定参与线程的数量 parties。
• await()：让当前线程等待，直到所有参与线程都到达屏障点。

CyclicBarrier 的典型用法包括：

• 多个线程分阶段执行任务，每个阶段结束后等待其他线程，然后一起执行下一个阶段。
• 多个线程同时执行不同任务，等待所有任务完成后再进行下一步操作。

CyclicBarrier 使用

案例一：计算10个员工的平均薪资

package com.atguigu.signcenter.nosafe;import java.util.Set;
import java.util.concurrent.*;/** * 使用循环栅栏求五个人的平均薪资* @author: jd* @create: 2024-09-04*/
public class CyclicBarrierDemo {private static final int STUDENT_COUNT =10;//存储工人姓名及工资private ConcurrentHashMap concurrentHashMap = new ConcurrentHashMap<String,Integer>();private ExecutorService executorService =Executors.newFixedThreadPool(10);public void avgScore() throws InterruptedException {CyclicBarrier  cyclicBarrier =new CyclicBarrier(10);for (int i = 0; i < STUDENT_COUNT; i++) {executorService.submit(()->{//获取工人的工资,这里随机生成工资int score = (int) (Math.random() * 3000 + 5000);concurrentHashMap.put(Thread.currentThread().getName(),score);System.out.println(Thread.currentThread().getName()+"对应的工资为："+score);try {//执行完运行 await 等待所有工人的工资都计算完毕cyclicBarrier.await();} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}});}Thread.sleep(2000);if(cyclicBarrier.getNumberWaiting() ==0){int totalNumber = 0;Set<String> set =concurrentHashMap.keySet();for (String s : set) {totalNumber+=(int)concurrentHashMap.get(s);}System.out.println("五位工人的平均工资为:" + (totalNumber / STUDENT_COUNT) + "元");}System.out.println("========计算完毕========");executorService.shutdown();}public static void main(String[] args) throws InterruptedException {CyclicBarrierDemo cyclicBarrierDemo = new CyclicBarrierDemo();cyclicBarrierDemo.avgScore();}}

结果：

pool-1-thread-7对应的工资为：5210
pool-1-thread-3对应的工资为：6376
pool-1-thread-5对应的工资为：7101
pool-1-thread-2对应的工资为：5388
pool-1-thread-10对应的工资为：6609
pool-1-thread-1对应的工资为：5067
pool-1-thread-4对应的工资为：7341
pool-1-thread-8对应的工资为：5228
pool-1-thread-6对应的工资为：6683
pool-1-thread-9对应的工资为：5430
五位工人的平均工资为:6043元
========计算完毕========

案例2：

现在要模拟一个所有员工都到达公园之后，进行马拉松比赛的一个过程，等待员工都进行完比赛之后，开始颁奖晚会。

先编写人出发，到公园，最后的表演节目的代码

package com.atguigu.signcenter.nosafe;import java.util.concurrent.*;/*** 现在要模拟一个所有员工都到达公园之后，进行马拉松比赛的一个过程，等待员工都进行完比赛之后，开始颁奖晚会。* 循环屏障演示到达公园，最后的表演一个节目* @author: jd* @create: 2024-09-05*/
public class CyclicBarrierDemo2 {private static final int PEOPLE_COUNT =10;// 创建一个线程池来执行任务static final ThreadPoolExecutor executor = new ThreadPoolExecutor(10,20,30L,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(),Executors.defaultThreadFactory());/*** 模拟10个人分别 出发去公园*/public void goParkTogether(){CyclicBarrier cyclicBarrier =new CyclicBarrier(10,()->{try {Thread.sleep(3000);System.out.println("因为" + Thread.currentThread().getName() + "最后到我给大家表演一个节目，先解解闷，再开始比赛");} catch (InterruptedException e) {e.printStackTrace();}});//启动10个线程，分别模拟十个人出发去公园及在公园路上花费的时间for (int i = 0; i < PEOPLE_COUNT; i++) {executor.submit(()->{try {//模拟路上花费的时间Thread.sleep(2000);System.out.println(Thread.currentThread().getName()+"已经到达");//到屏障了进行等待cyclicBarrier.await();} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}});}}public static void main(String[] args) {CyclicBarrierDemo2 cyclicBarrierDemo2 = new CyclicBarrierDemo2();cyclicBarrierDemo2.goParkTogether();}}

结果：

pool-1-thread-8已经到达
pool-1-thread-4已经到达
pool-1-thread-3已经到达
pool-1-thread-2已经到达
pool-1-thread-7已经到达
pool-1-thread-10已经到达
pool-1-thread-6已经到达
pool-1-thread-9已经到达
pool-1-thread-1已经到达
pool-1-thread-5已经到达
因为pool-1-thread-5最后到我给大家表演一个节目，再开始比赛

两种写法上稍稍有差异，第一个是通过判断在等待的线程还有没有，如果没有了则执行最后的内容；第二种则是在创建栅栏的时候指定了，等所有线程执行完毕后会执行的内容。

这篇关于【JAVA高级】并发同步工具CyclicBarrier 的使用介绍的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---