Package | Description |
---|---|
alluxio.concurrent.jsr |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
CompletableFuture.acceptEither(CompletionStage<? extends T> other,
java.util.function.Consumer<? super T> action) |
CompletableFuture<Void> |
CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other,
java.util.function.Consumer<? super T> action) |
CompletableFuture<Void> |
CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other,
java.util.function.Consumer<? super T> action,
Executor executor) |
static CompletableFuture<Void> |
CompletableFuture.allOf(CompletableFuture<?>... cfs)
Returns a new CompletableFuture that is completed when all of the given CompletableFutures
complete.
|
static CompletableFuture<Object> |
CompletableFuture.anyOf(CompletableFuture<?>... cfs)
Returns a new CompletableFuture that is completed when any of the given CompletableFutures
complete, with the same result.
|
<U> CompletableFuture<U> |
CompletableFuture.applyToEither(CompletionStage<? extends T> other,
java.util.function.Function<? super T,U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.applyToEitherAsync(CompletionStage<? extends T> other,
java.util.function.Function<? super T,U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.applyToEitherAsync(CompletionStage<? extends T> other,
java.util.function.Function<? super T,U> fn,
Executor executor) |
CompletableFuture<T> |
CompletableFuture.completeAsync(java.util.function.Supplier<? extends T> supplier)
Completes this CompletableFuture with the result of the given Supplier function invoked from an
asynchronous task using the default executor.
|
CompletableFuture<T> |
CompletableFuture.completeAsync(java.util.function.Supplier<? extends T> supplier,
Executor executor)
Completes this CompletableFuture with the result of the given Supplier function invoked from an
asynchronous task using the given executor.
|
static <U> CompletableFuture<U> |
CompletableFuture.completedFuture(U value)
Returns a new CompletableFuture that is already completed with the given value.
|
CompletableFuture<T> |
CompletableFuture.completeOnTimeout(T value,
long timeout,
TimeUnit unit)
Completes this CompletableFuture with the given value if not otherwise completed before the
given timeout.
|
CompletableFuture<T> |
CompletableFuture.copy()
Returns a new CompletableFuture that is completed normally with the same value as this
CompletableFuture when it completes normally.
|
CompletableFuture<T> |
CompletableFuture.exceptionally(java.util.function.Function<Throwable,? extends T> fn)
Returns a new CompletableFuture that is completed when this CompletableFuture completes, with
the result of the given function of the exception triggering this CompletableFuture's
completion when it completes exceptionally; otherwise, if this CompletableFuture completes
normally, then the returned CompletableFuture also completes normally with the same value.
|
static <U> CompletableFuture<U> |
CompletableFuture.failedFuture(Throwable ex)
Returns a new CompletableFuture that is already completed exceptionally with the given
exception.
|
<U> CompletableFuture<U> |
CompletableFuture.handle(java.util.function.BiFunction<? super T,Throwable,? extends U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.handleAsync(java.util.function.BiFunction<? super T,Throwable,? extends U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.handleAsync(java.util.function.BiFunction<? super T,Throwable,? extends U> fn,
Executor executor) |
<U> CompletableFuture<U> |
CompletableFuture.newIncompleteFuture()
Returns a new incomplete CompletableFuture of the type to be returned by a CompletionStage
method.
|
CompletableFuture<T> |
CompletableFuture.orTimeout(long timeout,
TimeUnit unit)
Exceptionally completes this CompletableFuture with a
TimeoutException if not otherwise
completed before the given timeout. |
CompletableFuture<Void> |
CompletableFuture.runAfterBoth(CompletionStage<?> other,
Runnable action) |
CompletableFuture<Void> |
CompletableFuture.runAfterBothAsync(CompletionStage<?> other,
Runnable action) |
CompletableFuture<Void> |
CompletableFuture.runAfterBothAsync(CompletionStage<?> other,
Runnable action,
Executor executor) |
CompletableFuture<Void> |
CompletableFuture.runAfterEither(CompletionStage<?> other,
Runnable action) |
CompletableFuture<Void> |
CompletableFuture.runAfterEitherAsync(CompletionStage<?> other,
Runnable action) |
CompletableFuture<Void> |
CompletableFuture.runAfterEitherAsync(CompletionStage<?> other,
Runnable action,
Executor executor) |
static CompletableFuture<Void> |
CompletableFuture.runAsync(Runnable runnable)
Returns a new CompletableFuture that is asynchronously completed by a task running in the
ForkJoinPool.commonPool() after it runs the given action. |
static CompletableFuture<Void> |
CompletableFuture.runAsync(Runnable runnable,
Executor executor)
Returns a new CompletableFuture that is asynchronously completed by a task running in the given
executor after it runs the given action.
|
static <U> CompletableFuture<U> |
CompletableFuture.supplyAsync(java.util.function.Supplier<U> supplier)
Returns a new CompletableFuture that is asynchronously completed by a task running in the
ForkJoinPool.commonPool() with the value obtained by calling the given Supplier. |
static <U> CompletableFuture<U> |
CompletableFuture.supplyAsync(java.util.function.Supplier<U> supplier,
Executor executor)
Returns a new CompletableFuture that is asynchronously completed by a task running in the given
executor with the value obtained by calling the given Supplier.
|
CompletableFuture<Void> |
CompletableFuture.thenAccept(java.util.function.Consumer<? super T> action) |
CompletableFuture<Void> |
CompletableFuture.thenAcceptAsync(java.util.function.Consumer<? super T> action) |
CompletableFuture<Void> |
CompletableFuture.thenAcceptAsync(java.util.function.Consumer<? super T> action,
Executor executor) |
<U> CompletableFuture<Void> |
CompletableFuture.thenAcceptBoth(CompletionStage<? extends U> other,
java.util.function.BiConsumer<? super T,? super U> action) |
<U> CompletableFuture<Void> |
CompletableFuture.thenAcceptBothAsync(CompletionStage<? extends U> other,
java.util.function.BiConsumer<? super T,? super U> action) |
<U> CompletableFuture<Void> |
CompletableFuture.thenAcceptBothAsync(CompletionStage<? extends U> other,
java.util.function.BiConsumer<? super T,? super U> action,
Executor executor) |
<U> CompletableFuture<U> |
CompletableFuture.thenApply(java.util.function.Function<? super T,? extends U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.thenApplyAsync(java.util.function.Function<? super T,? extends U> fn) |
<U> CompletableFuture<U> |
CompletableFuture.thenApplyAsync(java.util.function.Function<? super T,? extends U> fn,
Executor executor) |
<U,V> CompletableFuture<V> |
CompletableFuture.thenCombine(CompletionStage<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends V> fn) |
<U,V> CompletableFuture<V> |
CompletableFuture.thenCombineAsync(CompletionStage<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends V> fn) |
<U,V> CompletableFuture<V> |
CompletableFuture.thenCombineAsync(CompletionStage<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends V> fn,
Executor executor) |
<U> CompletableFuture<U> |
CompletableFuture.thenCompose(java.util.function.Function<? super T,? extends CompletionStage<U>> fn) |
<U> CompletableFuture<U> |
CompletableFuture.thenComposeAsync(java.util.function.Function<? super T,? extends CompletionStage<U>> fn) |
<U> CompletableFuture<U> |
CompletableFuture.thenComposeAsync(java.util.function.Function<? super T,? extends CompletionStage<U>> fn,
Executor executor) |
CompletableFuture<Void> |
CompletableFuture.thenRun(Runnable action) |
CompletableFuture<Void> |
CompletableFuture.thenRunAsync(Runnable action) |
CompletableFuture<Void> |
CompletableFuture.thenRunAsync(Runnable action,
Executor executor) |
CompletableFuture<T> |
CompletionStage.toCompletableFuture()
Returns a
CompletableFuture maintaining the same completion properties as this stage. |
CompletableFuture<T> |
CompletableFuture.toCompletableFuture()
Returns this CompletableFuture.
|
CompletableFuture<T> |
CompletableFuture.whenComplete(java.util.function.BiConsumer<? super T,? super Throwable> action) |
CompletableFuture<T> |
CompletableFuture.whenCompleteAsync(java.util.function.BiConsumer<? super T,? super Throwable> action) |
CompletableFuture<T> |
CompletableFuture.whenCompleteAsync(java.util.function.BiConsumer<? super T,? super Throwable> action,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<Void> |
CompletableFuture.allOf(CompletableFuture<?>... cfs)
Returns a new CompletableFuture that is completed when all of the given CompletableFutures
complete.
|
static CompletableFuture<Object> |
CompletableFuture.anyOf(CompletableFuture<?>... cfs)
Returns a new CompletableFuture that is completed when any of the given CompletableFutures
complete, with the same result.
|
Copyright © 2023. All Rights Reserved.