Java中的异步编程模式：CompletableFuture与Reactive Programming的实战

Java中的异步编程模式：CompletableFuture与Reactive Programming的实战

大家好，我是微赚淘客返利系统3.0的小编，是个冬天不穿秋裤，天冷也要风度的程序猿！在现代Java开发中，异步编程已经成为提高应用性能和响应速度的重要手段。今天我们将探讨Java中的两种常用异步编程模式：CompletableFuture和Reactive Programming，并通过实际代码示例来展示它们的使用场景和优势。

一、使用CompletableFuture进行异步编程

CompletableFuture是Java 8引入的强大工具，提供了对Future的增强支持，可以以更加简洁的方式编写异步代码。

  1. 基本使用

    CompletableFuture可以创建非阻塞的异步任务，并允许任务完成时触发回调。以下是一个简单的示例：

    package cn.juwatech.async;import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;public class CompletableFutureExample {public static void main(String[] args) {CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟长时间的计算try {Thread.sleep(1000);} catch (InterruptedException e) {throw new IllegalStateException(e);}return "Hello, CompletableFuture!";});// 注册回调函数future.thenAccept(result -> System.out.println("计算结果: " + result));// 阻塞主线程等待结果 (仅用于示例)try {System.out.println("等待计算完成...");System.out.println("最终结果: " + future.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}}
}

    在这个示例中，supplyAsync方法会异步执行提供的函数（一个模拟长时间计算的任务），并返回一个CompletableFuture。通过thenAccept方法可以注册一个回调函数，在任务完成时执行。这里还演示了如何使用get()方法获取结果，但请注意，使用get()会阻塞当前线程。

  2. 组合多个异步任务

    CompletableFuture允许组合多个异步任务，这对复杂的异步场景非常有用。以下示例展示了如何组合两个异步任务：

    package cn.juwatech.async;import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;public class CompletableFutureCombine {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new IllegalStateException(e);}return "任务1结果";});CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {try {Thread.sleep(2000);} catch (InterruptedException e) {throw new IllegalStateException(e);}return "任务2结果";});CompletableFuture<String> combinedFuture = future1.thenCombine(future2, (result1, result2) -> {return result1 + " & " + result2;});System.out.println("组合结果: " + combinedFuture.get());}
}

    在这个示例中，thenCombine方法用于将两个CompletableFuture的结果合并成一个新的结果。这个模式在需要等待多个任务完成后再进行下一步处理的场景非常有用。

  3. 异常处理

    异步操作中异常处理是不可避免的。CompletableFuture提供了exceptionally方法，可以在任务出现异常时执行指定的回调：

    package cn.juwatech.async;import java.util.concurrent.CompletableFuture;public class CompletableFutureExceptionHandling {public static void main(String[] args) {CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {if (true) {throw new RuntimeException("模拟异常");}return "成功";});future.exceptionally(ex -> {System.out.println("发生异常: " + ex.getMessage());return "默认值";}).thenAccept(result -> System.out.println("最终结果: " + result));}
}

    通过exceptionally，我们可以在发生异常时执行回调并提供一个默认值，这样可以避免异常导致应用崩溃。

二、Reactive Programming实战

