Suchergebnisse für Anfrage "future"
Wie verwende ich CompletableFuture.thenComposeAsync ()?
Gegeben public class Test { public static void main(String[] args) { int nThreads = 1; Executor e = Executors.newFixedThreadPool(nThreads); CompletableFuture.runAsync(() -> { System.out.println("Task 1. Thread: " ...
Gibt es sequentielle Future.find?
Ich habe eine Nebenwirkung, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }und ich möchte es wiederholt ausführen, bis das Prädikat true zurückgibt. def success(n: Int): Boolean = n % 2 == 0Mein Plan ist ...
Wie man eine Methode immer wieder aufruft, bis sie einen `Future` -Wert zurückgibt, der` None` enthält
Gibt eine Methode zurück, die ein @ zurückgibFuture so was.. def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` } ... wie rufe ich es immer wieder auf, bis es ein @ zurückgiFuture Wert ...
Umgang mit gescheiterten Futures
In Play Framework 2.3 kann eine Aktion ein Ergebnis eines erfolgreichen zukünftigen Aufrufs wie folgt erzeugen: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + ...
Skala-Weg, um mit Zuständen in Vorstellungen umzugehen?
Ich versuche, eine übersichtliche Konstruktion mit Verständnis für Geschäftslogik zu erstellen, die auf Futures basiert. Hier ist ein Beispiel, das ein Arbeitsbeispiel enthält, das auf der Ausnahmebehandlung basiert: (for { // find the user by ...
Daten aus einer Zukunft in Scala holen
Ich habe eineFuture[List[Person]]Und ich möchte das bekommenList[Person] davon. Wie kann ich es tun ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
Verwandeln Sie Java Future in eine CompletableFuture
Java 8 stellt vorCompletableFuture, eine neue Implementierung von Future, die komponierbar ist (enthält eine Reihe von thenXxx-Methoden). Ich möchte dies ausschließlich verwenden, aber viele der Bibliotheken, die ich verwenden möchte, geben nur ...
Ist es möglich, einen Rückruf zu installieren, nachdem die Anforderungsverarbeitung in Spray abgeschlossen ist?
Ich versuche, große temporäre Dateien von Spray bereitzustellen. Ich muss diese Dateien löschen, sobald die HTTP-Anforderung abgeschlossen ist. Ich konnte bisher keinen Weg finden, dies zu tun ... Ich verwende Code ähnlich ...
Verwenden von Futures in Akka-Darstellern
Ich fange gerade an, Akka-Schauspieler in Scala zu lernen. Ich verstehe, dass von einem Schauspieler empfangene Nachrichten in der Mailbox eines Schauspielers in eine Warteschlange gestellt und einzeln verarbeitet werden. Indem ...
boost :: future and continuations - Wert gesetzt, Zukunft aber weiterhin blockiert
Ich versuche folgende Fortsetzung zum Laufen zu bringen - aberf.get() Blöcke. Was ist los mit dir? #include <iostream> #define BOOST_THREAD_PROVIDES_FUTURE #define BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION #include ...