completable-future

3熱

1答えて

私は、中断された可能性のある状態を維持しながら、切断された結果を持つブロッキングメソッドを処理するさまざまな方法を試してきました。私は、送信と受信を調整するのが難しい異種のクラスやメソッドを扱う必要があることにイライラしていることが分かりました。次の例では、SomeBlockingMethod()は通常、メッセージが別のプロセスに送信されるときにvoidを返します。しかし、代わりに結果を受け取る

4熱

1答えて

なぜCompletableFutureのthenAccept（）がメインスレッドで実行されていない

CompletableFutureのsupplyAsync（）内で長時間実行される操作を処理し、thenAccept（）に結果を取得します。いくつかの時間でthenAccept（）はメインスレッドで実行しますが、それはワーカースレッドで実行しています。しかし、私はthenAccept（）操作をメインスレッドでのみ実行します。これはサンプルコードです。 private void test() {

3熱

2答えて

ブロックしないでCompletableFutureを開始するにはどうしたらいいですか？

CompletableFuture APIはかなり威圧的です。たくさんのことが受け入れられています。さまざまなオプションがなぜ存在するのかを知ることは難しいです。 CompletableFuture<?> future = CompletableFuture.supplyAsync(() ->..., executor) future.startNonBlocking...((...) ->

-3熱

2答えて

CompletableFutureに時間がかかります - Java 8

技術的には同じコードスニペットを2つ持っていますが、2つ目は1秒後に最初のスニペットをとります。最初のものは、（上記のいずれか6Sを取り、次に第二のコードが一貫1S以上を要する理由7S Here is the link to code CompletableFuture<Double> earlyEarningsInHomeCountryCF = currencyConvCF.thenApplyA

4熱

1答えて

javaマルチネストされたCompletionStageは、 "flatMap"と同等ですか？

は、だから私は、次の例を持って考える： CompletionStage<String> tokenFuture = getToken(); CompletionStage<CompletionStage<CompletionStage<CompletionStage<Boolean>>>> result = tokenFuture.thenApply(token -> { WSRe

8熱

1答えて

JavaEEアプリケーションサーバーのCompletableFuture/parallelStream

新しいJava8が用意されているので、私たちは非同期タスクのための素晴らしい機能を得ています。 CompletableFutureおよび.paralellStream（）です。これをJava SEで実行するとわかりますが、ForkJoinPoolを利用しますが、たとえば次の例を実行するとどうなりますか？ワイルドフライやTomcatEE？ //Here I start a comp.Future w

11熱

2答えて

条件が成立した場合にのみ、いくつかのCompletionStageを連結する

私は連鎖したいいくつかの方法を持っています：CompletionStage問題は、最初のものの結果が次のものが実行されるべきかどうかを判断することです。現在、これを達成する唯一の方法は、特別な引数を次のCompletionStageに渡しているように見えるので、完全なコードは実行されません。たとえば：コード全体以来 public enum SomeResult { RESULT_1,

1熱

1答えて

runAsync呼び出しの後に連鎖すると、thenRunAsync（thenRunとは対照的に）で違いがありますか？

次のコードでは、を呼び出してから、RunAsyncを呼び出すのに違いはありますか？ちょうどに電話して、代わりにに電話する必要がありますか？ CompletableFuture.runAsync(this::doWork , executorService) .thenRunAsync(this::handleSuccess); のコメントに反応してエラボ：私は、代わりにこのコードを使

5熱

2答えて

Javaでは、CompletableFuturesをどのように処理して、完了した最初の望ましい結果が得られますか？

通常、CompletableFutureを使用すると、結果が利用可能になるとすぐに、thenApplyまたは他のメソッドを呼び出して何かを実行します。しかし、今私は肯定的な結果を得てからすべての結果を無視するまで結果を処理したいという状況があります。私は、CompletableFuture.anyOfを使うことができました（リストを配列に変換してanyOfを呼び出す必要はありません）。しかし、そ

20熱

1答えて

コレクションまたはリストを含むJava 8 CompletableFuture.allOf（...）

Java 8には、CompletableFuture.allOf(CompletableFuture<?>...cfs)という関数があり、与えられたすべての未完了が完了したときに完了するCompletableFutureを返します。しかし、私はほとんど常にCompletableFutureの配列を扱っていませんが、代わりにList<CompletableFuture>を持っています。もちろん、私