Java中间件(2)--分布式系统&中间件从入门到精通(六)

本文涉及的产品
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
云原生网关 MSE Higress,422元/月
简介: Java中间件(2)--分布式系统&中间件从入门到精通(六)

上篇文章介绍了线程池使用的优点,synchronized和reentrantLock的区别,reentrantlock又有读写锁,适用于读多写少的场景,可以用tryLock获取锁,并且在构造器可以指定布尔值,来当做公平锁来使用。

Java中间件(1)--分布式系统&中间件从入门到精通(五)


前面说了synchronized除了有互斥性的作用外,还有可见性的作用,synchronized保证了代码块中变量的可见性,Volatile则保证了所修饰变量的可见性,是实现轻量级变量可见性方法。直接在变量前面加个volatile关键字就行。

需要注意的是,与锁相比,这里只操作了线程的可见性,绝对没有保证原子性,可见性和多个线程操作变量保证互斥性是两件事,如果volatile修饰的变量,在多线程的情况下来操作数据,并不能保证线程安全问题。


Atomics是jdk1.5之后引入的,这里面会有一些atomic开头的类,比如int在这里会显示AtomicInteger来提供相关原子性的操作,不光保证原子性,性能也能得到提升,主要因为atomicInteger内部通过JNI的方式使用硬件支持cas指令。


而wait、notify、notifyAll则是java的Object对象上的三个方法,这三个的调用都必须写在synchronized代码块里,顾名思义wait是等待的,后面两个则会唤醒它,notify是单个唤醒,notifyAll则是唤醒所有。

在代码实践中,wait的使用一般嵌在循环中,当达到一定值的时候,会判断是否到达,如果没有则继续等待,这么做主要为了防止虚假唤醒。


countdownLatch也是current包里的一个类,主要是当多个线程达到预期状态,多个线程这里指的是初始化countDownLatch里的参数,其他线程才可以从等待状态继续运行,即是可以唤醒多个等待的线程,达到自己的预期会调用countDown方法,而等待的线程则会调用await()方法,当参数一直到0的时候,则会调用notifyAll()方法,让等待线程不再等待。

 

