当前位置：首页 > news >正文

并发设计模式实战系列(16)：屏障（Barrier）

news 来源：原创 2025/8/20 17:33:02

🌟 大家好，我是摘星！ 🌟

今天为大家带来的是并发设计模式实战系列，第十六章屏障（Barrier），废话不多说直接开始~

一、核心原理深度拆解

1. 屏障的同步机制

2. 关键参数

二、生活化类比：团队登山

三、Java代码实现（生产级Demo）

1. 完整可运行代码

2. 关键方法说明

四、横向对比表格

1. 同步工具对比

2. 屏障参数配置对比

五、高级应用技巧

1. 多阶段任务控制

2. 动态线程管理

3. 性能监控

六、工程实践中的陷阱与解决方案

1. 死锁风险场景

2. 屏障断裂处理

七、性能优化技巧

1. 分层屏障设计

2. 与ForkJoinPool结合

八、分布式屏障扩展（ZooKeeper实现）

1. 核心原理

2. Java代码片段

九、监控与调试方案

1. 关键监控指标

2. Arthas诊断命令

十、与其他模式的组合应用

1. 屏障 + 生产者消费者模式

2. 代码示例

一、核心原理深度拆解

1. 屏障的同步机制

┌─────────────┐    ┌─────────────┐    ┌─────────────┐
│  线程1       │    │  线程2       │    │  线程N       │
│ 执行阶段1    │    │ 执行阶段1    │    │ 执行阶段1    │
└──────┬──────┘    └──────┬──────┘    └──────┬──────┘│                  │                  │└─────────┬────────┴────────┬─────────┘│   屏障点         │▼                  ▼┌───────────────────┐│   所有线程到达后    ││   才继续执行阶段2   │└───────────────────┘

协调机制：强制多个线程在某个点等待，直到所有参与线程都到达该点
重置特性：CyclicBarrier 可重复使用（自动重置），CountDownLatch 不可重置

2. 关键参数

parties：需要等待的线程数量
barrierAction：所有线程到达后触发的回调（可选）

二、生活化类比：团队登山

系统组件	现实类比	核心行为
线程	登山队员	各自以不同速度攀登
屏障点	集合点	必须所有队员到齐才能继续前进
barrierAction	领队	检查装备、宣布下一阶段路线

异常处理：若有队员受伤（线程中断），其他队员需要决定是否继续等待

三、Java代码实现（生产级Demo）

1. 完整可运行代码

import java.util.concurrent.*;
import java.util.Random;public class BarrierPatternDemo {// 登山模拟static class MountainClimbing {private final CyclicBarrier barrier;private final Random rand = new Random();public MountainClimbing(int teamSize) {// 屏障点设置：队伍到齐后执行领队指令this.barrier = new CyclicBarrier(teamSize, () -> {System.out.println("\n=== 所有队员已到达集合点 ===");System.out.println("领队：检查装备完毕，向下一营地前进！");});}public void climb(String name) {try {// 第一阶段攀登int time = rand.nextInt(3000);System.out.printf("%s 正在攀登第一段（预计%dms）...\n", name, time);Thread.sleep(time);System.out.printf("[%s] 到达第一集合点，等待队友...\n", name);barrier.await();  // 等待所有队员// 第二阶段（屏障解除后）time = rand.nextInt(4000);System.out.printf("%s 向顶峰冲刺（预计%dms）...\n", name, time);Thread.sleep(time);System.out.printf("[%s] 成功登顶！\n", name);} catch (InterruptedException | BrokenBarrierException e) {System.out.printf("[%s] 登山中断: %s\n", name, e.getMessage());}}}public static void main(String[] args) {final int TEAM_SIZE = 3;MountainClimbing expedition = new MountainClimbing(TEAM_SIZE);// 创建登山线程ExecutorService pool = Executors.newFixedThreadPool(TEAM_SIZE);for (int i = 1; i <= TEAM_SIZE; i++) {String name = "队员-" + i;pool.execute(() -> expedition.climb(name));}pool.shutdown();}
}

2. 关键方法说明

