增强的Future
使用CompletableFuture，实现Future功能可以实现手动设置CompletableFuture的完成状态
package cn.edu.jxnu.lambda;import java.util.concurrent.CompletableFuture;/*** Copyright ? 2018 梦境迷离. All rights reserved.* * @description:* @Package: cn.edu.jxnu.lambda* @author: 梦境迷离* @date: 2018年3月27日 上午10:03:02*/public class CompletableFutureDemo {public static void main(String[] args) throws InterruptedException {final CompletableFuture<Integer> future = new CompletableFuture<>();new Thread(new AskThread(future)).start();// 模拟长时间计算过程Thread.sleep(1000);// 告知完成结果，载入数据future.complete(60);// 继续进行计算平方并打印出3600}/*** CompletableFuture 实现了Future接口和CompletionStage接口* CompletionStage接口拥有很多方法，为了流式调用 形如* stage.thenApply(x->square(x)).thenAccept(x->System.out::println(x)).thenRun(()->System.out.println())*/// 计算re表示的数字的平方，将其打印static class AskThread implements Runnable {CompletableFuture<Integer> re = null;public AskThread(CompletableFuture<Integer> re) {this.re = re;}@Overridepublic void run() {int myRe = 0;try {// 没有传入int数字之前会阻塞myRe = re.get() * re.get();} catch (Exception e) {}System.out.println(myRe);}}
}流式调用，异常
package cn.edu.jxnu.lambda;import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;/*** Copyright ? 2018 梦境迷离. All rights reserved.* * @description:CompletableFuture的流式调用，异常，异步* @Package: cn.edu.jxnu.lambda* @author: 梦境迷离* @date: 2018年3月27日 上午11:06:30*/public class CompletableFutureDemo2 {public static void main(String[] args) throws InterruptedException, ExecutionException {// 1、supplyAsync方法构造一个CompletableFuture实例// 2、supplyAsync在一个新的线程中执行传入的参数// 3、calu方法可能执行的很慢，但是不会影响CompletableFuture实例的构造速度，因此supplyAsync是立即返回的// 4、计算没有完成则get方法会等待final CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> calu(50));System.out.println(future.get());// CompletableFuture的工厂方法，supplyAsync用于需要返回值的场景，runAsync应用于没有返回值的场景// 都有一个方法可以接受Executor参数的方法，可以指定在自己的线程池中工作，如果不指定，则使用系统的ForkJoinPool.common线程池// ForkJoinPool.commonPool()// Java8新增，获取一公共的ForkJoin线程池，都是Daemon线程，这意味的如果主线程退出，无论这些线程池的任务是否执行完成，都会退出系统System.out.println("*********************流式调用****************");// 计算50*50，得到结果并将2500转化为字符串，再拼接两个引号，再打印该字符串CompletableFuture<Void> future2 = CompletableFuture.supplyAsync(() -> calu(50)).thenApply(i -> Integer.toString(i)).thenApply(str -> "\"" + str + "\"").thenAccept(System.out::println);// 必须调用，否则主线程退出，所有的Daemon的线程都会退出，calu无法正常完成future2.get();System.out.println("*********************CompletableFuture异常处理****************");CompletableFuture<Void> future3 = CompletableFuture.supplyAsync(() -> caluError(50)).exceptionally(ex -> {// 打印异常信息，返回一个默认值0System.out.println(ex.toString());return 0;}).thenApply(i -> Integer.toString(i)).thenApply(str -> "\"" + str + "\"").thenAccept(System.out::println);future3.get();}/*** @description:不需要自动定义线程，只需要包装一个任务*/public static int calu(Integer param) {try {Thread.sleep(1000);} catch (Exception e) {}return param * param;}/*** 处理异常*/public static Integer caluError(Integer param) {return param / 0;}
}
组合多个CompletableFuture
package cn.edu.jxnu.lambda;import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;/*** Copyright ? 2018 梦境迷离. All rights reserved.* * @description:组合多个CompletableFuture* @Package: cn.edu.jxnu.lambda* @author: 梦境迷离* @date: 2018年3月27日 上午11:31:34*/public class CompletableFutureDemo3 {public static void main(String[] args) throws InterruptedException, ExecutionException {System.out.println("*****************方法一*******************");// 1、使用thenCompose()方法// 2、将第一个CompletableFuture的计算结果传递给第二个CompletableFuture，继续进行计算CompletableFuture<Void> fu = CompletableFuture.supplyAsync(() -> calu(50)).thenCompose(i -> CompletableFuture.supplyAsync(() -> calu(i))).thenApply(i -> Integer.toString(i)).thenApply(str -> "\"" + str + "\"").thenAccept(System.out::println);fu.get();System.out.println("*****************方法二*******************");// 1、使用thenCombine()方法CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> calu(50));CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> calu(25));// 将future1与future2的计算结果相加CompletableFuture<Void> fu2 = future1.thenCombine(future2, (i, j) -> (i + j)).thenApply(str -> "\"" + str + "\"").thenAccept(System.out::println);fu2.get();}public static Integer calu(Integer param) {return param / 2;}}