您现在的位置是：首页 > 其他

当前栏目

Java 8：CompletableFuture

依赖线程执行异步

2023-03-02 11:01:55 时间

1.  解决 `Future`无法描述`多个Future`结果间的`依赖性`的问题
    
    1.  一个大任务中，多个小任务是相互依赖的，没有组合各个小任务的结果，没法得到大任务。
    2.  两个任务之间存在 `顺序`，产生依赖
2.  功能
    
    1.  流式处理 - CompletionStage 中提供大量接口供流式调用
    2.  提供解决`异步执行任务的静态方法` （4个）
        
        1.  无返回值静态方法（2个），有返回值静态方法（2个），在方法中可设置 `线程池`
            
            1.  异步执行线程，默认线程在`ForkJoinPool.commonPool()`系统级公共线程池中，可设置。
        2.  调用 `CompletableFuture.get()方法`，获取异步任务的结果。（运行速度快可以获得，否则阻塞）
        3.  出现 `异常`怎么处理?
    3.  提供`异常处理`
        
        1.  利用函数式风格，提供 `exceptionally()` 处理异常
    4.  组合任务
        
        1.  一个 CompletableFuture 可以在执行完成后，将执行结果通过 Function 传递给下一个 CompletionStage 进行处理。
        2.  方法 thenCombime() 首先完成当前 CompletableFuture 和 other 的执行。接着，将这两者的执行结果传递给 BiFunction（该接口接收两个参数，并有一个返回值），并返回代表 BiFunction 实例的 CompletableFuture 对象：
        
            // 依赖前一组任务的结果 public <U> CompletableFuture<U> thenCompose(Function<? super T, ? extends CompletionStage<U>> fn) // 组合结果 public <U,V> CompletableFuture<U> thenCombime ( CompletionStage<? extends U> other, BiFunction<? super T, ? super U,? extends V> fn)
    5.  end
3.  end

参考来源 ： [Java8 CompletableFuture][]

[Java8 CompletableFuture]: https://blog.csdn.net/sunhaoning/article/details/68163450

猜你喜欢

最长无重复子串
写技术博客的一些心得分享
Java 多线程（七）：线程池
Java 多线程（五）：锁（三）
Java 多线程（四）：锁（二）
Java 多线程（三）：锁（一）
Java 多线程（二）：并发编程的三大特性
线性时间非比较类排序
Java 多线程（一）：基础
合并k个已排序的链表
HDFS 高可用分布式环境搭建
合并两个有序数组
连续子数组的最大和
HDFS 分布式环境搭建
容器盛水问题
大数加法
HDFS 伪分布式环境搭建
设计LRU缓存结构
两数之和
使用单调栈来解决的一些问题

zl程序教程

当前栏目

Java 8：CompletableFuture

相关文章