AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Java并发编程 - AQS 之 CyclicBarrier(二)

2022-05-30 188
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Java并发编程 - AQS 之 CyclicBarrier(二)

案例二


package com.mmall.concurrency.example.aqs;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@Slf4j
public class CyclicBarrierExample2 {
    private static CyclicBarrier barrier = new CyclicBarrier(5);
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            final int threadNum = i;
            Thread.sleep(1000);
            executor.execute(() -> {
                try {
                    race(threadNum);
                } catch (Exception e) {
                    log.error("exception", e);
                }
            });
        }
        executor.shutdown();
    }
    private static void race(int threadNum) throws Exception {
        Thread.sleep(1000);
        log.info("{} is ready", threadNum);
        try {
            barrier.await(2000, TimeUnit.MILLISECONDS);
        } catch (Exception e) {
            log.warn("Exception", e);
        }
        log.info("{} continue", threadNum);
    }
}
// 输出
21:43:03.378 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 0 is ready
21:43:04.376 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 1 is ready
21:43:05.376 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 2 is ready
21:43:05.382 [pool-1-thread-1] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:05.382 [pool-1-thread-2] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:05.382 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 0 continue
21:43:05.382 [pool-1-thread-3] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:05.382 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 1 continue
21:43:05.382 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 2 continue
21:43:06.377 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 3 is ready
21:43:06.377 [pool-1-thread-4] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:06.377 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 3 continue
21:43:07.377 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 4 is ready
21:43:07.377 [pool-1-thread-3] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:07.377 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 4 continue
21:43:08.378 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 5 is ready
21:43:08.378 [pool-1-thread-4] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:08.378 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 5 continue
21:43:09.378 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 6 is ready
21:43:09.378 [pool-1-thread-3] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:09.378 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 6 continue
21:43:10.379 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 7 is ready
21:43:10.379 [pool-1-thread-4] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:10.379 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 7 continue
21:43:11.380 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 8 is ready
21:43:11.380 [pool-1-thread-3] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:11.380 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 8 continue
21:43:12.380 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 9 is ready
21:43:12.380 [pool-1-thread-4] WARN  c.m.concurrency.example.aqs.test9 - Exception
21:43:12.380 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 9 continue
Process finished with exit code 0

分析 await(timeout,TimeUnit) 方法


在 CyclicBarrier 上进行限时的阻塞等待，直到发生以下情形之一。

在 CyclicBarrier 上等待的线程数量达到 parties，则所有线程被释放，继续执行。

当前线程被中断，则抛出 InterruptedException 异常，并停止等待，继续执行。

当前线程等待超时，则抛出 TimeoutException 异常，并停止等待，继续执行。

其他等待的线程被中断，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。

其他等待的线程超时，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。

其他线程调用 CyclicBarrier.reset() 方法，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。



案例三

package com.mmall.concurrency.example.aqs;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Slf4j
public class CyclicBarrierExample3 {
    private static CyclicBarrier barrier = new CyclicBarrier(5, () -> {
        log.info("callback is running");
    });
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            final int threadNum = i;
            Thread.sleep(1000);
            executor.execute(() -> {
                try {
                    race(threadNum);
                } catch (Exception e) {
                    log.error("exception", e);
                }
            });
        }
        executor.shutdown();
    }
    private static void race(int threadNum) throws Exception {
        Thread.sleep(1000);
        log.info("{} is ready", threadNum);
        barrier.await();
        log.info("{} continue", threadNum);
    }
}
// 输出
21:47:26.683 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 0 is ready
21:47:27.682 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 1 is ready
21:47:28.684 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 2 is ready
21:47:29.683 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 3 is ready
21:47:30.683 [pool-1-thread-5] INFO  c.m.concurrency.example.aqs.test9 - 4 is ready
21:47:30.683 [pool-1-thread-5] INFO  c.m.concurrency.example.aqs.test9 - callback is running
21:47:30.683 [pool-1-thread-5] INFO  c.m.concurrency.example.aqs.test9 - 4 continue
21:47:30.683 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 0 continue
21:47:30.683 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 1 continue
21:47:30.683 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 2 continue
21:47:30.683 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 3 continue
21:47:31.684 [pool-1-thread-6] INFO  c.m.concurrency.example.aqs.test9 - 5 is ready
21:47:32.684 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 6 is ready
21:47:33.685 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 7 is ready
21:47:34.685 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 8 is ready
21:47:35.685 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 9 is ready
21:47:35.685 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - callback is running
21:47:35.685 [pool-1-thread-1] INFO  c.m.concurrency.example.aqs.test9 - 9 continue
21:47:35.686 [pool-1-thread-6] INFO  c.m.concurrency.example.aqs.test9 - 5 continue
21:47:35.686 [pool-1-thread-4] INFO  c.m.concurrency.example.aqs.test9 - 6 continue
21:47:35.686 [pool-1-thread-3] INFO  c.m.concurrency.example.aqs.test9 - 7 continue
21:47:35.686 [pool-1-thread-2] INFO  c.m.concurrency.example.aqs.test9 - 8 continue
Process finished with exit code 0
  • 在案例一的基础上，无非新增了一个回调函数功能：在线程达到屏障的时候，优先执行该回调函数先。
