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

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

2022-05-30 141
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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并发编程
Java编程cyclicbarrier
Java CyclicBarrier
Java AQS
Lux_Sun
目录
相关文章
muxiaoxi
|
1月前
|
安全 Java 程序员
深入理解Java内存模型与并发编程####
本文旨在探讨Java内存模型（JMM）的复杂性及其对并发编程的影响，不同于传统的摘要形式，本文将以一个实际案例为引子，逐步揭示JMM的核心概念，包括原子性、可见性、有序性，以及这些特性在多线程环境下的具体表现。通过对比分析不同并发工具类的应用，如synchronized、volatile关键字、Lock接口及其实现等，本文将展示如何在实践中有效利用JMM来设计高效且安全的并发程序。最后，还将简要介绍Java 8及更高版本中引入的新特性，如StampedLock，以及它们如何进一步优化多线程编程模型。 ####
muxiaoxi
36 0
游客moiomvrp3vyac2
|
1月前
|
Java 程序员
Java编程中的异常处理：从基础到高级
在Java的世界中，异常处理是代码健壮性的守护神。本文将带你从异常的基本概念出发，逐步深入到高级用法，探索如何优雅地处理程序中的错误和异常情况。通过实际案例，我们将一起学习如何编写更可靠、更易于维护的Java代码。准备好了吗？让我们一起踏上这段旅程，解锁Java异常处理的秘密！
游客moiomvrp3vyac2
63 0
运营研究坊
|
25天前
|
存储 缓存 Java
Java 并发编程——volatile 关键字解析
本文介绍了Java线程中的`volatile`关键字及其与`synchronized`锁的区别。`volatile`保证了变量的可见性和一定的有序性，但不能保证原子性。它通过内存屏障实现，避免指令重排序，确保线程间数据一致。相比`synchronized`，`volatile`性能更优，适用于简单状态标记和某些特定场景，如单例模式中的双重检查锁定。文中还解释了Java内存模型的基本概念，包括主内存、工作内存及并发编程中的原子性、可见性和有序性。
运营研究坊
61 5
Java 并发编程——volatile 关键字解析
互联网课堂
|
29天前
|
算法 Java 调度
java并发编程中Monitor里的waitSet和EntryList都是做什么的
在Java并发编程中，Monitor内部包含两个重要队列：等待集（Wait Set）和入口列表（Entry List）。Wait Set用于线程的条件等待和协作，线程调用`wait()`后进入此集合，通过`notify()`或`notifyAll()`唤醒。Entry List则管理锁的竞争，未能获取锁的线程在此排队，等待锁释放后重新竞争。理解两者区别有助于设计高效的多线程程序。 - **Wait Set**：线程调用`wait()`后进入，等待条件满足被唤醒，需重新竞争锁。 - **Entry List**：多个线程竞争锁时，未获锁的线程在此排队，等待锁释放后获取锁继续执行。
互联网课堂
64 12
栈江湖
|
26天前
|
存储 安全 Java
Java多线程编程秘籍：各种方案一网打尽，不要错过！
Java 中实现多线程的方式主要有四种：继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点，适用于不同的场景。继承 Thread 类最简单，实现 Runnable 接口更灵活，Callable 接口支持返回结果，线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外，还介绍了多线程相关的常见面试问题及答案，涵盖线程概念、线程安全、线程池等知识点。
栈江湖
145 2
游客nmbcre4jd7shs
|
1月前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱，并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手，逐步深入到具体的代码示例，帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者，都能从中获得有价值的见解和建议。 ####
游客nmbcre4jd7shs
50 4
mg的嘟嘟
|
1月前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念，包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着，详细讲解了Java提供的同步机制，如synchronized关键字、wait()和notify()方法等，以及如何通过这些机制实现线程间的协调与通信。最后，本文还讨论了一些常见的并发问题，例如死锁、竞态条件等，并提供了相应的解决策略。
mg的嘟嘟
63 3
Java开发者
|
1月前
|
开发框架 安全 Java
Java 反射机制：动态编程的强大利器
Java反射机制允许程序在运行时检查类、接口、字段和方法的信息，并能操作对象。它提供了一种动态编程的方式，使得代码更加灵活，能够适应未知的或变化的需求，是开发框架和库的重要工具。
Java开发者
63 4
ShaFaChuang-36210
|
2月前
|
监控 安全 Java
Java中的多线程编程：从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式，本文将以一个简短的代码示例作为开篇，直接展示多线程的魅力，随后再详细解析其背后的原理与实现方式，旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例：创建两个线程，分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
ShaFaChuang-36210
68 1
shuj
|
2月前
|
安全 Java 调度
Java中的多线程编程入门
【10月更文挑战第29天】在Java的世界中，多线程就像是一场精心编排的交响乐。每个线程都是乐团中的一个乐手，他们各自演奏着自己的部分，却又和谐地共同完成整场演出。本文将带你走进Java多线程的世界，让你从零基础到能够编写基本的多线程程序。
shuj
40 1

热门文章

最新文章

  • 1
    Java volatile关键字：你真的懂了吗？
  • 2
    Java最新图形化界面开发技术——JavaFx教程（含UI控件用法介绍、属性绑定、事件监听、FXML）
  • 3
    java项目中jar启动执行日志报错：no main manifest attribute, in /www/wwwroot/snow-server/z-server.jar-jar打包的大小明显小于正常大小如何解决
  • 4
    springboot java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver应该如何解决
  • 5
    Java多线程编程秘籍：各种方案一网打尽，不要错过！
  • 6
    【Bug合集】——Java大小写引起传参失败，获取值为null的解决方案
  • 7
    Java中的数据类型
  • 8
    Java中的字符集编码入门－增补字符（转载）
  • 9
    JAVA线程池有哪些队列？ 以及它们的适用场景案例
  • 10
    如何在 Java 代码中使用 JSqlParser 解析复杂的 SQL 语句？
  • 1
    Java一分钟之-Java网络编程基础：Socket通信
    192
  • 2
    【Java开发指南 | 第三十一篇】Java 包(package)
    93
  • 3
    【Java开发指南 | 第二十九篇】Java接口
    55
  • 4
    【Java开发指南 | 第二十八篇】Java封装
    66
  • 5
    【Java开发指南 | 第二十六篇】Java多态
    46
  • 6
    【Java开发指南 | 第二十五篇】Java 重写(Override)与重载(Overload)
    64
  • 7
    【Java开发指南 | 第二十四篇】Java继承
    67
  • 8
    【Java开发指南 | 第二十三篇】Java异常处理
    55
  • 9
    Java并发编程学习12-任务取消（上）
    78
  • 10
    【Java开发指南 | 第九篇】访问实例变量和方法、继承、接口
    67

    • 相关课程

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

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用
  • 部署基于Dragonwell的Java运行环境
    • 下一篇
    DataWorks智能交互式数据开发与分析之旅