Reactive Programming是一种响应式编程模式，专注于数据流和变化的传播。Java中的Reactive Programming通常使用Reactor或者RxJava库实现。

  1. Reactor框架简介

    Reactor是一个基于Reactive Streams规范的库，广泛应用于Spring WebFlux等异步应用中。以下是使用Reactor的简单示例：

    package cn.juwatech.reactive;import reactor.core.publisher.Flux;public class ReactorExample {public static void main(String[] args) {Flux<String> flux = Flux.just("Hello", "Reactive", "Programming").map(String::toUpperCase).filter(word -> word.length() > 5);flux.subscribe(System.out::println);}
}

    在这个示例中，Flux用于表示一个包含多个元素的数据流。我们可以使用map和filter等操作符来对数据流进行处理。subscribe方法用于订阅数据流，从而触发流的执行。

  2. 异步处理与背压

    Reactive Programming的一个重要特性是背压（Backpressure），用于控制数据生产者与消费者之间的速度匹配。下面是一个包含背压处理的示例：

    package cn.juwatech.reactive;import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;public class BackpressureExample {public static void main(String[] args) {Flux<Integer> numbers = Flux.range(1, 100).log().publishOn(Schedulers.boundedElastic()).limitRate(10); // 背压策略：限制每次请求的元素数量numbers.subscribe(data -> {try {Thread.sleep(100); // 模拟慢速处理System.out.println("处理数据: " + data);} catch (InterruptedException e) {e.printStackTrace();}},error -> System.err.println("发生错误: " + error),() -> System.out.println("处理完成"));}
}

    这个示例中，limitRate(10)用于限制每次从生产者请求的元素数量，模拟背压的应用场景。通过publishOn(Schedulers.boundedElastic())将数据流的执行调度到一个弹性线程池上，以非阻塞的方式处理数据。

  3. 与Spring WebFlux集成

    Spring WebFlux是Spring 5引入的响应式Web框架，可以使用Reactor进行异步处理。下面是一个简单的控制器示例：

    package cn.juwatech.webflux;import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;@RestController
public class ReactiveController {@GetMapping("/hello")public Mono<String> sayHello() {return Mono.just("Hello, WebFlux!").map(String::toUpperCase);}
}

    这个控制器使用了Reactor的Mono类型，表示一个包含单个元素的异步数据流。通过Mono.just创建数据流，并使用map操作符对数据进行处理。最终，Spring WebFlux会自动将Mono转换为HTTP响应。

总结

通过CompletableFuture和Reactive Programming，Java开发者可以在不同场景下实现异步编程，从而提高应用的性能和响应速度。在选择使用哪种异步编程模式时，可以根据项目需求和开发团队的技术栈做出决定。

本文著作权归聚娃科技微赚淘客系统开发者团队，转载请注明出处！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.xdnf.cn/news/144257.html

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

碎纸片的自动拼接复原技术

碎纸片的自动拼接复原技术

摘要&#xff1a;破碎文件的拼接在司法物证复原、历史文献修复以及军事情报获取等领域都有着重要的应用。目前发现对碎纸片的拼接大部分由人工完成&#xff0c;准确率较高&#xff0c;但耗费大量人力财力及时间&#xff0c;效率很低。随着计算机技术的发展&#xff0c;人们试图…
阅读更多...
java 解析excel

java 解析excel

在Java中解析Excel文件&#xff0c;可以使用Apache POI库。以下是一个简单的例子&#xff0c;展示如何使用Apache POI读取一个Excel文件&#xff08;假设为.xlsx格式&#xff09;的内容。 首先&#xff0c;确保你的项目中包含了Apache POI的依赖。如果你使用Maven&#xff0c;…
阅读更多...
结构体易忘点

结构体易忘点

结构体初始化 当我们去初始化一个结构体的时候&#xff0c;我们常常会按变量顺序初始化&#xff0c;但其实也可以不按顺序&#xff0c;同时也可以部分数据初始化。 结构体对齐 结构体里面的成员有一定的对齐规则&#xff0c;他不是每一个空间都存着有效数据的&#xff0c;有些…
阅读更多...
综合时如何计算net delay？

综合时如何计算net delay？

在PR阶段&#xff0c;互连线的延迟可以通过抽取net的rc值计算得到。而在综合阶段&#xff0c;因为没有实际的布局布线&#xff0c;便无法去抽取net上的rc值。那么&#xff0c;线负载模型&#xff08;wire load model&#xff09;便派上用场了。 所谓线负载模型&#xff0c;就是…
阅读更多...
力扣上刷题之C语言实现（数组）

力扣上刷题之C语言实现（数组）

一. 简介 本文记录一下力扣的逻辑题。主要是数组方面的&#xff0c;使用 C语言实现。 二. 力扣上刷题之C语言实现 1. 两数之和 给定一个整数数组 nums 和一个整数目标值 target&#xff0c;请你在该数组中找出 和为目标值 target的那 两个 整数&#xff0c;并返回它们的数…
阅读更多...
uni-app安装插件

uni-app安装插件

1.通过插件市场安装https://ext.dcloud.net.cn 打开HBuilderX编辑器。 点击菜单栏中的“工具”->“插件安装”。 这里会看到已安装插件和安装新插件两个选项卡&#xff0c;点击安装新插件&#xff0c; 能看到一些核心插件&#xff0c;如果所需要的插件在核心插件里面有&…
阅读更多...
PyCharm和VS Code 安装通义灵码，可本地安装包安装，解决插件安装不上问题

PyCharm和VS Code 安装通义灵码，可本地安装包安装，解决插件安装不上问题

PyCharm和VS Code 安装通义灵码&#xff0c;可本地安装包安装&#xff0c;解决插件安装不上问题 PyCharm、VS Code 安装通义灵码介绍主要应用场景支持编程语言安装指南JetBrains IDEs 中安装指南步骤 1&#xff1a;准备工作步骤 2&#xff1a;在 JetBrains IDEs 中安装通义灵码…
阅读更多...
【快速笔记】freeRTOS

【快速笔记】freeRTOS

第十八章 低功耗Tickless模式 睡眠模式:__WFI 中断唤醒 __WFE 事件唤醒 CPU CLK关闭 停止模式&#xff1a;RAM保持 中断唤醒 当 STM32F103 处于休眠模式的时候 Cortex-M3 内核停止运行&#xff0c;但是其他外设运行正常&#xff0c; 比如 NVIC、SRAM 等。 休眠模式的功耗比其他…
阅读更多...
集运系统核心功能模块：打造高效集运仓日常管理

集运系统核心功能模块：打造高效集运仓日常管理

在跨境电商的快速发展背景下&#xff0c;集运业务作为物流环节中的重要一环&#xff0c;其效率和管理的精细化程度直接影响着客户体验和企业效益。集运系统作为提升管理效率的关键工具&#xff0c;需要具备一系列核心模块来确保业务的顺畅运行。以下是集运系统在日常管理中不可…
阅读更多...
汇总：工业导管生产中 17种检测仪进行品质检测

汇总：工业导管生产中 17种检测仪进行品质检测

定义 1&#xff09;泛指做疏导用的管子。2&#xff09;工业用导管即钻孔灌注桩水下浇灌砼导管。混凝土灌注导管用于大型的桥梁工程、中铁工程、公路工程、水电工程、高层地基的钻孔灌注桩的水下浇筑使用。 种类 工业导管种类繁多&#xff0c;主要包括钢管、铜管、不锈钢管、PVC…
阅读更多...
golang操作mysql利器-gorm

golang操作mysql利器-gorm

1、傻瓜示例 GORM通过将数据库表中的数据映射到面向对象的模型中&#xff0c;简化了数据库操作&#xff0c;使得开发者可以很方便的使用代码来操作数据库&#xff0c;而无需编写SQL语句。 目前有个mysql表&#xff1a;miniprogram_orders&#xff0c;其存储了所有用户对应的订…
阅读更多...
2023年全国研究生数学建模竞赛华为杯B题DFT类矩阵的整数分解逼近求解全过程文档及程序

2023年全国研究生数学建模竞赛华为杯B题DFT类矩阵的整数分解逼近求解全过程文档及程序

2023年全国研究生数学建模竞赛华为杯 B题 DFT类矩阵的整数分解逼近 原题再现&#xff1a; 一、问题背景   离散傅里叶变换&#xff08;Discrete Fourier Transform&#xff0c;DFT&#xff09;作为一种基本工具广泛应用于工程、科学以及数学领域。例如&#xff0c;通信信号…
阅读更多...
基于深度学习的手势识别算法（论文复现）

基于深度学习的手势识别算法（论文复现）

基于深度学习的手势识别算法&#xff08;论文复现&#xff09; 本文所涉及所有资源均在传知代码平台可获取 文章目录 基于深度学习的手势识别算法&#xff08;论文复现&#xff09;概述算法原理核心逻辑效果演示使用方式 概述 本文基于论文 Simple Baselines for Human Pose Es…
阅读更多...
Sublime Text 3 相关设置

Sublime Text 3 相关设置

打开设置 { “font_size”: 16, // 字体大小 “save_on_focus_lost”: true, // 自动保存 }
阅读更多...
YOLOv8改进系列，YOLOv8 Neck结构引入BiFPN

YOLOv8改进系列，YOLOv8 Neck结构引入BiFPN

摘要 模型效率在计算机视觉中变得越来越重要。本文系统地研究了神经网络架构设计选择用于目标检测，并提出了几项关键优化以提高效率。首先，提出了一种加权双向特征金字塔网络（BiFPN），它允许轻松快速的多尺度特征融合；其次，我们提出了一种复合缩放方法，该方法同时均匀地…
阅读更多...
MATLAB 在数学建模中的深入应用：从基础到高级实践

MATLAB 在数学建模中的深入应用：从基础到高级实践

目录 前言 一、MATLAB基础知识 1.1 MATLAB工作环境简介 1.1.1 命令窗口&#xff08;Command Window&#xff09; 1.1.2 工作区&#xff08;Workspace&#xff09; 1.1.3 命令历史&#xff08;Command History&#xff09; 1.1.4 编辑器&#xff08;Editor&#xff09; 1…
阅读更多...
Electron 安装包 asar 解压定位问题实战

Electron 安装包 asar 解压定位问题实战

背景 在开发 Electron 过程中&#xff0c;我们想知道 Electron 打包的最终形态是什么样的&#xff0c;以便我们能更好的理解 Electron 打包的过程&#xff0c;以及逆向来快速追踪一些问题&#xff0c;例如下面这个报错&#xff0c;以前这类报错都是靠猜&#xff0c;现在则可以…
阅读更多...
矿场工程车检测数据集 4900张 工程车 带标注voc yolo

矿场工程车检测数据集 4900张 工程车 带标注voc yolo

矿场工程车检测数据集 数据集描述 该数据集旨在用于矿场工程车的检测和分类任务&#xff0c;涵盖了多种常见的工程车辆类型。数据集包含了大量的工程车图像及其对应的标注信息&#xff0c;可用于训练计算机视觉模型&#xff0c;以识别和定位矿场中的不同工程车辆。 数据规模 …
阅读更多...
《微信小程序实战（3） · 推广海报制作》

《微信小程序实战（3） · 推广海报制作》

&#x1f4e2; 大家好&#xff0c;我是 【战神刘玉栋】&#xff0c;有10多年的研发经验&#xff0c;致力于前后端技术栈的知识沉淀和传播。 &#x1f497; &#x1f33b; CSDN入驻不久&#xff0c;希望大家多多支持&#xff0c;后续会继续提升文章质量&#xff0c;绝不滥竽充数…
阅读更多...
web学习——day1

web学习——day1

1.web标准 2.html和css 此时&#xff0c;学完这一部分&#xff0c;你web的具体的结构已经有了 但是呢&#xff0c;这还是太单调了&#xff0c;我们应该加点儿样式&#xff0c;这就该用到CSS了 CSS引入方式 样式1&#xff1a;颜色 样式2&#xff1a;哪怕对于同一类事物&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023