// 1. 屏障等待（可设置超时）
barrier.await(5, TimeUnit.SECONDS);// 2. 检查屏障状态
barrier.isBroken();  // 是否有线程被中断
barrier.getNumberWaiting();  // 当前等待的线程数// 3. 重置屏障（CyclicBarrier特有）
barrier.reset();

四、横向对比表格

1. 同步工具对比

工具	可重用性	可中断	额外功能	适用场景
CyclicBarrier	✓	✓	支持回调(barrierAction)	多阶段任务同步
CountDownLatch	✗	✓	一次性	主线程等待多个子线程完成
Phaser	✓	✓	动态注册/注销	复杂分阶段任务
Exchanger	✓	✓	数据交换	线程间数据传递

2. 屏障参数配置对比

配置项	CyclicBarrier	CountDownLatch
初始化参数	等待线程数	需要countDown的次数
重用方式	自动重置	需重新创建实例
异常处理	BrokenBarrierException	无特殊异常

五、高级应用技巧

1. 多阶段任务控制

// 使用多个屏障实现多阶段同步
CyclicBarrier phase1 = new CyclicBarrier(3);
CyclicBarrier phase2 = new CyclicBarrier(3, ()->System.out.println("阶段2完成"));// 线程中按顺序等待
phase1.await();
// 执行阶段1任务...
phase2.await();

2. 动态线程管理

// 使用Phaser替代（JDK7+）
Phaser phaser = new Phaser(1); // 注册主线程
for (int i = 0; i < 3; i++) {phaser.register(); // 动态注册任务线程new Thread(() -> {doWork();phaser.arriveAndDeregister(); // 完成任务后注销}).start();
}
phaser.arriveAndAwaitAdvance(); // 主线程等待

3. 性能监控

// 监控屏障等待情况
System.out.println("当前等待线程数: " + barrier.getNumberWaiting());
if (barrier.isBroken()) {System.out.println("警告：屏障已被破坏！");
}

六、工程实践中的陷阱与解决方案

1. 死锁风险场景

// 错误示例：线程池大小 < 屏障要求的parties数
ExecutorService pool = Executors.newFixedThreadPool(2);
CyclicBarrier barrier = new CyclicBarrier(3); // 要求3个线程
pool.submit(() -> barrier.await()); // 永远阻塞
pool.submit(() -> barrier.await());

解决方案：

确保线程池大小 ≥ parties数
添加超时机制：

barrier.await(10, TimeUnit.SECONDS);

2. 屏障断裂处理

当某个等待线程被中断或超时，会触发BrokenBarrierException，此时需要：

try {barrier.await();
} catch (BrokenBarrierException e) {// 1. 记录断裂原因// 2. 重置屏障或终止任务barrier.reset(); // 仅CyclicBarrier有效
}

七、性能优化技巧

1. 分层屏障设计

┌─────────────┐    ┌─────────────┐    ┌─────────────┐
│  子任务组1   │    │  子任务组2   │    │  子任务组N   │
│  (屏障A)     │    │  (屏障A)     │    │  (屏障A)     │
└──────┬──────┘    └──────┬──────┘    └──────┬──────┘│                  │                  │└─────────┬────────┴────────┬─────────┘│   全局屏障B      │▼                  ▼┌───────────────────┐│   最终聚合处理     │└───────────────────┘

适用场景：大数据分片处理（如MapReduce）

2. 与ForkJoinPool结合

ForkJoinPool pool = new ForkJoinPool(4);
CyclicBarrier barrier = new CyclicBarrier(4);pool.execute(() -> {// 分治任务1barrier.await();// 合并结果...
});

八、分布式屏障扩展（ZooKeeper实现）

1. 核心原理

┌─────────────┐    ┌─────────────┐
│  节点1       │    │  节点2       │
│ 创建临时节点 │───>│ 监听节点变化 │
└─────────────┘    └─────────────┘│               ▲└───────┬───────┘▼┌─────────────┐│  ZooKeeper   ││  /barrier    │└─────────────┘

2. Java代码片段