文章标签：
Java
关键词：
Java编程
Java AQS
Java CyclicBarrier
Java aqs cyclicbarrier
Java并发编程
Lux_Sun
目录
相关文章
啦啦啦191
|
2月前
|
IDE Java 编译器
java编程最基础学习
Java入门需掌握：环境搭建、基础语法、面向对象、数组集合与异常处理。通过实践编写简单程序，逐步深入学习，打牢编程基础。
啦啦啦191
210 1
啦啦啦191
|
2月前
|
Java
如何在Java中进行多线程编程
Java多线程编程常用方式包括：继承Thread类、实现Runnable接口、Callable接口（可返回结果）及使用线程池。推荐线程池以提升性能，避免频繁创建线程。结合同步与通信机制，可有效管理并发任务。
啦啦啦191
149 6
AI侠客
|
2月前
|
安全 前端开发 Java
从反射到方法句柄：深入探索Java动态编程的终极解决方案
从反射到方法句柄，Java 动态编程不断演进。方法句柄以强类型、低开销、易优化的特性，解决反射性能差、类型弱、安全性低等问题，结合 `invokedynamic` 成为支撑 Lambda 与动态语言的终极方案。
AI侠客
150 0
啦啦啦191
|
3月前
|
SQL Java 数据库
2025 年 Java 从零基础小白到编程高手的详细学习路线攻略
2025年Java学习路线涵盖基础语法、面向对象、数据库、JavaWeb、Spring全家桶、分布式、云原生与高并发技术，结合实战项目与源码分析，助力零基础学员系统掌握Java开发技能，从入门到精通，全面提升竞争力，顺利进阶编程高手。
啦啦啦191
602 1
一缕微风绕指柔
|
3月前
|
Java 开发者
Java并发编程：CountDownLatch实战解析
Java并发编程：CountDownLatch实战解析
一缕微风绕指柔
441 100
啦啦啦191
|
3月前
|
NoSQL Java 关系型数据库
超全 Java 学习路线，帮你系统掌握编程的超详细 Java 学习路线
本文为超全Java学习路线，涵盖基础语法、面向对象编程、数据结构与算法、多线程、JVM原理、主流框架（如Spring Boot）、数据库（MySQL、Redis）及项目实战等内容，助力从零基础到企业级开发高手的进阶之路。
啦啦啦191
293 1
蓝易云
|
3月前
|
算法 Java
Java多线程编程：实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
蓝易云
233 16
阿秀a
|
Java 调度
java并发编程中CountDownLatch和CyclicBarrier的使用
java并发编程中CountDownLatch和CyclicBarrier的使用    在多线程程序设计中，经常会遇到一个线程等待一个或多个线程的场景，遇到这样的场景应该如何解决？ 如果是一个线程等待一个线程，则可以通过await()和notify()来实现； 如果是一个线程等待多个线程，则就可以使用CountDownLatch和CyclicBarrier来实现比较好的控制。
阿秀a
1212 0
凉凉心.
|
2月前
|
JSON 网络协议 安全
【Java】（10）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
160 1
凉凉心.
|
2月前
|
JSON 网络协议 安全
【Java基础】（1）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
178 1

热门文章

最新文章

  • 1
    百宝箱开放平台 ✖️ Java SDK
  • 2
    【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
  • 3
    Java 设计模式之策略模式：灵活切换算法的艺术
  • 4
    Java 设计模式之状态模式：让对象的行为随状态优雅变化
  • 5
    java零基础学习者入门课程
  • 6
    Java 设计模式之观察者模式：构建松耦合的事件响应系统
  • 7
    Java 设计模式之责任链模式：优雅处理请求的艺术
  • 8
    java实现图片与base64转换
  • 9
    Java应用频繁FullGC分析
  • 10
    浅析Java基本数据类型
  • 1
    2025 版 Java 零基础入门到精通实操指南
    957
  • 2
    java 入门学习视频_2025 最新 java 入门零基础学习视频教程
    251
  • 3
    顺丰同城抢单辅助脚本，顺丰骑士抢单辅助免封号，自动抢单神器【java版开源】
    792
  • 4
    现代化 java 分层开发实施策略与最佳实践指南
    250
  • 5
    我们详细地讲解一下 Java 异常及要如何处理
    142
  • 6
    MinIO Java SDK 7.1.4 升级到 8.5.17 需要注意什么
    468
  • 7
    微信不封号无限加人软件，微信一键自动加人软件，java实现批量化加人
    147
  • 8
    Java 与 C++ 区别深入剖析及应用实例详解
    536
  • 9
    Java 生态大模型应用开发全流程实战案例与技术路径终极对决
    987
  • 10
    Java 抽象类与接口在 Java17 + 开发中的现代应用实践解析
    180

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0
    • 下一篇
    阿里云负载均衡收费标准：ALB、NLB和CLB价格，包括LCU费用、实例费和公网带宽价格