这篇文章主要介绍“分析Java8使用工厂方法supplyAsync创建CompletableFuture”，在日常操作中，相信很多人在分析Java8使用工厂方法supplyAsync创建CompletableFuture问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”分析Java8使用工厂方法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 对象是完全等价的，这意味着它提供了同样的错误管理机制，而前者你花费了大量的精力才得以构建。
验证代码如下
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似是与线程无关的。
到此，关于“分析Java8使用工厂方法supplyAsync创建CompletableFuture”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
