在JDK1.5曾经提供了Future和Callable的实现,能够用于阻塞式获取后果,如果想要异步获取后果,通常都会以轮询的形式去获取后果,如下:
//定义一个异步工作
Future<String> future = executor.submit(()<span style="color:transparent">来源gaodai#ma#com搞*代#码网</span> -> {
Thread.sleep(2000);
return "hello world";
});
//轮询获取后果
while (true) {
if (future.isDone()) {
System.out.println(future.get());
break;
}
}
从下面的模式看来轮询的形式会消耗无谓的CPU资源，而且也不能及时地失去计算结果.所以要实现真正的异步,上述这样是齐全不够的,在Netty中,咱们随处可见异步编程
ChannelFuture f = serverBootstrap.bind(port).sync();
f.addListener(new GenericFutureListener<Future<? super Void>>() {
@Override
public void operationComplete(Future<? super Void> future) throws Exception {
System.out.println("complete");
}
});
而JDK1.8中的CompletableFuture就为咱们提供了异步函数式编程,CompletableFuture提供了十分弱小的Future的扩大性能，能够帮忙咱们简化异步编程的复杂性，提供了函数式编程的能力，能够通过回调的形式解决计算结果，并且提供了转换和组合CompletableFuture的办法。
- 创立CompletableFuture对象
CompletableFuture提供了四个静态方法用来创立CompletableFuture对象：
Asynsc示意异步,而supplyAsync与runAsync不同在与前者异步返回一个后果,后者是void.第二个函数第二个参数示意是用咱们本人创立的线程池,否则采纳默认的ForkJoinPool.commonPool()作为它的线程池.其中Supplier是一个函数式接口,代表是一个生成者的意思,传入0个参数,返回一个后果.(更具体的能够看我另一篇文章)
CompletableFuture<String> future = CompletableFuture.supplyAsync(()->{
return "hello world";
});
System.out.println(future.get()); //阻塞的获取后果 ''helllo world"
- 被动计算
以下4个办法用于获取后果
getNow有点非凡，如果后果曾经计算完则返回后果或者抛出异样，否则返回给定的valueIfAbsent值。join()与get()区别在于join()返回计算的后果或者抛出一个unchecked异样(CompletionException)，而get()返回一个具体的异样.
被动触发计算.
下面办法示意当调用CompletableFuture.get()被阻塞的时候,那么这个办法就是完结阻塞,并且get()获取设置的value.
public static CompletableFuture<Integer> compute () {
final CompletableFuture<Integer> future = new CompletableFuture<>();
return future;
}
public static void main (String[]args) throws Exception {
final CompletableFuture<Integer> f = compute();
class Client extends Thread {
CompletableFuture<Integer> f;
Client(String threadName, CompletableFuture<Integer> f) {
super(threadName);
this.f = f;
}
@Override
public void run() {
try {
System.out.println(this.getName() + ": " + f.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
new Client("Client1", f).start();
new Client("Client2", f).start();
System.out.println("waiting");
//设置Future.get()获取到的值
f.complete(100);
//以异样的模式触发计算
//f.completeExceptionally(new Exception());
Thread.sleep(1000);
}
- 计算结果实现时的解决
下面4个办法是当计算阶段完结的时候触发,BiConsumer有两个入参,别离代表计算返回值,另外一个是异样.无返回值.办法不以Async结尾，意味着Action应用雷同的线程执行，而Async可能会应用其它的线程去执行(如果应用雷同的线程池，也可能会被同一个线程选中执行)。
future.whenCompleteAsync((v, e) -> {
System.out.println("return value:" + v + " exception:" + e);
});
handle()
与whenComplete()不同的是这个函数返回CompletableFuture并不是原始的CompletableFuture返回的值,而是BiFunction返回的值.
- CompletableFuture的组合
thenApply
当计算结算实现之后,前面能够接持续一系列的thenApply,来实现值的转化.
它们与handle办法的区别在于handle办法会解决失常计算值和异样，因而它能够屏蔽异样，防止异样持续抛出。而thenApply办法只是用来解决正常值，因而一旦有异样就会抛出。
CompletableFuture<String> future = CompletableFuture.supplyAsync(()->{
return "hello world";
});
CompletableFuture<String> future3 = future.thenApply((element)->{
return element+" addPart";
}).thenApply((element)->{
return element+" addTwoPart";
});
System.out.println(future3.get());//hello world addPart addTwoPart
- CompletableFuture的Consumer
只对CompletableFuture的后果进行生产,无返回值,也就是最初的CompletableFuture是void.
//入参为原始的CompletableFuture的后果.
CompletableFuture future4 = future.thenAccept((e)->{
System.out.println("without return value");
});
future4.get();
thenAcceptBoth
这个办法用来组合两个CompletableFuture,其中一个CompletableFuture期待另一个CompletableFuture的后果.
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
return "hello world";
});
CompletableFuture future5 = future.thenAcceptBoth(CompletableFuture.completedFuture("compose"),
(x, y) -> System.out.println(x + y));//hello world compose
- Either和ALL
thenAcceptBoth是当两个CompletableFuture都计算实现，而咱们上面要理解的办法applyToEither是当任意一个CompletableFuture计算实现的时候就会执行。
Random rand = new Random();
CompletableFuture<Integer> future9 = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(1000 + rand.nextInt(1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
return 100;
});
CompletableFuture<Integer> future10 = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(1000 + rand.nextInt(1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
return 200;
});
//两个中任意一个计算实现,那么触发Runnable的执行
CompletableFuture<String> f = future10.applyToEither(future9,i -> i.toString());
//两个都计算实现,那么触发Runnable的执行
CompletableFuture f1 = future10.acceptEither(future9,(e)->{
System.out.println(e);
});
System.out.println(f.get());
如果想组合超过2个以上的CompletableFuture,allOf和anyOf可能会满足你的要求.allOf办法是当所有的CompletableFuture都执行完后执行计算。anyOf办法是当任意一个CompletableFuture执行完后就会执行计算，计算的后果雷同。
总结
有了CompletableFuture之后,咱们本人实现异步编程变得轻松很多,这个类也提供了许多办法来组合CompletableFuture.联合Lambada表达式来用,变得很轻松.
f的whenComplete的内容由哪个线程来执行，取决于哪个线程X执行了f.complete()。然而当X线程执行了f.complete()的时候，whenComplete还没有被执行到的时候（就是事件还没有注册的时候），那么X线程就不会去同步执行whenComplete的回调了。这个时候哪个线程执行到了whenComplete的事件注册的时候，就由哪个线程本人来同步执行whenComplete的事件内容。
而whenCompleteAsync的场合，就简略很多。一句话就是线程池外面拿一个空的线程或者新启一个线程来执行回调。和执行f.complete的线程以及执行whenCompleteAsync的线程无关。
转载请注明原文链接：关于java:CompletableFuture详解
