一文掌握并发编程工具CompletableFuture

为什么需要CompletableFuture？

Future是Java5添加的类，用来描述一个异步计算的结果。主动调用isDone获取计算是否结束，get阻塞获取计算结果，cancel主动停止任务。
但是，这些方法不足之处在于，想要获取结果，我们只能通过轮询或者阻塞的方式。有没有一种方式，通过观察者模式当计算结果完成后及时通知监听者呢？
CompletableFuture登场了，包含50多个方法，帮助我们实现Future的各种编排。

创建CompletableFuture

public static CompletableFuture 	runAsync(Runnable runnable)
public static CompletableFuture 	runAsync(Runnable runnable, Executor executor)
public static  CompletableFuture 	supplyAsync(Supplier supplier)
public static  CompletableFuture 	supplyAsync(Supplier supplier, Executor executor)

runAsync 看参数即可知道，这是没有返回值的任务
supplyAsync 消费者lamda函数，泛型U即为返回值，
如果不指定executor，默认使用ForkJoinPool.commonPool()作为线程池，一般我们都使用自己定义的线程池

示例

 CompletableFuture.supplyAsync(() -> newQuery().select(fields)
                        .eq(isNotEmpty(logicDelete), "isDrop", logicDelete)
                        .in(idName, idList)
                        .getBeanList()
                , executor)

Future完成的回调

完成时回调，返回原对象

public CompletableFuture 	whenComplete(BiConsumer action)
public CompletableFuture 	whenCompleteAsync(BiConsumer action)
public CompletableFuture 	whenCompleteAsync(BiConsumer action, Executor executor)
public CompletableFuture     exceptionally(Function fn)

BiConsumer fn 传入 T 、异常E，相当于做出对象消费

任务完成后回调action，返回的也是CompletableFuture
无Async结尾用本线程同步执行
有Async结尾代表交给线程池异步执行，如果不指定executor，默认使用ForkJoinPool.commonPool()作为线程池
exceptionally方法返回一个新的CompletableFuture，当原始的CompletableFuture抛出异常的时候，就会触发这个CompletableFuture的计算，调用function计算值，否则如果原始的CompletableFuture正常计算完后，这个新的CompletableFuture也计算完成，它的值和原始的CompletableFuture的计算的值相同。也就是这个
exceptionally方法用来处理异常的情况

CompletableFuture.supplyAsync().whenComplete((t,e)-> {
            System.out.println("执行完成" + t);
 })

完成时回调，返回转换后对象

public  CompletableFuture 	thenApply(Function fn)
public  CompletableFuture 	thenApplyAsync(Function fn)
public  CompletableFuture 	thenApplyAsync(Function fn, Executor executor)

三个方法区别和上面一样就不赘述了
Function fn 传入 T 返回 U ，相当于做出对象的转换

示例

CompletableFuture future = CompletableFuture.supplyAsync(() -> {    return 100;});
CompletableFuture f =  future.thenApplyAsync(i -> i * 10).thenApply(i -> i.toString()); 
// 其实没必要这样写呀
CompletableFuture future = CompletableFuture.supplyAsync(() -> {    return (100*10) + "";});

无异常消费型

public CompletableFuture 	thenAccept(Consumer action)
public CompletableFuture 	thenAcceptAsync(Consumer action)
public CompletableFuture 	thenAcceptAsync(Consumer action, Executor executor)

三个方法区别和上面一样就不赘述了
Consumer fn 消费生成的T 无返回

组合多个CompletableFuture

public static CompletableFuture 	    allOf(CompletableFuture... cfs)
public static CompletableFuture

一文掌握并发编程工具CompletableFuture

Java相关栏目本月热门文章