Tag: completable-future
In Java 8, auf eine Zukunft, die explizit beendet wird (Einstellung, seinen Wert und status), und kann auch abhängige Funktionen und Aktionen, die der trigger nach seiner Fertigstellung.
Wie zu unterbrechen zugrunde liegenden Ausführung von CompletableFuture
5 Antworten
Ich weiß, dass CompletableFuture design hat keine Kontrolle über seine Ausführung mit Unterbrechungen, aber ich nehme an, einige von Euch haben dieses problem. CompletableFutures sind sehr gute Art und Weise zu Komponieren asynchrone Ausführung, aber gegeben der
Wie bekomme ich ein CompletableFuture<T> von einer Async-Http-Client-Anfrage?
1 Antworten
Auf Async-Http-Client-Dokumentation ich sehen, wie man eine Future<Response> als das Ergebnis eines asynchronen HTTP-Get-Anfrage einfach tun, zum Beispiel: AsyncHttpClient asyncHttpClient = new DefaultAsyncHttpClient(); Future<Response> f = asyncHttpClient .prepareGet("http://api.football-data.org/v1/soccerseasons/398") .execute(); Response r = f.get(); Jedoch, für die Bequemlichkeit
Muss ein exception-handler übergeben CompletableFuture.ausnahmsweise() zurückgeben müssen einen sinnvollen Wert?
2 Antworten
Ich bin verwendet, um die ListenableFuture Muster, mit onSuccess() und onFailure() Rückrufe, z.B. ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool()); ListenableFuture<String> future = service.submit(...) Futures.addCallback(future, new FutureCallback<String>() { public void onSuccess(String result) { handleResult(result); } public void onFailure(Throwable t) {
Was ist der Unterschied zwischen 'CompletionStage' und 'CompletableFuture'
3 Antworten
Habe ich ein Beispiel gesehen, in jedem von Ihnen, aber ich muss genau wissen, was ist der Unterschied in der Tiefe, Weil ich manchmal denke, ich kann beide nutzen das gleiche Ergebnis zu erhalten, So möchte ich
Spring @Async mit CompletableFuture
1 Antworten
Ich habe eine Frage zu diesem code: @Async public CompletableFuture<String> doFoo() { CompletableFuture<String> fooFuture = new CompletableFuture<>(); try { String fooResult = longOp(); fooFuture.complete(fooResult); } catch (Exception e) { fooFuture.completeExceptionally(e); } return fooFuture; } Die Frage ist:
Was ist der empfohlene Weg, zu warten, bis die Ausfüllbaren Zukunft threads beenden
2 Antworten
Ich bin mit CompletableFuture wie unten im code. Aber über die Art und Weise ich sollte warten, bis alle runnables fertig, fand ich zwei Wege, und ich weiß nicht, der Unterschied zwischen Ihnen-und welche ist die beste
Werfen Ausnahme von CompletableFuture
4 Antworten
Ich habe den folgenden code: //How to throw the ServerException? public void myFunc() throws ServerException{ //Some code CompletableFuture<A> a = CompletableFuture.supplyAsync(() -> { try { return someObj.someFunc(); } catch(ServerException ex) { //throw ex; gives an error here.
Java 8 Lieferant Exception-handling mit CompletableFuture
5 Antworten
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 = new TestCompletableFuture(); testF.start(); } public void start() { Supplier<Integer>
ExecutorService.submit(Task) vs CompletableFuture.supplyAsync(Aufgabe, Testamentsvollstrecker)
3 Antworten
Laufen einige Dinge parallel oder asynchron, ich kann entweder einen ExecutorService: <T> Future<T> submit(Runnable task, T result); oder die CompletableFuture Api:static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor); (Nehmen wir an ich verwende in beiden Fällen die gleiche
Return CompleteFuture & lt; Void & gt; oder CompletableFuture & lt;? & gt;
4 Antworten
Möchte ich schreiben, dass eine asynchrone Methode gibt eine CompletableFuture. Der einzige Zweck für die Zukunft ist zu verfolgen, wenn die Methode beendet ist, nicht Ihr Ergebnis. Wäre es besser, zurück CompletableFuture<Void> oder CompletableFuture<?>? Gibt es einen
Liste & lt; Zukunft & gt; zu Future & lt; List & gt; Sequenz
8 Antworten
Ich versuche zu konvertieren List<CompletableFuture<X>> zu CompletableFuture<List<T>>. Dies ist sehr nützlich, wenn Sie viele asynchrone Aufgaben, und Sie müssen, um Ergebnisse zu erhalten alle von Ihnen. Wenn eine von Ihnen fehlschlägt, dann wird die endgültige Zukunft ausfällt.