Java 异步编程 (5 种异步实现方式详解)
同步操作如果遇到一个耗时的方法,需要阻塞等待,那么我们有没有办法解决呢?让它异步执行,下面我会详解异步及实现 @mikechen
目录
- 什么是异步?
- 一、线程异步
- 二、Future异步
- 三、CompletableFuture异步
- 四、SpringBoot @Async异步
- 五、Guava异步
- Java异步编程小结
什么是异步?
首先我们先来看看一个同步的用户注册例子,流程如下:
在同步操作中,我们执行到 插入数据库 的时候,我们必须等待这个方法彻底执行完才能执行“ 发送短信 ”这个操作,如果 插入数据库 这个动作执行时间较长,发送短信需要等待,这就是典型的同步场景。
于是聪明的人们开始思考,如果两者关联性不强,能不能将一些非核心业务从主流程中剥离出来,于是有了异步编程雏形,改进后的流程如下:
这就是异步编程,它是程序并发运行的一种手段,它允许多个事件同时发生,当程序调用需要长时间运行的方法时,它不会阻塞当前的执行流程,程序可以继续运行。
在聊完异步编程后,那么我们一起来看看Java里面实现异步编程究竟有哪些方式呢?
一、线程异步
在 Java 语言中最简单使用异步编程的方式就是创建一个 线程来实现,如果你使用的 JDK 版本是 8 以上的话,可以使用 Lambda 表达式 会更加简洁。
public class AsyncThread extends Thread{@Overridepublic void run() {System.out.println("当前线程名称:" + this.getName() + ", 执行线程名称:" + Thread.currentThread().getName() + "-hello");} }
public static void main(String[] args) {// 模拟业务流程// .......// 创建异步线程 AsyncThread asyncThread = new AsyncThread();// 启动异步线程asyncThread.start(); }
当然如果每次都创建一个 Thread线程,频繁的创建、销毁,浪费系统资源,我们可以采用线程池:
private ExecutorService executor = Executors.newCachedThreadPool() ;public void fun() throws Exception {executor.submit(new Runnable(){@overridepublic void run() {try {//要执行的业务代码,我们这里没有写方法,可以让线程休息几秒进行测试Thread.sleep(10000);System.out.print("睡够啦~");}catch(Exception e) {throw new RuntimeException("报错啦!!");}}});}
将业务逻辑封装到 Runnable 或 Callable 中,交由 线程池 来执行。
二、Future异步
上述方式虽然达到了多线程并行处理,但有些业务不仅仅要执行过程,还要获取执行结果,后续提供在JUC包增加了Future。
从字面意思理解就是未来的意思,但使用起来却着实有点鸡肋,并不能实现真正意义上的异步,获取结果时需要阻塞线程,或者不断轮询。
@Test public void futureTest() throws Exception {System.out.println("main函数开始执行");ExecutorService executor = Executors.newFixedThreadPool(1);Future<Integer> future = executor.submit(new Callable<Integer>() {@Overridepublic Integer call() throws Exception {System.out.println("===task start===");Thread.sleep(5000);System.out.println("===task finish===");return 3;}});//这里需要返回值时会阻塞主线程,如果不需要返回值使用是OK的。倒也还能接收//Integer result=future.get();System.out.println("main函数执行结束");System.in.read();}
三、CompletableFuture异步
Future 类通过 get() 方法阻塞等待获取异步执行的运行结果,性能比较差。
JDK1.8 中,Java 提供了 CompletableFuture 类,它是基于异步函数式编程。相对阻塞式等待返回结果,CompletableFuture 可以通过回调的方式来处理计算结果,实现了异步非阻塞,性能更优。
CompletableFuture 实现了 Future 和 CompletionStage 接口, 并提供了多种实现异步编程的方法,如supplyAsync, runAsync以及thenApplyAsync。
下面我们使用CompletableFuture来实现上面的例子:
CompletableFuture<Long> completableFuture = CompletableFuture.supplyAsync(() -> factorial(number)); while (!completableFuture.isDone()) {System.out.println("CompletableFuture is not finished yet..."); } long result = completableFuture.get();
我们不需要显式使用 ExecutorService,CompletableFuture 内部使用了 ForkJoinPool 来处理异步任务,这使得我们的代码变的更简洁。
四、SpringBoot @Async异步
在@Async注解之前,使用多线程需要使用JDK的原生方法,非常麻烦,当有了@Async之后就比较简单了。
首先,使用 @EnableAsync 启用异步注解:
@SpringBootApplication @EnableAsync public class StartApplication {public static void main(String[] args) {SpringApplication.run(StartApplication.class, args);} }
自定义线程池:
@Configuration @Slf4j public class ThreadPoolConfiguration {@Bean(name = "defaultThreadPoolExecutor", destroyMethod = "shutdown")public ThreadPoolExecutor systemCheckPoolExecutorService() {return new ThreadPoolExecutor(3, 10, 60, TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(10000),new ThreadFactoryBuilder().setNameFormat("default-executor-%d").build(),(r, executor) -> log.error("system pool is full! "));} }
在异步处理的方法上添加注解 @Async
,当对 execute 方法
调用时,通过自定义的线程池 defaultThreadPoolExecutor
异步化执行 execute 方法
@Service public class AsyncServiceImpl implements AsyncService {@Async("defaultThreadPoolExecutor")public Boolean execute(Integer num) {System.out.println("线程:" + Thread.currentThread().getName() + " , 任务:" + num);return true;}}
用 @Async 注解标记的方法,称为异步方法。在spring boot应用中使用 @Async 很简单:
调用异步方法类上或者启动类加上注解 @EnableAsync
在需要被异步调用的方法外加上 @Async
所使用的 @Async 注解方法的类对象应该是Spring容器管理的bean对象;
五、Guava异步
Guava 提供了 ListenableFuture 类来执行异步操作
1.首先我们需要添加 guava 的maven依赖:
<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>28.2-jre</version> </dependency>
2.现在我们使用ListenableFuture来实现我们之前的例子:
ExecutorService threadpool = Executors.newCachedThreadPool(); ListeningExecutorService service = MoreExecutors.listeningDecorator(threadpool); ListenableFuture<Long> guavaFuture = (ListenableFuture<Long>) service.submit(()-> factorial(number)); long result = guavaFuture.get();
这里使用MoreExecutors获取ListeningExecutorService类的实例,然后ListeningExecutorService.submit执行异步任务,并返回 ListenableFuture实例。
Java异步编程小结
异步编程受到了越来越多的关注,尤其是在 IO 密集型的业务场景中,相比传统的同步开发模式,异步编程的优势越来越明显,希望以上介绍的5种Java异步编程方式对你有所帮助!
Java 异步编程 (5 种异步实现方式详解)相关推荐
- java中的json_JAVA中的四种JSON解析方式详解
JAVA中的四种JSON解析方式详解 我们在日常开发中少不了和JSON数据打交道,那么我们来看看JAVA中常用的JSON解析方式. 1.JSON官方 脱离框架使用 2.GSON 3.FastJSON ...
- Java网络编程(6)NIO - Channel详解
前言 NIO的三个核心组件:Buffer.Channel.Selector Java网络编程(4)NIO的理解与NIO的三个组件完成了大概的了解 Java网络编程(5)NIO - Buffer详解详细 ...
- 集丰照明|LED五种调光方式详解(DALI/DMX/0-10V/PWM/可控硅)
LED五种调光方式详解 LED的发光原理同传统照明不同,同功率的 LED 光源,因其采用的芯片不同,电流电压参数则不同,故其内部布线结构和电路分布也不同,导致了各生产厂商的光源对调光驱动的要求也不尽相 ...
- Java并发编程:线程封闭和ThreadLocal详解
什么是线程封闭 当访问共享变量时,往往需要加锁来保证数据同步.一种避免使用同步的方式就是不共享数据.如果仅在单线程中访问数据,就不需要同步了.这种技术称为线程封闭.在Java语言中,提供了一些类库和机 ...
- 电信设置的nat 虚拟服务器192.168.1.3 是什么,VMware WorkStation的三种网络连接方式详解...
一. 首先贴出本人在网络上找到与VMware网络连接相关的知识 安装完虚拟机后,默认安装了两个虚拟网卡,VMnet1和VMnet8,其他的未安装(当然也可以手动安装其他的).其中VMnet1是host ...
- java并发编程之线程的生命周期详解
java线程从创建到销毁,一共会有6个状态,不一定都经历,有可能只经历部分: NEW:初始状态,线程被创建,但是还没有调用start方法. RUNNABLED:运行状态,java线程把操作系统中的就绪 ...
- 10种网络安全攻击方式详解!
在网络攻击逐渐增加的当下,无论是企业还是个人做好网络安全防护都显得尤为重要,而想要有效应对网络攻击,我们就需要对攻击手段进行一定的了解,本文为大家盘点最常见的10种网络安全攻击方式,快来一起看看吧,希 ...
- java中三种基本循环方式详解
#博学谷IT学习技术支持# Java循环for,while和do-while 简述:如果对于同一种操作需要执行多次的话,就要使用到循环结构.它可以大大简化代码的书写量,让我们的开发更便捷. 例如:打印 ...
- android 请求方式有哪些,Android中的几种网络请求方式详解
Android应用经常会和服务器端交互,这就需要手机客户端发送网络请求,下面整理四种常用网络请求方式. java.net包中的HttpURLConnection类 Get方式: // Get方式请求 ...
最新文章
- Unity easyTouch移动代码(参考)
- matplotlib plot绘图简介
- JVM参数设置和分析
- numpy均匀分布_Python计算类库(Numpy)
- Trust is the most important thing to the team!
- #抵抗3#(#Resistance 3#) 绝对值得体验的冒险历程
- html前台检验特殊字符正则,【Qt编程】html特殊字符及正则表达式
- php历史上的今天源码,代码获取历史上的今天发生的事_基础知识
- centos oracle sqlplus,centos 下oracle sqlplus乱码问题解决
- MSSQL差异备份拿shell(转)
- LMM(LightMoonMovie)亮月湾电影分享管理系统;
- matlab图像处理中的错误--调用imhist报错
- 月薪3千与3万文案的区别!一字千金就体现在细微之处
- rop检查_【国际高影响力文章红毯秀7月】白内障扩瞳安全性、ROP筛查新标准、45mmHg眼内灌注压...
- hazy的leetcode刷题笔记(三)
- 我也说说《变形金刚》2
- Nginx多个域名配置ssl证书出错解决方案
- V8引擎:编译器和解析器是如何执行一段javascript代码的?
- ArduPilot之H743+BMI270x2+First Normal Takeoff
- 区块链共享经济:为什么可以挑战Uber和Airbnb?