Tag: future

Habe ich Folgendes Aufrufbar: public class Worker implements Callable<Boolean>{ @Override public Boolean call(){ boolean success=true; //do Something return success; } } Nun bin ich es, der Sie ausführt: Worker worker - new Worker(); Future<Boolean> submit = executor.submit(worker);

Ich bin mit der Future API von Scala 2.10.X. Hier ist mein use-case: object Class1 { def apply(f: (Int) => Future[String])(i: Int): Future[String] = { val start = DateTime.now val result = f(i) result.onComplete{ case _ =>

Gibt es wiki-Artikel über Sie: (http://en.wikipedia.org/wiki/Futures_and_promises, http://en.wikipedia.org/wiki/Thunk_(delayed_computation)). Aber ich bin nicht sicher, was sind die genauen Unterschiede zwischen den drei als Programmiersprache-Konzept? Sind futures und verspricht nur anwendbar in concurrent programming? InformationsquelleAutor JRR | 2013-09-10

Ich bin mit: Scala 2.10 Spielen 2.1 Derzeit bin ich mit der Future Klasse aus scala.concurrent._, aber ich bin offen für eine neue API. Ich habe Probleme bei der Kombination der Ergebnisse von mehreren futures in einer

C# hat ein cooles neues feature public Task<string> async f() { string r = LongCompute(); return r; } aber ist das nicht äquivalent zu public Future<String> f() { return Globals.executorService.submit(new Callable<String>() { public String call() throws Exception

Gibt es zwei Ansätze für die übermittlung und der Abruf der Aufgabe zum Ergebnis FutureTask futureTask = new FutureTask<String>(callable); Verwendung der Kombination von Callable und Future und reichen auf ExecutorService. Abrufen Ergebnis mit future.get(). Future future =

Ich habe den folgenden code: #include <iostream> #include <future> #include <chrono> #include <thread> using namespace std; int sleep_10s() { this_thread::sleep_for(chrono::seconds(10)); cout << "Sleeping Done\n"; return 3; } int main() { auto result=async(launch::async, sleep_10s); auto status=result.wait_for(chrono::seconds(1)); if (status==future_status::ready)

Die Organisation, für die ich arbeite, hat ein trigger für den Fall, dass Anrufe ein wenig code in eine Klasse namens Fälle.cls. Ich veränderte den code, aber bei der Einsatzplanung, dass ich immer ein error: pending batch

Den andThen Bedeutung, die ich gelernt, aus dieser Antwort ist eine Funktion Komponist. Sagen, dass f andThen g andThen h wird gleich h(g(f(x))) Dies impliziert die h function erhalten input von g(f(x)) Aber für die andThen im

In meiner Scala app, ich habe eine Funktion aufruft, die eine Funktion liefert ein Ergebnis vom Typ Future[T]. Ich übergeben zu müssen, das zugeordnete Ergebnis in meinem rekursiven Aufruf der Funktion. Ich will, dass das tail-rekursiv ist,

Ich habe ein seltsames problem mit Zukunft.get() in Java. Es gibt immer eine InterruptedException, aber die seltsame Sache ist, dass die Ursache der Ausnahme null ist, so kann ich nicht sagen, unterbrach mich.. Es kommt noch schlimmer,

Ich bin in den Prozess des Verstehens fine grain util.die Parallelität. Wo ist die Umsetzung des Java - Callable und Future sich in die JVM ? Habe ich die Zukunft Klasse, wo er beschreibt die Zukunft auf

Durch die Ausführung dieser scala-code, habe ich keine Ausgabe in der Konsole. (Ich weiß nicht wirklich verstehen, was passiert ist) Wenn ich entfernen Console.println("Console.println OK!") => alles scheint in Ordnung. Wenn ich entfernen Thread.sleep(2000) => alles scheint

Gegeben das folgende Beispiel: val handler : Connection = new DatabaseConnectionHandler() val result : Future[Future[Future[Option[ResultSet]]]] = handler.connect .map( (parameters) => handler ) .map( connection => connection.sendQuery("BEGIN TRANSACTION SERIALIZABLE") ) .map( future => future.map( query => query.rows )

Ok, also ich weiß, die erste Antwort /Kommentar hier wird "verwenden Sie eine ExecutorService und verwenden invokeAll". Es gibt jedoch einen guten Grund (was ich nicht langweilen Sie die Menschen mit) für uns halten, die thread-pools zu

ExecutorService pool=Executors.newFixedThreadPool(7); List<Future<Hotel>> future=new ArrayList<Future<Hotel>>(); List<Callable<Hotel>> callList = new ArrayList<Callable<Hotel>>(); for(int i=0;i<=diff;i++){ String str="2013-"+(liDates.get(i).get(Calendar.MONTH)+1)+"-"+liDates.get(i).get(Calendar.DATE); callList.add(new HotelCheapestFare(str)); } future=pool.invokeAll(callList); for(int i=0;i<=future.size();i++){ System.out.println("name is:"+future.get(i).get().getName()); } Nun möchte ich den pool zu invokeAll alle die Aufgabe bekommen, bevor die for-Schleife,

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

Ich bin mir bewusst, dass mein problem mag ein wenig Komplex. Aber ich werde versuchen, mich selbst auszudrücken. Habe ich diese Methode, die ich zurückgeben möchte, ein Map[String, List[String]] mit Daten gefüllt. def myFunction():Map[String, List[String]] = {

Vom java-docs auf Zukunft.Abbrechen() boolean cancel(boolean mayInterruptIfRunning) Versucht ein Abbruch der Ausführung dieser Aufgabe. Dieser Versuch wird scheitern, wenn die Aufgabe bereits abgeschlossen hat, wurde bereits abgebrochen oder konnte nicht gekündigt werden, ein anderer Grund. Wenn Sie

Java 8 führt CompletableFuture eine neue Implementierung, die Zukunft ist composable (enthält eine Reihe von thenXxx Methoden). Ich möchte in diesem ausschließlich, aber viele der Bibliotheken, die ich verwenden möchten zurückkehren, nur nicht composable Future Instanzen. Ist

Angenommen ich habe mehrere futures und müssen warten, bis entweder jeder von Ihnen schlägt fehl oder alle von Ihnen erfolgreich. Zum Beispiel: es sind 3 futures: f1f2f3. Wenn f1 gelingt f2 fehl ich nicht warten, bis f3

Ich bin ein wenig verwirrt über die std::async Funktion. Die Spezifikation sagt: asynchroner Vorgang wird ausgeführt, "als ob in einem neuen thread der Ausführung" (C++11 §30.6.8/11). Nun, was hat das zu bedeuten? In meinem Verständnis, der code

Was ist der sauberste Weg, um map die Exception einer gescheiterten Future in scala? Sagen, ich habe: import scala.concurrent._ import scala.concurrent.ExecutionContext.Implicits.global val f = Future { if(math.random < 0.5) 1 else throw new Exception("Oh no") } Wenn

Was sind die Unterschiede zwischen Deferreds, Verspricht und Futures? Gibt es eine allgemein anerkannte Theorie, die hinter all diesen drei? InformationsquelleAutor der Frage Tower | 2011-07-23

Wenn ein ExecutorService und Future Objekte (bei der Einreichung Runnable Aufgaben), wenn ich geben Sie einen timeout-Wert für die Zukunft der get-Funktion, macht die zugrunde liegenden Faden Holen Sie getötet, als ein TimeoutException geworfen wird? InformationsquelleAutor der