1.CompletableFuture的办法简介和应用
2.总结
1.CompletableFuture的办法简介和应用
从下面那篇博客 JAVA并发编程——Future和CompletableFuture的简介与应用 咱们对CompletableFuture有了一个大略的理解和初步的应用，接下来咱们来零碎介绍一下CompletableFuture这个类有哪些办法。
1.0 根底的运行办法
//无返回值,相似Runnable 可抉择传入一个线程池public static CompletableFuture<Void> runAsync(Runnable runnable)public static CompletableFuture<Void> runAsync(Runnable runnable,Executor executor) //有返回值，相似Future 可抉择传入一个线程池public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier)public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier,Executor executor)1.1 取得后果和触发计算的办法
public T get();//始终阻塞获取后果，和Future的get()办法雷同public T get(long timeout, TimeUnit unit);// 在肯定工夫内获取后果，没取得后果就抛异样public T getNow(T valueIfAbsent);//马上获取后果，如果没获取到后果就返回传入参数的默认值。public T join(); //和get()办法雷同，区别是join()不会抛出异样，get()会抛出异样public boolean complete(T value) //在计算未实现的状况下，立即打断get办法立刻返回括号值1.2 对计算结果进行解决的办法
thenApply() //计算结果存在依赖关系，先执行上一步再执行下一步//因为存在依赖关系(以后步错，不走下一步)，以后步骤有异样的话就叫停。public class CompletableFutureDemo2{public static void main(String[] args) throws ExecutionException, InterruptedException{//当一个线程依赖另一个线程时用 thenApply 办法来把这两个线程串行化,CompletableFuture.supplyAsync(() -> {//暂停几秒钟线程try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("111");return 1024; }).thenApply(f -> { System.out.println("222");return f + 1; }).thenApply(f -> {//int age = 10/0; // 异常情况：那步出错就停在那步。System.out.println("333");return f + 1; }).whenCompleteAsync((v,e) -> {//当实现的时候 System.out.println("*****v: "+v); }).exceptionally(e -> {//当产生异样的时候 e.printStackTrace();return null; }); System.out.println("-----主线程完结，END");// 主线程不要立即完结，否则CompletableFuture默认应用的线程池会立即敞开:try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }}}//有异样也能够往下一步走，依据带的异样参数能够进一步解决handle()public class CompletableFutureDemo2{public static void main(String[] args) throws ExecutionException, InterruptedException {//当一个线程依赖另一个线程时用 handle 办法来把这两个线程串行化, // 异常情况：有异样也能够往下一步走，依据带的异样参数能够进一步解决CompletableFuture.supplyAsync(() -> {//暂停几秒钟线程try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("111");return 1024; }).handle((f,e) -> {int age = 10/0; System.out.println("222");return f + 1; }).handle((f,e) -> { System.out.println("333");return f + 1; }).whenCompleteAsync((v,e) -> { System.out.println("*****v: "+v); }).exceptionally(e -> { e.printStackTrace();return null; }); System.out.println("-----主线程完结，END");// 主线程不要立即完结，否则CompletableFuture默认应用的线程池会立即敞开:try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); } }}1.3 对计算结果进行生产的办法
//接管工作的处理结果，并生产解决，无返回后果thenAccept();//工作 A 执行完执行 B，并且 B 不须要 A 的后果thenRun();//工作 A 执行完执行 B，B 须要 A 的后果，然而工作 B 无返回值thenAccept();//工作 A 执行完执行 B，B 须要 A 的后果，同时工作 B 有返回值thenApply();public static void main(String[] args) throws ExecutionException, InterruptedException{ CompletableFuture.supplyAsync(() -> {return 1; }).thenApply(f -> {return f + 2; }).thenApply(f -> {return f + 3; }).thenApply(f -> {return f + 4; }).thenAccept(r -> System.out.println(r));}1.4 对计算速度进行选用的办法
//谁快用谁applyToEither()public class CompletableFutureDemo2{public static void main(String[] args) throws ExecutionException, InterruptedException { CompletableFuture completableFuture1 = CompletableFuture.supplyAsync(() -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");//暂停几秒钟线程try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }return 10; }); CompletableFuture completableFuture2 = CompletableFuture.supplyAsync(() -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }return 20; }); CompletableFuture thenCombineResult = completableFuture1.applyToEither(completableFuture2,f -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");return f + 1; }); System.out.println(Thread.currentThread().getName() + "\t" + thenCombineResult.get()); }}1.5 对计算结果进行合并的办法
//两个CompletionStage工作都实现后，最终能把两个工作的后果一起交给thenCombine 来解决thenCombine()public class CompletableFutureDemo2{public static void main(String[] args) throws ExecutionException, InterruptedException { CompletableFuture completableFuture1 = CompletableFuture.supplyAsync(() -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");return 10; }); CompletableFuture completableFuture2 = CompletableFuture.supplyAsync(() -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");return 20; }); CompletableFuture thenCombineResult = completableFuture1.thenCombine(completableFuture2, (x, y) -> { System.out.println(Thread.currentThread().getName() + "\t" + "---come in ");return x + y; }); System.out.println(thenCombineResult.get()); }}2.总结
这篇博客咱们总结了CompletableFuture的根底办法，咱们还是须要在生产上多加练习，遗记api的时候能够看一下源码或者从新翻阅一下这篇博客。