Java8 CompletableFuture 异步执行操作
更新时间：2021年06月22日 18:02:04 作者：ACGkaka_
CompletableFuture是java8提供的基于异步操作的封装，日常开发中经常会用到，接下来通过本文给大家介绍Java8 CompletableFuture 异步执行操作，感兴趣的朋友一起看看吧
1.简介
CompletableFuture 是 JDK8 提供的一个异步执行工具。
示例1：
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
for (int i = 0; i < 3; i++) {
System.out.println(i);
try {
Thread.sleep(1000L);
} catch (InterruptedException ignored) {
}
}
System.out.println("Future Finished.");
});
System.out.println("Main Thread Finished.");
future.get();
}
输出结果1：
2.异步执行
CompletableFuture 提供了两个方法用于异步执行：
CompletableFuture.runAsync，没有返回值；CompletableFuture.supplyAsync，有返回值。
示例：
public static void main(String[] args) throws ExecutionException, InterruptedException {
// runAsync 没有返回值
CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> System.out.println("future1 executed."));
// supplyAsync 有返回值
CompletableFuture<Object> future2 = CompletableFuture.supplyAsync(() -> {
System.out.println("future2 executed.");
return "result";
});
System.out.println("future1.get(): " + future1.get());
System.out.println("future2.get(): " + future2.get());
}
输出结果：
3.守护线程
CompletableFuture返回的Future默认为守护线程，如果不调用get()获取结果，主线程结束后会自动结束。主要有以下4种情景：
- 情景1： 执行时间 > 主线程时间，异步线程
会执行； - 情景2： 执行时间 > 主线程，是守护线程，会被杀死，异步线程
不会执行； - 情景3： 执行时间 > 主线程，但是不是守护线程，不会被杀死，异步线程
会执行； - 情景4： ExecutorService.submit()，默认不是守护线程，不会被杀死，异步线程
会执行。
示例：
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(2);
// 1.执行时间 < 主线程，会打印
CompletableFuture<Void> future1 = CompletableFuture.runAsync(() ->
System.out.println("Thread1 是否为守护线程 : " + Thread.currentThread().isDaemon()));
// 2.执行时间 > 主线程，是守护线程，会被杀死，不会打印
CompletableFuture.runAsync(() -> {
try {
Thread.sleep(3000L);
System.out.println("Thread2 是否为守护线程 : " + Thread.currentThread().isDaemon());
} catch (InterruptedException e) {
e.printStackTrace();
}});
// 3.执行时间 > 主线程，但是不是守护线程，不会被杀死，会打印
CompletableFuture.runAsync(() -> {
try {
Thread.sleep(1000L);
System.out.println("Thread3 等待1秒");
System.out.println("Thread3 是否为守护线程 : " + Thread.currentThread().isDaemon());
} catch (InterruptedException e) {
e.printStackTrace();
}}, executorService);
// 4.ExecutorService.submit()，默认不是守护线程，不会被杀死，会打印。
executorService.submit(() -> {
try {
Thread.sleep(2000L);
System.out.println("Thread4 等待2秒");
System.out.println("Thread4 是否为守护线程 : " + Thread.currentThread().isDaemon());
} catch (InterruptedException e) {
e.printStackTrace();
}});
// 主线程执行完毕
System.out.println("Main Thread Finished.");
executorService.shutdown();
}
输出结果2：
4.处理执行结果
CompletableFuture还封装了很多处理执行结果操作。操作太多，列举比较常用的几种：
thenAccept()： 对结果进行使用；
thenApply()： 对结果进行转换；
exceptionally()： 对异常进行处理；
whenComplete()： 相当于 thenAccept() + thenApply() + exceptionally().
示例：
public static void main(String[] args) {
// thenAccept对结果进行使用
System.out.println("------------------------------");
CompletableFuture.supplyAsync(() -> "Thread1 Finished.").thenAccept(System.out::println);
// thenApply对结果进行转换
System.out.println("------------------------------");
CompletableFuture.supplyAsync(() -> "Thread2 Finished.")
.thenApply(s -> s + " + thenApply()")
.thenAccept(System.out::println);
// exceptionally对异常进行处理
System.out.println("------------------------------");
CompletableFuture.supplyAsync(() -> {throw new RuntimeException("Thread3 Failed.");})
.exceptionally(Throwable::toString).thenAccept(System.out::println);
// 主线程执行完毕
System.out.println("------------------------------");
System.out.println("Main Thread Finished.");
}
输出结果：
whenComplete() 示例：
public static void main(String[] args) throws ExecutionException, InterruptedException {
// thenAccept对结果进行使用
System.out.println("------------------------------");
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Thread1 Finished.").whenComplete(new BiConsumer<String, Throwable>() {
@Override
public void accept(String s, Throwable throwable) {
System.out.println("result: " + s);
System.out.println("throwable: " + throwable);
}
});
// exceptionally对异常进行处理
System.out.println("------------------------------");
CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Thread3 Failed.");
}).whenComplete(new BiConsumer<Object, Throwable>() {
@Override
public void accept(Object s, Throwable throwable) {
System.out.println("result: " + s);
System.out.println("throwable: " + throwable);
}
});
System.out.println("------------------------------");
System.out.println("future.get(): " + future.get());
// 主线程执行完毕
System.out.println("------------------------------");
System.out.println("Main Thread Finished.");
}
输出结果：
整理完毕，完结撒花~
以上就是Java8 CompletableFuture 异步执行的详细内容，更多关于Java8 CompletableFuture 异步执行的资料请关注脚本之家其它相关文章！
您可能感兴趣的文章:
- Java8 CompletableFuture runAsync学习总结submit() execute()等
- Java CompletableFuture实现多线程异步编排
- 详解Java8 CompletableFuture的并行处理用法
- Java8 使用工厂方法supplyAsync创建CompletableFuture实例
- Java8 自定义CompletableFuture的原理解析
- Java并发 CompletableFuture异步编程的实现
- Java8新的异步编程方式CompletableFuture实现
- Java8 CompletableFuture详解
- Java中的CompletableFuture原理与用法
相关文章
这篇文章主要介绍了springboot配置https访问的方法,需要的朋友可以参考下2018-11-11
大家好，本篇文章主要讲的是详解Java的继承，感兴趣的同学赶快来看一看吧，对你有帮助的话记得收藏一下，方便下次浏览2022-01-01
这篇文章主要为大家详细介绍了Java编写实现窗体程序显示日历，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-06-06
这篇文章主要介绍了Java 爬虫如何爬取需要登录的网站,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-10-10
下面小编就为大家带来一篇JVM内存管理之JAVA语言的内存管理详解。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
这篇文章主要为大家详细介绍了使用javax.sound实现简单音频播放，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-03-03
这篇文章主要介绍了java读取某个文件夹下的所有文件实例代码的相关资料,需要的朋友可以参考下2017-03-03
这篇文章主要介绍了Spring整合websocket整合应用示例（下）的相关资料,需要的朋友可以参考下2016-04-04
本篇文章主要介绍了Spring Data JPA调用存储过程实例代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。2017-04-04
这篇文章主要介绍了详解springcloud Feign的Hystrix支持，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-01-01
最新评论