Suchergebnisse für Anfrage "future"
Mit Futures und Thread.sleep
Beim Ausführen dieses Scala-Codes habe ich keine Ausgabe in der Konsole. (Ich verstehe nicht wirklich, was passiert) Wenn ich entferneConsole.println("Console.println OK!") => alles scheint in Ordnung zu sein. Wenn ich ...
Wie komponiere ich Observables, um die angegebenen verschachtelten und abhängigen Rückrufe zu vermeiden?
Imdieses Blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , er gibtDie [https://gist.github.com/benjchristensen/4677544] (kopiere / füge den folgenden ...
Sind Futures auf einem Thread ausgeführt? (Scala)
Wird unter Verwendung des impliziten Standardausführungskontexts in Scala jede neue Zukunft für einen einzelnen, dedizierten Thread berechnet oder wird die Berechnung aufgeteilt und auf mehrere Threads im Thread-Pool verteilt? Ich weiß nicht, ob ...
Wie kann Future as Applicative in Scala implementiert werden?
Angenommen, ich muss zwei gleichzeitige Berechnungen ausführen, auf beide warten und dann die Ergebnisse kombinieren. Genauer gesagt muss ich @ ausführf1: X1 => Y1 undf2: X2 => Y2 gleichzeitig und rufen Sie dannf: (Y1, Y2) => Y um endlich einen ...
Android volley Timeout Ausnahme bei Verwendung von RequestFuture.get ()
In meinem Fragment versuche ich, TMDBs offene Filmdatenbank zu verwenden, um Details zu "Now Playing" -Filmen abzurufen. Wenn ich die RequestFuture.get (time, TimeUnit) -Methode verwende, um diese Volley-Anfrage auszuführen, erhalte ich immer ...
Warum verkettet das andThen of Future das Ergebnis nicht?
DasandThen was bedeutet, ich habe daraus gelerntAntworte [https://stackoverflow.com/a/20292526/2210478] ist ein Funktionskomponist. Sag da f andThen g andThen hwird gleich h(g(f(x)))Dies impliziert dash function erhält Eingaben ...
Confusion über Threads, die von std :: async mit dem Parameter std :: launch :: async @ gestartet wurd
Ich bin ein bisschen verwirrt über diestd::async Funktion. Die Spezifikation besagt: asynchrone Operation wird "wie in einem neuen Ausführungsthread" ausgeführt (C ++ 11 §30.6.8 / 11). Now, was soll das heißen? ach meinem Verständnis ist der ...
Was ist der Vorteil von FutureTask gegenüber Callable?
Es gibt zwei Ansätze zum Übermitteln und Abrufen der Aufgabe für das Ergebnis FutureTask futureTask = new FutureTask<String>(callable);Verwenden Sie eine Kombination vonCallable undFuture und abschicken amExecutorService. Ergebnis mit @ ...
Blocking Keyword in Scala
Was ist der Unterschied zwischenFuture(blocking(blockingCall())) undblocking(Future(blockingCall()))? Beide sind in @ definierscala.concurrent._ Ich habe geschautat the scala docs [http://docs.scala-lang.org/overviews/core/futures.html#blocking] ...
The Future ist nicht vollständig?
object Executor extends App { implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() implicit val ec = system.dispatcher import akka.stream.io._ val file = new File("res/AdviceAnimals.tsv") ...