CompletableFuture的使用
2020-11-23 11:12:56 28 举报AI智能生成
登录查看完整内容
CompletableFuture 的使用
作者其他创作
大纲/内容
CompletableFuture
说明
是一个具体的类。实现了接口 Future 和 CompletionStage。不像FutureTask实现了Runnable接口，所以需要传入任务才可以执行
因为实现了Future接口，所以get() 等阻塞方法还可以使用
建议使用异步方法
构造方法
传入静态值
用来返回一个已经计算好的CompltableFuture
public static <U> CompletableFuture<U> completedFuture(U value)
传入异步执行代码
注意
以Async结尾并且没有指定Executor的方法会使用ForkJoinPool.commonPool()作为它的线程池执行异步代码。
runAsync方法也好理解，它以Runnable函数式接口类型为参数，所以CompletableFuture的计算结果为空。
阻塞获取结果
转换
任务计算完成后，可以传给接下来的任务，返回最后任务的执行结果
方法
使用
消费
纯消费
组合另一个CompletionStage，纯消费
忽略任务的结果
组合
并行执行
返回新的CompletableFuture
Either
acceptEither
当任意一个CompletionStage完成的时候，action这个消费者就会被执行。这个方法返回CompletableFuture<Void>
applyToEither
当任意一个CompletionStage完成的时候，fn会被执行，它的返回值会当作新的CompletableFuture<U>的计算结果。
辅助方法
allOf
allOf方法是当所有的CompletableFuture都执行完后执行计算。
public static CompletableFuture<Void> \t allOf(CompletableFuture<?>... cfs)
anyOf
anyOf方法是当任意一个CompletableFuture执行完后就会执行计算，计算的结果相同。
public static CompletableFuture<Object> \tanyOf(CompletableFuture<?>... cfs)
0 条评论
回复 删除
下一页
