CompletableFuture API 改进
Java 8 中引入了 CompletableFuture 类来表示可以通过显式设置其值和状态来完成的 Future。它可以用作 java.util.concurrent.CompletionStage。它支持在未来完成时触发的相关功能和操作。在 java 9 CompletableFuture API 中得到了进一步的增强。以下是对 API 所做的相关更改。
- 支持延迟和超时。
- 改进了对子类化的支持。
- 添加了新的工厂方法。
支持延迟和超时
public CompletableFuture<T> completeOnTimeout(T value, long timeout, TimeUnit unit)
如果在给定超时之前未完成,则此方法使用给定值完成此 CompletableFuture。
public CompletableFuture<T> orTimeout(long timeout, TimeUnit unit)
如果在给定超时之前没有以其他方式完成,则此方法异常完成此 CompletableFuture 并带有 TimeoutException。
改进了对子类化的支持
public Executor defaultExecutor()
它返回用于未指定 Executor 的异步方法的默认 Executor。该方法可以在子类中重写,返回一个Executor,提供一个独立的线程,最少。
public <U> CompletableFuture<U> newIncompleteFuture()
返回要由 CompletionStage 方法返回的类型的新的不完整 CompletableFuture。 CompletableFuture 类的子类应重写此方法以返回与此 CompletableFuture 相同的类的实例。默认实现返回 CompletableFuture 类的实例。
新工厂方法
public static <U> CompletableFuture<U> completedFuture(U value)
这个工厂方法返回一个新的 CompletableFuture,它已经用给定的值完成。
public static <U> CompletionStage<U> completedStage(U value)
这个工厂方法返回一个新的 CompletionStage,它已经用给定的值完成,并且只支持接口 CompletionStage 中存在的那些方法。
public static <U> CompletionStage<U> failedStage(Throwable ex)
这个工厂方法返回一个新的 CompletionStage,它已经在给定的异常下异常完成,并且只支持接口 CompletionStage 中存在的那些方法。
java