CompletableFuture实现原理分析

落日映苍穹つ 2024-05-23 22:11 62阅读 0赞

![format_png][]

## 简介 ##

介绍了CompletableFuture的特性以及一些使用方法，今天我们主要来聊一聊CompletableFuture的回调功能以及异步工作原理是如何实现的。

## CompletableFuture类结构 ##

1.CompletableFuture类结构主要有两个属性

public class CompletableFuture<T> implements Future<T>, CompletionStage<T> {
        volatile Object result;       // Either the result or boxed AltResult
        volatile Completion stack;    // Top of Treiber stack of dependent actions
        ...
    }
    复制代码

*  **result**：存储CompletableFuture的返回，或者存储异常对象AltResult。
 *  **stack**：是CompletableFuture.Completion对象，表示操作数栈栈顶，在进行CompletableFuture链式调用的过程中，所有链式调用的CompletableFuture任务都会被压入该stack中，在任务调用的过程按**后进先出**的顺序出栈执行完所有任务。

2.stack属性栈结构

abstract static class Completion extends ForkJoinTask<Void>
        implements Runnable, AsynchronousCompletionTask {
        volatile Completion next;      // Treiber stack link
        ...
    }
    复制代码

*  **next**：存储下一个任务链式调用栈。

3.UniCompletion的内部结构

abstract static class UniCompletion<T,V> extends Completion {
        Executor executor;                 // executor to use (null if none)
        CompletableFuture<V> dep;          // the dependent to complete
        CompletableFuture<T> src;          // source for action
        ...
    }
    复制代码

UniCompletion继承Completion类，包含以下几个参数：

*  **executo**

[format_png]: https://img-blog.csdnimg.cn/img_convert/6168c240725b61696b2f8c311027a7d8.webp?x-oss-process=image/format,png