Java中的异步编程模型
1.什么是异步编程?
异步编程是一种编程模式,允许程序在等待某些操作(例如文件I/O或网络请求)完成时,不必停下来等待,而是继续执行其他任务。当异步操作完成时,回调函数或任务调度器会处理结果,从而提高程序的并发性和响应速度。
2.同步 vs 异步
- 同步:在调用某个方法时,调用方会一直等待该方法执行完毕,才会继续执行后续的操作。期间,调用方被阻塞。
- 异步:调用某个方法时,调用方可以立即返回,并在方法执行完毕后,通过回调或事件通知的方式处理结果,调用方不会被阻塞。
3.Java中的异步编程工具
Java从java.util.concurrent包开始支持丰富的并发工具,特别是CompletableFuture类,它是异步编程的核心工具。让我们先看看CompletableFuture的基本使用方法。
CompletableFuture:强大的异步任务管理
CompletableFuture是Java 8引入的类,它允许我们轻松地编写异步代码。它不仅可以创建异步任务,还能链式地处理任务结果。
3.1创建异步任务
我们可以通过runAsync()或supplyAsync()方法来创建异步任务。runAsync()适用于不返回结果的任务,而supplyAsync()适用于返回结果的任务。
import java.util.concurrent.CompletableFuture;public class AsyncExample {public static void main(String[] args) {// 创建一个异步任务,模拟计算CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {System.out.println("正在执行异步任务...");try {Thread.sleep(2000); // 模拟耗时操作} catch (InterruptedException e) {e.printStackTrace();}System.out.println("异步任务完成");});// 主线程继续执行System.out.println("主线程继续执行其他操作...");// 等待异步任务完成future.join();}
}
3.2获取异步任务结果
使用supplyAsync()时,我们可以通过thenApply()方法来处理异步任务的结果。thenApply()接收一个函数,表示任务完成后的处理逻辑。
import java.util.concurrent.CompletableFuture;public class AsyncResultExample {public static void main(String[] args) {// 创建一个返回结果的异步任务CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {System.out.println("正在计算...");return 10 + 20;});// 处理结果future.thenApply(result -> {System.out.println("计算结果: " + result);return result * 2;}).thenAccept(finalResult -> {System.out.println("最终结果: " + finalResult);});// 主线程继续执行System.out.println("主线程继续运行...");}
}
3.3链式处理任务
CompletableFuture的一个强大功能是它允许链式地组合多个异步任务。每个任务可以依赖于上一个任务的结果,从而形成复杂的异步流程。
import java.util.concurrent.CompletableFuture;public class ChainedTasksExample {public static void main(String[] args) {CompletableFuture.supplyAsync(() -> {// 第一个任务System.out.println("任务1: 获取用户数据...");return "用户数据";}).thenApply(userData -> {// 第二个任务,依赖第一个任务的结果System.out.println("任务2: 处理 " + userData);return "处理后的" + userData;}).thenAccept(finalResult -> {// 第三个任务,最终处理结果System.out.println("任务3: 显示结果 " + finalResult);});System.out.println("主线程继续执行...");}
}
3.4处理异常
异步任务中可能会发生异常。CompletableFuture提供了exceptionally()方法来捕获并处理异常,确保程序不会因为某个异步任务的失败而崩溃。
import java.util.concurrent.CompletableFuture;public class ExceptionHandlingExample {public static void main(String[] args) {CompletableFuture.supplyAsync(() -> {// 模拟异常if (true) {throw new RuntimeException("任务失败了");}return 42;}).exceptionally(ex -> {System.out.println("发生异常: " + ex.getMessage());return -1; // 返回默认值}).thenAccept(result -> {System.out.println("最终结果: " + result);});System.out.println("主线程继续执行...");}
}
4.异步事件驱动模型
除了CompletableFuture,在事件驱动开发中,异步编程也是核心。例如,在处理GUI编程、网络请求、I/O操作时,通常通过异步事件驱动模型来提高系统的响应速度。
在Java中,GUI框架如Swing、JavaFX等,都会使用异步事件模型处理用户输入,避免界面阻塞。
4.1例:JavaFX中的异步事件处理
在JavaFX中,我们可以通过异步任务来避免UI卡顿。例如,当我们需要从网络获取数据时,可以使用异步任务来执行,并在任务完成后更新UI。
import javafx.application.Application;
import javafx.concurrent.Task;
import javafx.scene.Scene;
import javafx.scene.control.Label;
import javafx.scene.layout.StackPane;
import javafx.stage.Stage;public class AsyncJavaFXExample extends Application {@Overridepublic void start(Stage primaryStage) {Label label = new Label("等待中...");StackPane root = new StackPane(label);Scene scene = new Scene(root, 300, 200);primaryStage.setTitle("JavaFX异步任务示例");primaryStage.setScene(scene);primaryStage.show();// 创建异步任务Task<String> task = new Task<String>() {@Overrideprotected String call() throws Exception {// 模拟耗时操作Thread.sleep(2000);return "任务完成";}};// 当任务完成时,更新UItask.setOnSucceeded(event -> label.setText(task.getValue()));// 启动任务new Thread(task).start();}public static void main(String[] args) {launch(args);}
}
独步天涯路自远,我心如铁志如磐。
相关文章:
Java中的异步编程模型
1.什么是异步编程? 异步编程是一种编程模式,允许程序在等待某些操作(例如文件I/O或网络请求)完成时,不必停下来等待,而是继续执行其他任务。当异步操作完成时,回调函数或任务调度器会处理结果&…...
opencv 按位操作
opencv位运算说明 按位与,按位或,按位非,按位异或 在 OpenCV 中,按位操作函数的接口一般包括两个或多个图像数组(矩阵)作为输入,常常还会有一个可选的掩码参数。下面我列出每个函数的具体接口…...
【Bug】STM32串口空闲中断接收不定长数据异常
Bug 使用标准库配置STM32F103C8T6的串口1开启接收中断和空闲中断,通过空闲中断来判断数据发送是否结束,收到数据后切换板载LED灯所接引脚电平,发现LED出现三种情况,熄灭、微亮、正常亮,但是LED灯所接的GPIO引脚为PC13…...
使用Radzen Blazor组件库开发的基于ABP框架炫酷UI主题
一、项目简介 使用过ABP框架的童鞋应该知道它也自带了一款免费的Blazor UI主题,它的页面是长这样的: 个人感觉不太美观,于是网上搜了很多Blazor开源组件库,发现有一款样式非常不错的组件库,名叫:Radzen&am…...
Java入门4——输入输出+实用的函数
在本篇博客,采用代码解释的方法,帮助大家熟悉Java的语法 一、输入和输出 在Java当中,我们一般有这样输入输出: import java.util.Scanner;public class javaSchool {public static void main(String[] args) {Scanner scanner …...
《当尼采哭泣》
这是一个相互救赎的故事。故事铺垫比较冗长,看到一半的时候一度看不下去。直到看到最后两章才最终感觉值得一看。很多表层现象,就像露出水面的冰山。解决表面的问题,需要深挖冰山水下的部分。一个人碰到的最难解决的问题不在外部,…...
TOMCAT Using CATALINA——OPTS,闪退解决方法(两种)
【Java实践】安装tomcat启动startup.bat出现闪退问题_安装tomcat点击startup闪退-CSDN博客...
Android音视频 MediaCodec框架-启动编码(4)
Android音视频 MediaCodec框架-启动编码 简述 上一节我们介绍了MediaCodec框架创建编码器流程,编解码的流程其实基本是一样的,只是底层的最终的实现组件不同,所以我们只看启动编码流程。 MediaCodec启动编码 从MediaCodec的start方法开始…...
# Go 语言中的 Interface 和 Struct
go package mainimport ("fmt" )// Girl 是一个接口,定义了所有"女性"类型都应该实现的方法 type Girl interface {call()introduce() }// Wife 结构体代表妻子 type wife struct {name stringage intyearsWed int }// call 方法…...
SSM与Springboot是什么关系? -----区别与联系
SSM(Spring Spring MVC MyBatis)和 Spring Boot 都是基于 Spring 框架的技术栈,但它们在使用方式、配置复杂度以及设计理念上有所不同。下面是 SSM 和 Spring Boot 之间的关系及主要区别: SSM (Spring Spring MVC MyBatis) 定…...
MATLAB小波变换图像融合系统
二、应用背景及意义 本课题利用小波变换进行图像的融合,然后对融合的结果进行图像质量的评价。所谓小波变换图像融合就是对多个的信息目标进行一系列的图像提取和合成,进而可以获得对同一个信息目标的更为精确、全面、可靠的高低频图像信息描述。并且也…...
nginx-安装和80端口映射多域名和ssl
一、安装所需插件 1、安装 gcc gcc是linux下的编译器,它可以编译 C,C,Ada,Object C和Java等语言。 yum -y install gcc 2、安装pcre、pcre-devel pcre是一个perl库,包括perl兼容的正则表达式库,nginx的http模块使用pcre来解析 正则表达式。…...
SVN小乌龟 create patch 和 apply patch 功能
在SVN(Subversion)版本控制系统中,使用“小乌龟”(TortoiseSVN)这个图形界面工具可以极大地简化SVN操作。TortoiseSVN中的“create patch”和“apply patch”是两个非常有用的功能,它们与版本控制中的补丁&…...
#MySQL `SELECT` 语句执行流程详解
在数据库操作中,MySQL 的 SELECT 语句是用于查询数据最常见的 SQL 语句之一。理解它的执行流程对数据库优化和性能提升具有至关重要的意义。本文将详细解析 SELECT 语句从发出请求到返回结果的每个步骤,并结合 MySQL 的架构为您提供深度理解。 ## 1. 连接…...
docker容器运行一段时间提示Failed to initialize NVML: Unknown Error
情况描述 服务器使用docker启动容器。启动以后一切正常也能跑程序。但是,在运行一段时间(2天左右不等),会发现gpu掉了。输入nvidia-smi提示 Failed to initialize NVML: Unknown Error 主要发生条件是,docker启动的…...
PPT自动化:快速更换PPT图片(如何保留原图片样式等参数更换图片)
文章目录 📖 介绍 📖🏡 演示环境 🏡📒 PPT更换图片 📒1. 安装 `python-pptx` 模块2. 加载PPT文件3. 查找并替换图片3.1 查找图片形状3.2 获取原图片的样式和位置3.3 替换图片4. 保存修改后的PPT文件5. 设置图片的相关参数5.1 设置透明度5.2 设置边框🚀 保留所有参…...
秒懂MVC, MVP, MVVM框架
框架的目标 关注点分离 (separation of concerns)低耦合 (Loose coupling)容易维护 (Maintainable)容易被测试 (Testable)...
IDEA社区版如何用tomcat运行war包
前言 我们在使用IDEA开发Java应用时,有时候需要运行的不是jar包,而是war包,但IDEA社区版默认是不支持tomcat容器的,无法直接运行war包。不过好在我们有一个强大的插件来支持我们使用tomcat,那么,我们应该如…...
如何使用 Git Cherry-Pick 和 Reset 处理误提交,并确保安全回滚
在开发过程中,偶尔会遇到不小心将功能开发提交到错误分支上的情况。假设我们计划在 10 月 24 号上线某些功能,但却不小心在 10 月 17 号的上线分支上进行了开发。为了解决这个问题并将误提交的内容移到正确的分支上,我们可以借助 Git 的一些功…...
Goland 搭建Gin脚手架
一、使用编辑器goland 搭建gin 打开编辑器 新建项目后 点击 create 二、获得Gin框架的代码 命令行安装 go get -u github.com/gin-gonic/gin 如果安装不上,配置一下环境 下载完成 官网git上下载 这样就下载完成了。、 不过这种方法需要设置一下GOPATH 然后再执…...
国防科技大学计算机基础课程笔记02信息编码
1.机内码和国标码 国标码就是我们非常熟悉的这个GB2312,但是因为都是16进制,因此这个了16进制的数据既可以翻译成为这个机器码,也可以翻译成为这个国标码,所以这个时候很容易会出现这个歧义的情况; 因此,我们的这个国…...
【Linux】shell脚本忽略错误继续执行
在 shell 脚本中,可以使用 set -e 命令来设置脚本在遇到错误时退出执行。如果你希望脚本忽略错误并继续执行,可以在脚本开头添加 set e 命令来取消该设置。 举例1 #!/bin/bash# 取消 set -e 的设置 set e# 执行命令,并忽略错误 rm somefile…...
IGP(Interior Gateway Protocol,内部网关协议)
IGP(Interior Gateway Protocol,内部网关协议) 是一种用于在一个自治系统(AS)内部传递路由信息的路由协议,主要用于在一个组织或机构的内部网络中决定数据包的最佳路径。与用于自治系统之间通信的 EGP&…...
Frozen-Flask :将 Flask 应用“冻结”为静态文件
Frozen-Flask 是一个用于将 Flask 应用“冻结”为静态文件的 Python 扩展。它的核心用途是:将一个 Flask Web 应用生成成纯静态 HTML 文件,从而可以部署到静态网站托管服务上,如 GitHub Pages、Netlify 或任何支持静态文件的网站服务器。 &am…...
【JavaSE】绘图与事件入门学习笔记
-Java绘图坐标体系 坐标体系-介绍 坐标原点位于左上角,以像素为单位。 在Java坐标系中,第一个是x坐标,表示当前位置为水平方向,距离坐标原点x个像素;第二个是y坐标,表示当前位置为垂直方向,距离坐标原点y个像素。 坐标体系-像素 …...
AspectJ 在 Android 中的完整使用指南
一、环境配置(Gradle 7.0 适配) 1. 项目级 build.gradle // 注意:沪江插件已停更,推荐官方兼容方案 buildscript {dependencies {classpath org.aspectj:aspectjtools:1.9.9.1 // AspectJ 工具} } 2. 模块级 build.gradle plu…...
均衡后的SNRSINR
本文主要摘自参考文献中的前两篇,相关文献中经常会出现MIMO检测后的SINR不过一直没有找到相关数学推到过程,其中文献[1]中给出了相关原理在此仅做记录。 1. 系统模型 复信道模型 n t n_t nt 根发送天线, n r n_r nr 根接收天线的 MIMO 系…...
html-<abbr> 缩写或首字母缩略词
定义与作用 <abbr> 标签用于表示缩写或首字母缩略词,它可以帮助用户更好地理解缩写的含义,尤其是对于那些不熟悉该缩写的用户。 title 属性的内容提供了缩写的详细说明。当用户将鼠标悬停在缩写上时,会显示一个提示框。 示例&#x…...
C++.OpenGL (20/64)混合(Blending)
混合(Blending) 透明效果核心原理 #mermaid-svg-SWG0UzVfJms7Sm3e {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-SWG0UzVfJms7Sm3e .error-icon{fill:#552222;}#mermaid-svg-SWG0UzVfJms7Sm3e .error-text{fill…...
DiscuzX3.5发帖json api
参考文章:PHP实现独立Discuz站外发帖(直连操作数据库)_discuz 发帖api-CSDN博客 简单改造了一下,适配我自己的需求 有一个站点存在多个采集站,我想通过主站拿标题,采集站拿内容 使用到的sql如下 CREATE TABLE pre_forum_post_…...
