1.Future类简介
2.Future类的应用
3.CompletableFuture类的简介
4.CompletableFuture类的的应用
5.总结
1.Future类简介
咱们之前在这篇文章 JAVA并发编程——Callable接口和FutureTask简介和应用中说过，Future就是能够取得返回值的一个异步解决线程类。
在之前无论是继承Thread类还是实现Runnable接口，咱们始终无奈失去线程的返回值，然而Future就能够，Future是领有返回值的线程，这样说咱们可能还不明确，咱们用一个生产的案例来阐明一下这个例子。
2.Future类的应用
假如咱们当初有这样一个需要：
咱们先来看一个页面:
这是一个网上找来的数据大屏的图片，如果这个屏幕的数据要你查问出并且返回，你会怎么做？
咱们晓得大屏展现的区域不同，要查问的业务逻辑也就不一样，能够将它分成如下这几块区域：
如果当初是一名老手，可能会一个区域一个区域串行地去查问，区域一查完了查区域二，紧接着区域三，而后再返回给前端，这样效率不高。
改良办法：多个区域同步查问，最初对立返回给前端（多箭齐发）。
这么说还是比拟形象，咱们用一张图片举例：
用这张图片应该就能解释了，接下来咱们应用Future类进行代码展现一下：
public DataResult queryData() throws ExecutionException, InterruptedException, TimeoutException {
DataResult result = new DataResult();
//查问区域1
FutureTask<Integer> allHumanNum = new FutureTask<>(() -> queryHumanNum());
//应用线程池执行
CalculateThreadPoolConfig.getThreadPoolExecutor().submit(allDoctorNum);
//查问区域2
FutureTask<Integer> allMaleNum = new FutureTask<>(() -> queryAllMaleNum());
//应用线程池执行 CalculateThreadPoolConfig.getThreadPoolExecutor().submit(queryInvitedDoctorNum);
//顺次类推
//......
//拼接后果集
result.setAllHumanNum(allHumanNum.get(5, TimeUnit.SECONDS));
result.setAllMaleNum(allMaleNum.get(5, TimeUnit.SECONDS));
return result;
}能够看出，咱们无论查问多少个数据集，只用破费查问工夫最长的那一个数据集的工夫就够了，就实现了同步并行查问的成果，大大减少查问工夫。
不过咱们要留神一下这行代码：
allHumanNum.get(5, TimeUnit.SECONDS);get的意思是始终阻塞返回后果，然而加了一个数字和单位就代表，只期待5秒，不然会抛异样。
咱们工作的时候，如果须要调用他人的接口返回数据，然而不晓得对方要计算多久，可能对方一个接口就把咱们写的整个性能给拖垮。为了防止这种状况，工作中为了爱护本人，咱们须要学会加一层保险，如果对方的接口如果五秒没有返回就过时不候了。
3.CompletableFuture类的简介
介绍了后面的FutreTask类，咱们晓得这尽管是一个很好用的类，然而也是有很多的毛病的，比方：
1.get()容易阻塞
2.如果想要把多个后果汇合并成一个后果集，就须要很多FutureTask
3.FutureTask只能用于单步的简略计算，不能将两个异步计算合成一个异步计算，这两个异步计算相互独立，同时第二个又依赖第一个的后果。
4.当Future汇合中某个工作最快完结时，返回后果。
等等
毛病还是比拟多的，这个时候咱们就能够应用 CompletableFuture 类！
CompletableFuture补救了Future模式的毛病。它能够将多个后果汇合并成一个后果集，又能够将一个异步工作分成好几个阶段进行计算，前面的后果又依赖之前的后果等等。
总而言之，FutureTask能办到的事，CompletableFuture也能办到，同时CompletableFuture还能办到更多的事件！
咱们先搜寻一下CompletableFuture这个类
它实现了Future接口和CompletionStage接口。
CompletionStage：代表异步计算过程中的某一个阶段，一个阶段实现当前可能会触发另外一个阶段。
咱们认真看CompletionStage领有的办法，依据thenApply，whenComplete，exceptionally等办法，能够大略看出这个类能够对一个计算的每个阶段进行编程，先执行完一步，（依据thenApply）再执行下一步，（whenComplete）最初运行完了会怎么样，（exceptionally）抛出异样会怎么样等等。
如同就像一条调用链一样，这就是所谓的链式编程。
接下来咱们用一个案例用CompletableFuture进行实战。
4.CompletableFuture类的的应用
假如咱们当初有一个电商比价需要：
咱们要从各大网站上收集Think in java这本书的价格，开多个线程从各大网站收集，收集完之后输入信息到控制台，线程执行结束也要输入信息，请应用CompletableFuture和链式编程来进行解决。
咱们接下来开始编程：
public class CompletableFutureNextMallDemo {
// 这是须要收集的价格网站
static List<NetMall> list = Arrays.asList(
new NetMall("jd"),
new NetMall("pdff"),
new NetMall("tmall"),
new NetMall("xhs"),
new NetMall("xy"),
new NetMall("zh"),
new NetMall("sf")
);
}class NetMall {
// 这是网站的具体类以及计算价格的办法
private String mallName;
public NetMall() {
}
public NetMall(String mallName) {
this.mallName = mallName;
}
public String getMallName() {
return mallName;
}
public void setMallName(String mallName) {
this.mallName = mallName;
}
//计算价格的办法
public double calcPrice(String productName) {
try {
//假如这是计算过程
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return ThreadLocalRandom.current().nextDouble() * 2 + productName.charAt(0);
}
}最要害的执行办法
//链式调度 多箭齐发
public static List<String> getPriceByASync(List<NetMall> list, String productName) {
//循环遍历所有网站，每一个网站开启一个线程进行计算
//CompletableFuture.supplyAsync代表有返回值的执行过程，相当于Future的get(0办法
return list.stream().map(netMall -> CompletableFuture.supplyAsync(() -> {
return String.format(productName + " in %s price is %.2f", netMall.getMallName(), netMall.calcPrice(productName));
}
//当第一步执行结束后，第二步就是输入书的价格
).thenApply(r-> {
System.out.println(r);
return r;
}
//当实现工作之后，输入该网站计算实现
).whenComplete((v,e)-> {
System.out.println(netMall.getMallName()+"计算实现！");
}
//当抛出异样的时候，输入异样
).exceptionally(e->{
System.out.println("获取失败，出现异常！" );
e.printStackTrace();
return null;
})).collect(Collectors.toList())
.stream()
//最初对立调用join办法返回后果
.map(CompletableFuture::join)
//最初合并成一个List，作为后果返回
.collect(Collectors.toList());
}这里咱们将CompletableFuture抽离进去会发现代码会是如下所示：
CompletableFuture
.supplyAsync()//执行有返回值的异步解决，相当于FutureTask的get()
.thenApply()//接着执行第二步
.whenComplete()//当实现时触发的逻辑
.exceptionally();//当出现异常的时候触发的逻辑
5.总结
通过明天的学习，咱们理解了Future和CompletableFuture的根本实践和实际，这自身就是十分好用的两个类，心愿咱们在工作中能多多应用，不过也不要自觉应用多线程，因为多应用一种工具，就会多一份危险。
发表回复