completable-future

1熱

1答えて

私はCompletableFutureチェーンで遊んでいて、予期せぬ動作（私にとっては少なくとも）の状況に遭遇しました：例外的なCompletableFutureが.thenCompose()呼び出しで渡された場合、結果のCompletableFutureは元の例外がラップされて終了しますCompletionExceptionにあります。たとえばなしで理解するのは難しいかもしれ：もちろん publ

2熱

1答えて

Java CompletableFuture.complete（）ブロック

JavaでCompletableFutureを使用すると問題が発生します。私は2つの選択要求を持っています。それらはサーバーからの応答を受け取るときに満たされます。接続スレッド（スレッド1）（使用リアクター）において、Iは、使用： if(hasException) { selectFuture.completeExceptionally(new ClientException(err

0熱

1答えて

CompletableFutureは、Webサービスの呼び出しを行い、すべてが完了したら保存します。

各セッションでプロパティを設定するためにWebサービスを呼び出す必要があるセッションのリストがあります。私はasyncプロセスを使用してwebserviceを呼び出し、そのためにcompletablefutureを使用しようとしています。すべて完了したら、それらをすべてdbに保存できます。どうすればいいですか？これまでのところ、私のコードは次のとおりですが、動作しません。 sessions.s

2熱

2答えて

Java 8でthenComposeの結果を複数回使用するにはどうすればよいですか？

私は myObject.updateDB(payload) .thenCompose(__ -> getUserID(payload.ID())) .thenCompose(id -> getProfile(id)) .thenCompose(userProfile -> updateSomething(userProfile)) .thenComp

0熱

1答えて

複数のthenApply in completableFuture

私は別のスレッドでいくつかのメソッドを実行したいが、あるスレッドの結果を別のスレッドに渡したいという状況があります。クラスには以下のメソッドがあります。私は印刷結果に乗算する減算に加えて結果を渡すためにしようとしています public static void main(String[] args) { int a = 10; int b = 5; Completabl

1熱

1答えて

は何Scalaの今後の救助のJavaのCompletableFuture相当であり、

を扱う私はさんFutureCompletableFutureはスカラ座のそれと同じである方法handleを持っていることがわかりhandleは基本的にmapとflatMap上流にあることを成功にすべて成功し、例外を変換する（またはjavaの世界でthenApplyとthenCompose）。 twitter future rescue（またはscala future recoverWith）と同等

4熱

1答えて

CompletableFuture :: runAsyncについて

私はちょうどthe documentation約CompletableFuture::runAsyncを読んで、説明でかなり混乱しました。ここではそこに書かれているものです：それが特定のアクションを実行した後、非同期に与えられたエグゼキュータで実行中のタスクによって完成された新しい CompletableFutureを返し。それはコールバックのいくつかの並べ替えを「登録」し、特定のアクション

3熱

1答えて

CompletableFuture、thenComposeメソッド

the contractについての誤解があります。thenCompose(Function<? super T,? extends CompletionStage<U>> fn)です。ここにあると言われるものです：この段階は通常を完了し、新しい CompletionStageを返し、供給関数の引数として、この段階で実行されます。 CompletionStageの結果は受け入れるようですが、

3熱

2答えて

ExecutorServiceを使用して結果が到着するまでポーリングする方法

タスクが完了したかどうかをリモートサーバーにポーリングする必要があるシナリオがあります。それができたら、結果を取得するために別の呼び出しを行います。私はもともと私はポーリングのためscheduleWithFixedDelayでSingleThreadScheduledExecutorを使用する必要があります考え出し： ScheduledExecutorService executor = Exe

5熱

1答えて

CompletableFuture＃thenApplyが使用されている場合は、whenCompleteは呼び出されません。

ScheduledExecutorService#scheduleAtFixedRateを使用して、リモートサーバー上でタスクをスケジュールし、完了をポーリングする次のコードがあります（my previous questionの結果）。タスクが完了すると、結果がダウンロードされます。呼び出し元にFutureを返信して、ブロックする時期と時間を決定し、タスクをキャンセルするオプションを与えることが