completable-future

1熱度

1回答

CompletionStage.thenCompose沒有連續執行

我想使用java 8 CompletionStages連續執行2個異步方法，以便第二個在第一個失敗時不會執行。但是，當我打電話thenCompose，傳遞的功能似乎開始之前，前一個功能齊全（如：兩個功能並行錯誤地執行以下是代碼： public CompletionStage<Graph> create(Payload payload) { CompletionStage<BlobInfo

java java-8 completable-future 2017-09-20

---

1熱度

1回答

模擬CompletionException在測試

我有一個類HttpClient有一個返回CompletableFuture功能： public class HttpClient { public static CompletableFuture<int> getSize() { CompletableFuture<int> future = ClientHelper.getResults() .thenA

java exception mockito completable-future 2017-08-13

---

-3熱度

2回答

如何在循環中調用可完成的未來併合並所有結果？

我正試圖實現這樣的事情。這是一個表達意圖的例子。 我希望所有完整的期貨能夠執行並將所有結果合併到一個結果並返回。因此，對於下面的示例，集合allResults應該包含字符串「one」，「two」，「three」，每個3次。我希望他們都能並行運行而不是連續運行。 任何指向我可以用來實現這一目標的可補充未來的API的指針都是非常有用的。 public class Main { publi

java completable-future 2017-10-05

---

3熱度

2回答

然後應用程序和Java CompletableFuture的應用程序同步有什麼區別？

假設我有以下代碼： CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> 0); thenApply情況： future.thenApply(x -> x + 1) .thenApply(x -> x + 1) .thenAccept(x -> System.out.p

java completable-future 2017-11-25

---

4熱度

2回答

什麼是正確的方式來創建一個已完成CompletableFuture <Void>

我在java 8中使用Completable期貨，我想寫一個方法，基於收到的參數，並行運行多個副作用的任務，然後返回他們的「合併」未來（使用CompletableFuture.allOf()），或者什麼都不做，並返回一個已經完成的未來。 然而，allOf返回CompletableFuture<Void>： public static CompletableFuture<Void> allOf(Co

java concurrency java-8 completable-future 2017-10-09

---

0熱度

1回答

加入多個回調執行在CompletableFuture

我有以下工作代碼： DiscoveryCallback callback = new DiscoveryCallback(); Manager.discover(someparam, callback); 我想這個調用包裝成一個CompletableFuture有RX-ISH API與其他異步操作組成。 Manager.discover（）是一個第三方庫，實際上是一個用於本機功能結合的方法，

java completable-future 2017-10-11

---

1熱度

1回答

登錄響應後身體異步的Spring MVC控制器方法

我已經得到了下面的事情在我的Spring MVC應用程序： @RestController public class SomeController { @GetMapping(value = "/csv", produces = { "text/csv", MediaType.APPLICATION_JSON_VALUE }) public Future someAsyncM

java spring spring-mvc asynchronous completable-future 2017-08-29

---

0熱度

1回答

中斷CompletableFuture默認值爲

假設我有3個服務。 首先我打電話serviceA，它返回一個CompletableFuture。 之後，結果我平常打電話serviceB和serviceC（thenCompose()）。 當我得到所有結果後，我想結合所有3個結果並將它返回給某個調用者。 在主叫方，我想等到整個X millseconds的全過程，使： 如果我打斷進程，同時serviceA通話過程中：拋出一些異常（所以它是強制性的）

java java-8 completable-future 2017-10-20

---

3熱度

2回答

如何問CompletableFuture使用非守護線程？

我已經寫了下面的代碼： System.out.println("Main thread:" + Thread.currentThread().getId()); CompletableFuture<Void> future = CompletableFuture.runAsync(() -> { try { System.out.println("Before sleep

java concurrency daemon future completable-future 2017-09-04

---

1熱度

1回答

如何防止在上下文線程CompletableFuture＃whenComplete執行

我有以下代碼： ConcurrentHashMap taskMap= new ConcurrentHashMap(); .... taskMap.compute(key, (k, queue) -> { CompletableFuture<Void> future = (queue == null) ? CompletableFuture.runAsync(myTa

java multithreading concurrency concurrenthashmap completable-future 2017-09-04

---