Java8 使用工厂方法supplyAsync创建CompletableFuture实例
目前为止我们已经了解了如何通过编程创建 CompletableFuture 对象以及如何获取返回值，虽然看起来这些操作已经比较方便，但还有进一步提升的空间， CompletableFuture 类自身提供了大量精巧的工厂方法，使用这些方法能更容易地完成整个流程，还不用担心实现的细节。
可以看到我们使用new Thread的方式，显然是不恰当的。
使用工厂方法 supplyAsync创建 CompletableFuture
采用 supplyAsync 方法后，可以用一行代码重写getPriceAsync 方法。
【使用工厂方法 supplyAsync 创建 CompletableFuture 对象】
public Future<Double> getPriceAsync(String product) {
return CompletableFuture.supplyAsync(() -> calculatePrice(product));
}
supplyAsync 方法接受一个生产者（ Supplier ）作为参数，返回一个 CompletableFuture对象，该对象完成异步执行后会读取调用生产者方法的返回值。
生产者方法会交由 ForkJoinPool池中的某个执行线程（ Executor ）运行，但是你也可以使用 supplyAsync 方法的重载版本，传递第二个参数指定不同的执行线程执行生产者方法。
一般而言，向 CompletableFuture 的工厂方法传递可选参数，指定生产者方法的执行线程是可行的，后面我们会会介绍如何使用适合你应用特性的执行线程改善程序的性能。
对比
刚刚的代码
public Future<Double> getPriceAsync(String product) {
return CompletableFuture.supplyAsync(() -> calculatePrice(product));
}
getPriceAsync 方法返回的 CompletableFuture 对象和 下面的代码
public Future<Double> getPriceAsync(String product) {
CompletableFuture<Double> futurePrice = new CompletableFuture<>();
new Thread( () -> {
try {
double price = calculatePrice(product);
futurePrice.complete(price);
} catch (Exception ex) {
futurePrice.completeExceptionally(ex);
}
}).start();
return futurePrice;
}
手工创建和完成的 CompletableFuture 对象是完全等价的，这意味着它提供了同样的错误管理机制，而前者你花费了大量的精力才得以构建。
对CompletableFuture async的理解
验证代码如下
ExecutorService executorService = Executors.newFixedThreadPool(3);
//executorService.submit(new RuleTestRunnable(1));
List<Integer> taskList = new ArrayList<>();
for (int i = 0; i < 30; i++) {
taskList.add(i);
}
CompletableFuture<String> a1 = CompletableFuture.supplyAsync(() -> {
logger.info("线程1{}{}","开始");
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("线程1{}{}","结束");
return "1";
},executorService);
CompletableFuture<String> a2 = CompletableFuture.supplyAsync(() -> {
logger.info("线程2{}{}","开始");
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("线程2{}{}","结束");
return "1";
},executorService);
CompletableFuture<Object> a= a1.thenCombineAsync(a2,(s1,s2) -> {
logger.info("组合线程{}{}");
return s1+s2;
},executorService);
Object result = a.get();
当executorService线程池大小为2时候，执行结果如下：
[pool-4-thread-1] INFO test.rcd.thread.CompletableFutureDemo.lambda$mains$4:127 - 组合线程{}{}
a1.thenCombineAsync方法始终被线程1或2执行
当executorService线程池大小为3时候,执行结果如下：
[pool-4-thread-3] INFO test.rcd.thread.CompletableFutureDemo.lambda$mains$4:127 - 组合线程{}{}
a1.thenCombineAsync方法始终被线程3执行
改为a1.thenCombine()，执行结果：
a1.thenCombineAsync方法始终被线程1或2执行
由此可见，async方法始终尝试取新线程执行方法，不带async方法则会从当前线程里取线程执行.CompletableFuture似是与线程无关的。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
对于JNI来说，我们可以使用native关键字来定义本地方法。那么在JNA中有那些在JAVA代码中定义本地方法的方式呢？对JNA本地方法映射JAVA代码的相关知识感兴趣的朋友一起看看吧2022-04-04
这篇文章主要介绍了Java类加载器和类加载机制,结合实例形式分析了java类加载器与类加载机制原理、实现方法及相关操作技巧,需要的朋友可以参考下2019-07-07
平时项目中只要涉及表，那么一定能接触到众多各式各样的ID编号。本文将通过Java语言实现手写一个ID生成工具类，需要的小伙伴可以参考一下2022-11-11
Java 中的 NoSuchMethodException 异常及解决思路(最新推荐)
NoSuchMethodException异常是Java中使用反射机制时常见的错误,它通常由方法名或参数不匹配、访问权限问题、方法签名不匹配等原因引发,解决方法包括核实方法名及其参数类型、确认方法访问权限、检查方法签名和重载问题、确保方法存在于正确的类中,感兴趣的朋友一起看看吧2025-01-01
SpringBoot使用Mybatis-Generator配置过程详解
这篇文章主要介绍了SpringBoot使用Mybatis-Generator配置过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-02-02
这篇文章主要为大家介绍了java爬虫Jsoup主要类及功能使用详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-12-12
跟着思路走，之后从简单题入手，反复去看，做过之后可能会忘记，之后再做一次，记不住就反复做，反复寻求思路和规律，慢慢积累就会发现质的变化2022-04-04
最小生成树（Minimum Spanning Tree）就是给定无向图中,边权重最小的生成树,下面这篇文章主要给大家介绍了关于Java图论进阶之最小生成树算法的相关资料,文中通过图文以及实例代码介绍的非常详细,需要的朋友可以参考下2023-01-01
Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的2022-09-09
Java中==符号与equals()的使用详解(测试两个变量是否相等)
下面小编就为大家带来一篇Java中==符号与equals()的使用详解(测试两个变量是否相等)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-07-07
最新评论