20230618 java.util.concurrent.CompletionStage-526互联

介绍

注意事项：

thenApply , thenApplyAsync
-  CompletionStage thenApply(Function<? super T,? extends U> fn);
-  CompletionStage thenApplyAsync (Function<? super T,? extends U> fn);
 - 异步执行，使用 ForkJoinPool.commonPool() 线程池
-  CompletionStage thenApplyAsync (Function<? super T,? extends U> fn, Executor executor);
 - 异步执行，指定线程池
thenAccept
- CompletionStage<Void> thenAccept(Consumer<? super T> action);
thenRun
- CompletionStage<Void> thenRun(Runnable action);
thenCompose
- CompletionStage thenCompose (Function<? super T, ? extends CompletionStage> fn);

handle
-  CompletionStage handle (BiFunction<? super T, Throwable, ? extends U> fn);
- 处理结果或异常
- fn 的两个入参是自身执行的结果和异常
- 抛出异常时，fn 的异常入参有值，否则为 null
whenComplete
- 同上
exceptionally
- 从异常计算一个结果
exceptionallyCompose
- 对异常调用函数并执行返回的 future

thenCombine
- <U,V> CompletionStage<V> thenCombine (CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn);
- 执行两个动作并用给定函数组合结果
- 将自身和入参中的两个 CompletionStage 分别执行，两个结果传入 fn 执行
- 有返回值
thenAcceptBoth
-  CompletionStage<Void> thenAcceptBoth (CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action);
- 同 thenCombine
- 无返回值
runAfterBoth
- CompletionStage<Void> runAfterBoth(CompletionStage<?> other, Runnable action);
- 两个动作都完成后执行 Runnable
applyToEither
-  CompletionStage applyToEither (CompletionStage<? extends T> other, Function<? super T, U> fn);
- 得到其中一个动作的结果时，传入给定的函数
acceptEither
- CompletionStage<Void> acceptEither (CompletionStage<? extends T> other, Consumer<? super T> action);
- 同 applyToEither
runAfterEither
- CompletionStage<Void> runAfterEither(CompletionStage<?> other, Runnable action);