类 CompletableToListenableFutureAdapter<T>
- java.lang.Object
- org.springframework.util.concurrent.CompletableToListenableFutureAdapter<T>
- 所有已实现的接口:
Future<T>
,ListenableFuture<T>
@UsesJava8 public class CompletableToListenableFutureAdapter<T> extends Object implements ListenableFuture<T>
- 从以下版本开始:
- 4.2
- 作者:
- Sebastien Deleuze, Juergen Hoeller
构造器概要
构造器 构造器 说明 CompletableToListenableFutureAdapter(CompletableFuture<T> completableFuture)
Create a new adapter for the givenCompletableFuture
.CompletableToListenableFutureAdapter(CompletionStage<T> completionStage)
Create a new adapter for the givenCompletionStage
.
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 void
addCallback(ListenableFutureCallback<? super T> callback)
Register the givenListenableFutureCallback
.void
addCallback(SuccessCallback<? super T> successCallback, FailureCallback failureCallback)
Java 8 lambda-friendly alternative with success and failure callbacks.boolean
cancel(boolean mayInterruptIfRunning)
T
get()
T
get(long timeout, TimeUnit unit)
boolean
isCancelled()
boolean
isDone()
构造器详细资料
CompletableToListenableFutureAdapter
public CompletableToListenableFutureAdapter(CompletionStage<T> completionStage)
Create a new adapter for the givenCompletionStage
.- 从以下版本开始:
- 4.3.7
CompletableToListenableFutureAdapter
public CompletableToListenableFutureAdapter(CompletableFuture<T> completableFuture)
Create a new adapter for the givenCompletableFuture
.
方法详细资料
addCallback
public void addCallback(ListenableFutureCallback<? super T> callback)
从接口复制的说明:ListenableFuture
Register the givenListenableFutureCallback
.- 指定者:
addCallback
在接口中ListenableFuture<T>
- 参数:
callback
- the callback to register
addCallback
public void addCallback(SuccessCallback<? super T> successCallback, FailureCallback failureCallback)
从接口复制的说明:ListenableFuture
Java 8 lambda-friendly alternative with success and failure callbacks.- 指定者:
addCallback
在接口中ListenableFuture<T>
- 参数:
successCallback
- the success callbackfailureCallback
- the failure callback
isCancelled
public boolean isCancelled()
- 指定者:
isCancelled
在接口中Future<T>
get
public T get() throws InterruptedException, ExecutionException
- 指定者:
get
在接口中Future<T>
- 抛出:
InterruptedException
ExecutionException
get
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException