Suchergebnisse für Anfrage "completable-future"
Wie wähle ich einen Executor für CompletableFuture :: supplyAsync
CompletableFuture::supplyAsync(() -> IO bound queries) Wie wähle ich einen Executor für CompletableFuture :: supplyAsync aus, um eine Verschmutzung des @ zu vermeideForkJoinPool.commonPool(). Es gibt viele Optionen inExecutors ...
Was ist die empfohlene Methode, um zu warten, bis die zukünftigen Completable-Threads beendet sind
Ich benutzeCompletableFuture wie unten im Code gezeigt. In Bezug auf die Art und Weise, wie ich warten soll, bis alle Läufe fertig sind, habe ich zwei Möglichkeiten gefunden und kenne den Unterschied zwischen beiden nicht und welche ist die beste ...
Java 8 Behandlung von Lieferantenausnahmen mit CompletableFuture
Betrachten Sie den folgenden Code - public class TestCompletableFuture { BiConsumer<Integer, Throwable> biConsumer = (x,y) -> { System.out.println(x); System.out.println(y); }; public static void main(String args[]) { TestCompletableFuture testF ...
List <Future> to Future <List> sequence
Ich versuche zu konvertierenList<CompletableFuture<X>> zuCompletableFuture<List<T>>. Dies ist sehr nützlich, wenn Sie viele asynchrone Aufgaben haben und die Ergebnisse aller Aufgaben erhalten möchten. Wenn einer von ihnen versagt, versagt die ...
Mehrere CompletionStage nur dann beibehalten, wenn eine Bedingung erfüllt ist
Ich habe mehrereCompletionStage Methoden, die ich verketten möchte. Das Problem ist, dass das Ergebnis des ersten bestimmt, ob die nächsten ausgeführt werden sollen. Derzeit scheint der einzige Weg, dies zu erreichen, darin zu ...
Map Ausnahme in abschließbarer Zukunft zu einem anderen Ausnahmetyp?
Ich verwende die abschließbaren Futures von Java 8 und möchte in der Lage sein, eine Ausnahme, die von der Zukunft ausgeht, in eine andere Ausnahme umzuwandeln. All das zusammengesetzte Zeug, das ich versucht habe, scheint kurzgeschlossen ...
CompletableFuture # whenComplete wird nicht aufgerufen, wenn thenApply verwendet wird
Ich habe den folgenden Code (resultierend aus meine vorherige Frage [https://stackoverflow.com/questions/40251528/how-to-use-executorservice-to-poll-until-a-result-arrives] ), der eine Aufgabe auf einem Remote-Server plant und dann mit @ ...
CompletableFuture: Warten auf die erste Rückkehr?
Ich habe welcheCompletableFutures und ich möchten sie parallel ausführen und auf das erste warten, das @ zurückginormalerweis. Ich weiß, ich kann @ verwendCompletableFuture.anyOf, um zu warten, bis der erste zurückkehrt, aber dies wird ...
Java8 CompletableFuture recoverMit Äquivalent? zB ausnahmsweise aber return CompletableFuture <U>
Ich sehe keine offensichtliche Möglichkeit, eine Ausnahme mit einem asynchronen Ergebnis zu behandeln. Zum Beispiel, wenn ich einen asynchronen Vorgang wiederholen möchte. Ich würde so etwas erwarten, aber handleAsync tut nicht das, was Sie ...
Hat CompletableFuture einen entsprechenden lokalen Kontext?
n früheren Zeiten hatten wir ThreadLocal für Programme, um Daten zusammen mit dem Anforderungspfad zu transportieren, da die gesamte Anforderungsverarbeitung für diesen Thread durchgeführt wurde und solche Dinge wie Logback dies mit MDC.put ...
Seite 1 von 2