std :: async Funktion läuft seriell

Wenn Sie std :: async mit launch :: async in einer for-Schleife verwenden, wird mein Code seriell im selben Thread ausgeführt, als würde jeder asynchrone Aufruf vor dem Start auf den vorherigen warten. In den Notizen für std :: async Referenzen ...

Was ist der Unterschied zwischen einer Zukunft und einem Versprechen?

Was ist der Unterschied zwischen

Scala - ScheduledFuture

Ich versuche die geplante Zukunft in Scala umzusetzen. Ich möchte, dass es eine bestimmte Zeit wartet und dann den Körper ausführt. Bisher habe ich den folge...

Wie konvertiere ich Map [A, Future [B]] nach Future [Map [A, B]]?

Ich habe mit der Scala Akka-Bibliothek gearbeitet und bin auf ein Problem gestoßen. Wie der Titel sagt, muss ich konvertieren

Wie man auf mehrere Futures wartet

Misserfolg in der Zukunft von Scala für das Verständnis

Ich habe drei aufeinanderfolgende Futures und verwende zum Verständnis wie dieses val comF = for { f1 <- future1 f2 <- future2 f3 <- future3 } yield { // something } comF onSuccess { } comF onFailure { // ---------------- Here is the problem ...

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 ...

Spark-Job mit asynchronem HTTP-Aufruf

Ich erstelle eine RDD aus einer Liste von URLs und versuche dann, Daten mit einem asynchronen http-Aufruf abzurufen. Ich brauche alle Ergebnisse, bevor ich andere Berechnungen mache. Im Idealfall muss ich die http-Aufrufe für verschiedene Knoten ...

Promise-Äquivalent in C #

In Scala gibt es eine Promise-Klasse, mit der Sie eine Zukunft manuell abschließen können. Ich suche eine Alternative in C #. Ich schreibe einen Test und möchte, dass er so aussieht: // var MyResult has a field `Header` var promise = new ...

Scala Option [Zukunft [T]] zu Zukunft [Option [T]]

Wie kann ich konvertierenOption[Future[T]] zuFuture[Option[T]] in scala? Ich möchte es verwenden in: val customerAddresses = for { a <- addressDAO.insert(ca.address) // Future[Address] ia <- ca.invoiceAddress.map(addressDAO.insert) ...