int max = 100;
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(100, 100, 60L,
            TimeUnit.SECONDS, new LinkedBlockingQueue<>(max));
        //AtomicInteger atomicInteger = new AtomicInteger();
        CountDownLatch countDownLatch = new CountDownLatch(max);
        for (int i = 0; i < max; i++) {
            threadPoolExecutor.execute(() -> {
                //atomicInteger.incrementAndGet();
                try {
                    countDownLatch.countDown();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });
        }
        System.out.println("子线程运行中=========");
        // countDownLatch.await();
        threadPoolExecutor.shutdown();
        System.out.println("子线程运行完才会输出!!!");


cyclicBarrier使用和countDownLatch类似,但是他是可以循环使用的,而且线程池数量太少容易发生死锁一定要小心最大线程数,使用的时候,参数必须任务数+1,因为countDownLatch调用的是countDown减一,然后调用await等待,而cyclicBarrier则是所有都调用await,当所有子线程和主线程都到达那个点阻塞的时候,这时候才会进行下一步。

     

int max = 100;
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(100, 100, 60L,
            TimeUnit.SECONDS, new LinkedBlockingQueue<>(max));
        //AtomicInteger atomicInteger = new AtomicInteger();
        //CountDownLatch countDownLatch = new CountDownLatch(max);
        CyclicBarrier cyclicBarrier = new CyclicBarrier(max + 1);
        for (int i = 0; i < max; i++) {
            threadPoolExecutor.execute(() -> {
                //atomicInteger.incrementAndGet();
                try {
                    //countDownLatch.countDown();
                    System.out.println(Thread.currentThread().getName());
                    cyclicBarrier.await();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });
        }
        System.out.println("子线程运行中=========");
        cyclicBarrier.await();
        // countDownLatch.await();
        threadPoolExecutor.shutdown();
        System.out.println("子线程运行完才会输出!!!");
目录
打赏
0
36
39
46
121
分享
相关文章
Java 基础类从入门到精通实操指南
这份指南专注于**Java 17+**的新特性和基础类库的现代化用法,涵盖开发环境配置、数据类型增强(如文本块)、字符串与集合处理进阶、异常改进(如密封类)、IO操作及实战案例。通过具体代码示例,如CSV数据分析工具,帮助开发者掌握高效编程技巧。同时提供性能优化建议和常用第三方库推荐,适合从入门到精通的Java学习者。资源链接:[点此下载](https://pan.quark.cn/s/14fcf913bae6)。
118 34
2025 年 Java 从入门到精通学习笔记全新版
《Java学习笔记:从入门到精通(2025更新版)》是一本全面覆盖Java开发核心技能的指南,适合零基础到高级开发者。内容包括Java基础(如开发环境配置、核心语法增强)、面向对象编程(密封类、接口增强)、进阶技术(虚拟线程、结构化并发、向量API)、实用类库与框架(HTTP客户端、Spring Boot)、微服务与云原生(容器化、Kubernetes)、响应式编程(Reactor、WebFlux)、函数式编程(Stream API)、测试技术(JUnit 5、Mockito)、数据持久化(JPA、R2DBC)以及实战项目(Todo应用)。
81 5
2025 年 Java 核心技术从入门到精通实战指南
《2025年Java核心技术实战指南》全面覆盖Java开发的最新趋势与最佳实践。内容包括Java新特性(如模式匹配、文本块、记录类)、微服务架构(Spring Boot 3.0+、Spring Cloud)、响应式编程(Reactor、WebFlux)、容器化与云原生(Docker、Kubernetes)、数据访问技术(JPA、R2DBC)、函数式编程、单元测试与集成测试(JUnit 5、Mockito)、性能优化与监控等。通过实战案例,帮助开发者掌握构建高性能、高可用系统的技能。代码资源可从[链接](https://pan.quark.cn/s/14fcf913bae6)获取。
120 7
2025 版 Java 学习路线实战指南从入门到精通
《Java学习路线实战指南(2025版)》是一份全面的Java开发学习手册,涵盖基础环境搭建、核心语法与新特性、数据结构与算法、微服务架构、云原生技术栈、AI融合及项目实战。内容包括JDK安装配置、IntelliJ IDEA设置、Records类与模式匹配增强、LeetCode题解、Spring Cloud微服务开发、Kubernetes部署、OpenAI API调用等。结合在线商城系统案例,采用Vue 3、Spring Boot 3.5、MySQL、Elasticsearch等技术,提供从理论到实践的完整路径,助力开发者掌握2025年最新趋势与最佳实践。
154 4
java 入门学习视频_2025 最新 java 入门零基础学习视频教程
《Java 21 入门实操指南(2025年版)》提供了Java最新特性的开发指导。首先介绍了JDK 21和IntelliJ IDEA 2025.1的环境配置,包括环境变量设置和预览功能启用。重点讲解了Java 21三大核心特性:虚拟线程简化高并发编程,Record模式优化数据解构,字符串模板提升字符串拼接可读性。最后通过图书管理系统案例,展示如何运用Record定义实体类、使用Stream API进行数据操作,以及结合字符串模板实现控制台交互。该指南完整呈现了从环境搭建到实际项目开发的Java 21全流程实
47 1
Java 从入门到实战完整学习路径与项目实战指南
本文详细介绍了“Java从入门到实战”的学习路径与应用实例,涵盖基础、进阶、框架工具及项目实战四个阶段。内容包括环境搭建、语法基础、面向对象编程,数据结构与算法、多线程并发、JVM原理,以及Spring框架等核心技术。通过学生管理系统、文件下载器和博客系统等实例,帮助读者将理论应用于实践。最后,提供全链路电商系统的开发方案,涉及前后端技术栈与分布式架构。附代码资源链接,助力成为合格的Java开发者。
50 4
|
27天前
|
Java 异步编程难题拆解实操指南:从入门到精通解决异步编程关键问题
本文深入探讨了Java异步编程的实操技巧,基于Project Reactor与Spring WebFlux等技术框架,通过具体案例解决常见难题。内容涵盖反应式编程基础、回调地狱解决方案、并行任务处理、响应式REST API开发、背压策略应用、微服务异步通信及性能监控等方面。结合代码示例,详细讲解了如何构建高性能异步应用,并总结了最佳实践,帮助开发者掌握异步编程的核心技能。适合希望提升异步开发能力的技术人员阅读。
42 3
2025 年全网超全 Java 从入门到精通学习路线指南
这是一份全面的Java学习路线图,涵盖从基础到进阶的知识体系。基础阶段包括环境搭建、语法学习与面向对象编程;进阶阶段深入数据结构、多线程、JVM原理及泛型集合;框架阶段掌握Spring、MyBatis等工具;数据库阶段学习SQL、MySQL及Redis;前端技术涉及HTML、CSS与Vue;分布式阶段探讨微服务架构、Docker与Kubernetes;最后通过企业级项目实战提升性能优化与代码重构能力。资源地址:[https://pan.quark.cn/s/14fcf913bae6](https://pan.quark.cn/s/14fcf913bae6)
463 7
Java 21 与 Spring Boot 3.2 微服务开发从入门到精通实操指南
《Java 21与Spring Boot 3.2微服务开发实践》摘要: 本文基于Java 21和Spring Boot 3.2最新特性,通过完整代码示例展示了微服务开发全流程。主要内容包括:1) 使用Spring Initializr初始化项目,集成Web、JPA、H2等组件;2) 配置虚拟线程支持高并发;3) 采用记录类优化DTO设计;4) 实现JPA Repository与Stream API数据访问;5) 服务层整合虚拟线程异步处理和结构化并发;6) 构建RESTful API并使用Springdoc生成文档。文中特别演示了虚拟线程配置(@Async)和StructuredTaskSco
85 0
最新 Java 从入门到实战技术实操指南
这是一份全面的Java实操指南,涵盖从入门到微服务架构的完整学习路径。内容包括Java 21新特性(虚拟线程、Record类)、响应式编程(Spring WebFlux)、微服务架构(Spring Boot 3.2、Spring Cloud、Kubernetes)、数据库与缓存(Redis 8、R2DBC)以及云原生部署和监控(Prometheus、Grafana)。通过电商系统实战项目,掌握最新技术栈与开发技巧。适合初学者及进阶开发者,附带代码示例与资源链接,助你快速提升技能。
40 0
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问