标签：product 方法 getPriceAsync CompletableFuture 线程 supplyAsync Java8
文章目录
Pre
Java8 - 使用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 对象是完全等价的，这意味着它提供了同样的错误管理机制，而前者你花费了大量的精力才得以构建。
标签：product,方法,getPriceAsync,CompletableFuture,线程,supplyAsync,Java8 来源： https://blog.51cto.com/u_15239532/2835703
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。