public class DistributedBarrier {private final ZooKeeper zk;private final String barrierPath;public void await() throws Exception {zk.create(barrierPath + "/node", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);while (true) {List<String> nodes = zk.getChildren(barrierPath, false);if (nodes.size() >= REQUIRED_NODES) {break; // 所有节点就绪}Thread.sleep(100);}}
}

九、监控与调试方案

1. 关键监控指标

指标	采集方式	健康阈值
平均等待时间	Barrier日志打点 + Prometheus	< 任务超时时间的20%
屏障断裂次数	异常捕获统计	每小时 < 3次
线程阻塞比例	ThreadMXBean监控	< 线程数的30%

2. Arthas诊断命令

# 查看屏障状态
watch java.util.concurrent.CyclicBarrier getParties returnObj
# 监控等待线程
thread -b | grep 'await'

十、与其他模式的组合应用

1. 屏障 + 生产者消费者模式

┌─────────────┐    ┌─────────────┐    ┌─────────────┐
│  生产者线程  │    │  生产者线程  │    │  屏障        │
│  生产数据    │───>│ 提交到队列   │───>│ 等待所有生产 │
└─────────────┘    └─────────────┘    └──────┬──────┘│
┌─────────────┐    ┌─────────────┐    ┌──────▼──────┐
│  消费者线程  │    │  消费者线程  │    │  屏障释放   │
│  开始消费    │<───│ 从队列获取   │<───│ 触发消费信号│
└─────────────┘    └─────────────┘    └─────────────┘

2. 代码示例

BlockingQueue<Data> queue = new LinkedBlockingQueue<>();
CyclicBarrier producerBarrier = new CyclicBarrier(3, () -> {System.out.println("所有生产者完成，启动消费者");startConsumers();
});// 生产者线程
void produce() {queue.put(generateData());producerBarrier.await();
}

并发设计模式实战系列(16)：屏障（Barrier）

🌟 大家好，我是摘星！ 🌟 今天为大家带来的是并发设计模式实战系列，第十六章屏障（Barrier），废话不多说直接开始~ 目录一、核心原理深度拆解 1. 屏障的同步机制 2. 关键参数二…...

编程日记 2025/8/20 17:33:02

pywinauto通过图片定位怎么更加精准的识别图片？

pywinauto通过图片定位怎么更加精准的识别图片？ 可以使用置信度的配置，添加了对比图片相似程度达到多少就可以认为是合适的定位图片 import time from time import sleep from pywinauto.application import Application from pywinauto.keyboard impo…...

编程日记 2025/8/20 17:28:21

Spring Cloud Stream集成RocketMQ（kafka/rabbitMQ通用）

什么是Spring Cloud Stream Spring Cloud Stream 是 Spring 生态系统中的一个框架，用于简化构建消息驱动微服务的开发和集成。它通过抽象化的方式将消息中间件（如 RabbitMQ、Kafka、RocketMQ 等）的复杂通信逻辑封装成简单的编程模型&#xf…...

编程日记 2025/8/20 17:29:53

基于docker使用showdoc搭建API开发文档服务器

以下是基于 Docker 快速搭建 ShowDoc API 文档服务器的完整指南，包含优化配置和常见问题解决方案： 1. 快速部署方案 # 创建数据目录（确保权限） mkdir -p /showdoc_data/html && chmod 777 -R /showdoc_data# 一键启动容器…...

编程日记 2025/8/20 12:24:37

Vision-Language Models (VLMs) 视觉语言模型的技术背景、应用场景和商业前景（Grok3 DeepSearch模式回答）

prompt: 你是一位文笔精湛、十分专业的技术博客作者，你将从技术背景、应用场景和商业前景等多个维度去向读者介绍Vision-Language Models 关键要点研究表明，视觉语言模型（VLMs）是多模态AI系统，能同时处理视觉和文本数…...

编程日记 2025/8/20 17:33:00

OpenAI大变革！继续与微软等，以非营利模式冲击AGI

今天凌晨2点，OpenAI宣布，将继续由非营利组织控制；现有的营利性实体将转变为一家公共利益公司；非营利组织将控制该公共利益公司，并成为其重要的持股方。这也就是说OpenAI曾在去年提到的由非营利性转变成营利性公司&am…...

编程日记 2025/8/20 7:23:56

Ubuntu打开中文文本乱码

文章目录中文乱码问题修复乱码系统字符编码修改文本编码修改vim乱码 utf-8编码原理特点应用场景与其他编码的转换 iso-8859-1基本信息字符涵盖应用场景与其他编码的关系 ubuntu打开文本出现乱码，可能是编码没设置对。中文乱码问题使用vim打开文本，或…...

编程日记 2025/8/20 12:06:42

车载通信网络安全：挑战与解决方案

1. 简介当今时代见证了车载汽车技术的巨大发展，因为现代智能汽车可以被视为具有出色外部基础设施连接能力的信息物理系统 [ 1 ]。车载技术支持的现代智能汽车不应被视为类似于机械系统，而是由数百万行复杂代码组成的集成架构，可为车内乘客提…...

编程日记 2025/8/18 11:11:06

【Linux系统】读写锁

读者写者问题重点读者写者问题是并发编程中的经典问题，主要研究多个进程或线程对共享数据进行读和写操作时如何实现同步和互斥，以保证数据的一致性和操作的正确性。问题核心要点同步与互斥：需要确保多个读者可以同时读共享数据&#…...

编程日记 2025/8/18 13:26:17

springBoot中自定义一个validation注解，实现指定枚举值校验

缘由在后台写接口的时候，经常会出现dto某个属性是映射到一个枚举的情况。有时候还会出现只能映射到枚举类中部分枚举值的情况。以前都是在service里面自行判断，很多地方代码冗余，所以就想着弄一个自定义的validation注解来实现。例如下面某…...

编程日记 2025/8/17 17:59:34

【Python】--装饰器

装饰器（Decorator）本质上是一个返回函数的函数主要作用是：在不修改原函数代码的前提下，给函数增加额外的功能比如：增加业务，日志记录、权限验证、执行时间统计、缓存等场景 my_decorator def func():pas…...

编程日记 2025/8/18 10:12:28

排序算法——堆排序

一、介绍「堆排序heapsort」是一种基于堆数据结构实现的高效排序算法。我们可以利用已经学过的“建堆操作”和“元素出堆操作”实现堆排序。 1. 输入数组并建立小顶堆，此时最小元素位于堆顶。 2. 不断执行出堆操作，依次记录出堆元素，即可得…...

编程日记 2025/8/18 10:12:26

Day111 | 灵神 | 二叉树 | 验证二叉搜索树

Day111 | 灵神 | 二叉树 | 验证二叉搜索树 98.验证二叉搜索树 98. 验证二叉搜索树 - 力扣（LeetCode） 方法一：前序遍历递归函数传入合法的左右边界，只有当前结点是合法的边界，才是二叉搜索树，否则就返回…...

编程日记 2025/8/20 2:17:42

软考-软件设计师中级备考 13、刷题数据结构

倒计时17天时间不多了，数据库、UML、等知识点有基础直接略过，法律全靠考前的一两天刷题，英语直接放弃。一、数据结构：链表、栈、队列、数组、哈希表、树、图 1、关于链表操作，说法正确的是： A)新增一个头…...

编程日记 2025/8/20 2:03:23

【5G通信】天线调整

在天线工程中，机械下倾角、电子下倾角和数字下倾角是调整天线波束指向的不同技术手段，其核心区别在于实现方式和灵活性： 1. 机械下倾角（Mechanical Downtilt） 定义：通过物理调整天线的安装角度&#xff0c…...

编程日记 2025/8/19 14:27:34

Kafka的Log Compaction原理是什么？

Kafka的Log Compaction（日志压缩）是一种独特的数据保留策略，其核心原理是保留每个key的最新有效记录。以下是关键原理分点说明： 1. 键值保留机制通过扫描所有消息的key，仅保留每个key对应的最新value值。例如&#…...

编程日记 2025/8/18 7:07:11

嵌入式面试八股文（十四）·内存管理机制、优先级继承机制以及优先级翻转

目录 1. 内存管理算法（五种内存管理机制） 1.1 heap_1.c 1.2 heap_2.c 1.3 heap_3.c 1.4 heap_4.c 1.5 heap_5.c 1.6 总结 2. STM32通知寄存器有哪些？ 2.1 核心寄存器组（Cortex-M） 2.2 特殊功能寄存…...

编程日记 2025/8/18 10:12:13

深度剖析：可视化如何重塑驾驶舱信息交互模式

为什么你开车时总觉得“信息太多却抓不住重点”？ 今天的汽车早已不是单纯的交通工具，而是一个高度集成的信息终端。从导航、油耗、胎压到自动驾驶提示，各种数据不断涌进驾驶舱。但问题也随之而来： 关键信息被淹没在一堆图标里…...

编程日记 2025/8/17 11:00:14

app根据蓝牙名字不同，匹配不同的产品型号，显示对应的UI界面

在开发一个 App 时，如果希望根据蓝牙设备名称（Bluetooth Name）的不同，自动匹配不同的产品型号，并显示对应的 UI 界面，可以按照以下思路来实现： ✅ 功能目标扫描并连接蓝牙设备；获取…...

编程日记 2025/8/20 2:03:25

数据结构 --- 栈

1.栈的初始化 2.入栈 3.出栈 4.取出栈顶元素 5.获取栈中有效元素个数 6.栈的销毁栈：⼀种特殊的线性表，其只允许在固定的⼀端进⾏插⼊和删除元素操作。进⾏数据插⼊和删除操作的⼀端称为栈顶，另⼀端称为栈底。栈中的数据元素遵守后进先…...

编程日记 2025/8/19 17:03:36

37-算法打卡-栈与队列-滑动窗口最大值-leetcode(239)-第三十七天

1 题目地址 239. 滑动窗口最大值 - 力扣（LeetCode）239. 滑动窗口最大值 - 给你一个整数数组 nums，有一个大小为 k 的滑动窗口从数组的最左侧移动到数组的最右侧。你只可以看到在滑动窗口内的 k 个数字。滑动窗口每次只向右移动一位。返回滑…...

编程日记 2025/8/18 10:12:02

【原创分享】魔音变声器内含超多语音包实时变声

魔音变声器,一款专业的调音变声器软件亲测可使用所有功能[真棒] 去除所有广告 ————————————【下载地址】———————————— 【获取方法1】：https://pan.xunlei.com/s/VOP_TXtKNlevTgYvIlxmmJquA1?pwd8vpi# ————————————【下 …...

编程日记 2025/8/19 15:09:21

数据结构（一）——线性表的顺序表示和实现

一、线性表的定义由n(n>0)个数据特性相同的元素构成的有限序列称为线性表，(n0)的时候被称为空表。一个数据元素可以是简单的一个数据，一个符号，也可以是复杂的若干个数据项的组合。二、线性表的类型定义 s线性表是由n(n≥0)个相同类…...

编程日记 2025/8/18 10:11:58

ChildForm窗口： ChildForm代码： using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; namespac…...

编程日记 2025/8/18 10:11:55

一、核心原理深度拆解

1. 屏障的同步机制

2. 关键参数

二、生活化类比：团队登山

三、Java代码实现（生产级Demo）

1. 完整可运行代码

2. 关键方法说明

四、横向对比表格

1. 同步工具对比

2. 屏障参数配置对比

五、高级应用技巧

1. 多阶段任务控制

2. 动态线程管理

3. 性能监控

六、工程实践中的陷阱与解决方案

1. 死锁风险场景

2. 屏障断裂处理

七、性能优化技巧

1. 分层屏障设计

2. 与ForkJoinPool结合

八、分布式屏障扩展（ZooKeeper实现）

1. 核心原理

2. Java代码片段

九、监控与调试方案

1. 关键监控指标

2. Arthas诊断命令

十、与其他模式的组合应用

1. 屏障 + 生产者消费者模式

2. 代码示例

相关文章：