completable-future

3熱

1答えて

私はメモリリークをデバッグしていて、CompletableFuture内部に潜入しなければなりませんでした。 CompletableFuture<V> g = f.apply(t).toCompletableFuture(); ... CompletableFuture<V> d = new CompletableFuture<V>(); UniRelay<V> copy = new Uni

0熱

1答えて

Java 8での非同期のfire-and-forgetメソッドのテスト

Java 8のFire-and-forget完了ステージメソッドを含むメソッドを含む統合テストを作成しようとしています。次 public CompletionStage<User> createAndStoreUser() { return createUser() .thenApply(this::store) .thenApply(user -> {

0熱

1答えて

内部CompletableFutureを使ったメソッドのユニットテスト

非同期呼び出しでconnector.runSomeService(data)を呼び出し、メソッドhandleServiceResponse(res, node)で応答を処理するメソッドがあります。 public void runServiceOnAllNodes(Collection<Node> nodes, Object data) { nodes.parallelStream().f

2熱

1答えて

リストからすべての結果を開き、CompletableFutureでスレッドに集めるには？

私は文字列のリストを持っており、それぞれについて新しいスレッドを開き、すべての情報をCompletableFutureに集める必要があります。これは私の繰り返しです： for (String result: results) { candidateInfos.add(getCandidatesInfo(result)); } 私が初めてスレッドの実装をしようとしていますし、私はい

1熱

1答えて

@AsyncでCompletableFutureを使用すると、スプリングブートAPIの空の応答が返されます。

ここは私のコントローラです。私はそれが働いているかどうかテストするために郵便配達員を使いましたが、私は空の応答を得ています。私はアプリケーション構成で@EnableAsync、サービスでは@Asyncを使用しました。サービスレイヤで@Asyncを削除すると動作しますが、非同期には実行されません。 @ApiOperation(value = "search person by passing sea

0熱

2答えて

CompletableFutureでWebサービスリクエストを並列化する方法は？

私は基本的に入力日付で与えられたデータを要求するサーブレット要求を持っています。複数の日付があるので、複数のリクエストを送信し、結果を集計する必要があります。例： List<Result> results = new ArrayList<>(); for (LocalDate date : dates) { ServletReq req = new ServletReq(date);

0熱

1答えて

Completablefuture - ラプダブロックを使用したthenapplyとの比較の利点

ラムダブロックを使用する利点を知りたい場合は、thenApply()を使用します。 supplyAsync()で関数を実行している同じスレッドがラムダブロックを常に実行するのに対して、thenApply()ブロックはsupplyAsync()を実行しているスレッドまたは呼び出し元スレッドで実行できることを理解します。 thenApply()は、supplyAsync()関数が実行された後に実行する

3熱

2答えて

CompletableFuture :: joinを中断するには？完了していないとき、私はCompletableFutureが::参加していることがわかりました

無停電ようだ：上記の実装では // CompletableFuture::join implementation from JDK 8 sources public T join() { Object r; return reportJoin((r = result) == null ? waitingGet(false) : r); } 、waitingGet(fal

1熱

1答えて

これらの2つのCompletableFuturesから同じ結果が得られることを期待してください

しかし、testCase2は例外を処理せず、エラーをスローします。何か不足していますか？申し訳ありません、私がした場合、これは全く新しいです。 @Test public void testCase1() throws Exception { CompletableFuture.supplyAsync(() -> { if (true) throw new RuntimeEx

0熱

1答えて

Springを待つListenableFuture

休憩の呼び出しにSpring AsyncRestTemplateを使用するサービスがあります。 AsyncRestTemplate.exchange()の各コールはListenableFutureを返します。このような何か： ListenableFuture future1 = new AsyncRestTemplate().exchange(...); ListenableFuture