completable-future

-1熱度

1回答

錯誤說「CompletableFuture（對象）在CompletableFuture私有訪問」實施CompletableFuture

當我如下實施CompletableFuture但得到一個錯誤說 CompletableFuture(Object)在CompletableFuture public CompletableFuture<A> init(B b) { C c = new C(); CompletableFuture<A> future = new CompletableFuture<A>(c);

1熱度

1回答

Java 8 CompletableFuture.thenApply（）

最後在Java 8中使用CompletableFuture dealio。我得到一個我不太瞭解的編譯錯誤（在我的IDE中）。我已經得到了我想要追加到一個URL，然後異步調用每個URL標識的List<String>。到目前爲止，我只有這幾種方法。 private void process(List<String> identifiers) { List<CompletableFutur

20熱度

1回答

Java 8 CompletableFuture.allOf（...）帶收集或列表

Java 8的函數CompletableFuture.allOf(CompletableFuture<?>...cfs)返回CompletableFuture，該函數在所有給定期貨完成時完成。但是，我幾乎總是不處理CompletableFuture s的數組，而是有一個List<CompletableFuture>。當然，我可以使用toArray()方法，但是最後不得不在陣列和列表之間來回轉換，

0熱度

1回答

我應該把@Async上的每個服務方法，使我的應用程序完全支持異步的春天？

我有一個非常簡單的控制器是這樣的： @RequestMapping(value = "food", method = RequestMethod.POST) public ResponseEntity<?> getAll(@RequestParam("term") String term) { List<Food> foods = foodService.findByNam

1熱度

1回答

使用ExecutorService的Java應用程序永遠不會關閉

我正在嘗試編寫一個程序，它將在多個Java工作線程中劃分工作。問題是，當我從命令行運行它時，它永遠不會返回。我沒有得到我的提示，最終必須按ctrl-c關閉程序。我它簡化爲以下瑣碎的情況下 import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.con

0熱度

1回答

Spring異步 - CompletableFuture與超時完成後處理程序

我有一個場景，我從我的REST API使用Spring異步調用外部Web服務。它返回一個CompletableFuture，很顯然我們可以等待一段時間，直到外部異步操作完成。當超時發生時，主線程返回狀態202。我想處理異步過程完成時，以便我需要更新數據庫中的字段。我們從哪裏得到這個處理程序，或者我該如何實現？因爲主線程已經返回。以前發表過一個問題。 Implement Async pr

8熱度

1回答

JavaEE應用服務器中的CompletableFuture/parallelStream

鑑於新的Java8，我們正在爲異步任務獲得非常好的功能，例如， CompletableFuture和.paralellStream（）。如果你在Java SE中運行它，就像我已經理解的那樣，你將使用ForkJoinPool，但是如果我在例如蜻蜓或TomcatEE？ //Here I start a comp.Future without giving an Executor test = Com

11熱度

2回答

僅在達到條件時鏈接幾個CompletionStage

我有幾個我想鏈接的CompletionStage方法。問題是第一個的結果將決定是否應該執行下一個。目前實現這一目標的唯一方法似乎是將「特殊」參數傳遞給下一個CompletionStage，因此它不會執行完整的代碼。例如： public enum SomeResult { RESULT_1, RESULT_2, RESULT_3 } public Completi

1熱度

1回答

如果在runAsync調用之後進行鏈接，那麼thenRunAsync（與thenRun相反）會有什麼區別？

在下面的代碼中，調用然後RunAsync有什麼區別嗎？我應該撥打，然後運行而不是？ CompletableFuture.runAsync(this::doWork , executorService) .thenRunAsync(this::handleSuccess); 闡述在迴應評論：如果我不是使用此代碼， CompletableFuture.runAsync(this::doW

-1熱度

1回答

如何處理兩個CompletionStages的最多一個例外

我有兩個CompletionStage s。如果其中一個失敗，我想執行一些操作，onException。如果兩者均失敗，我想執行onException，但只能執行一次。