Suchergebnisse für Anfrage "concurrency"
Muss der Zugriff auf scala.collection.immutable.List und Vector synchronisiert werden?
Ich gehe durchLernen der gleichzeitigen Programmierung in Scala [https://www.packtpub.com/application-development/learning-concurrent-programming-scala] und ist auf Folgendes gestoßen: In aktuellen Versionen von Scala können bestimmte ...
Java Concurrency: Volatile vs final in "kaskadierten" Variablen?
ist final Map<Integer,Map<String,Integer>> status = new ConcurrentHashMap<Integer, Map<String,Integer>>(); Map<Integer,Map<String,Integer>> statusInner = new ConcurrentHashMap<Integer, Map<String,Integer>>(); status.put(key,statusInner); das ...
Bad Use Cases von scala.concurrent.blocking?
Mit Verweis auf den dritten Punkt inDie [https://stackoverflow.com/a/19682155/383053] akzeptierte Antwort, gibt es Fälle, für die es sinnlos oder schlecht wäre, @ zu verwendeblocking für eine Langzeitberechnung, ob CPU- oder IO-gebunden, die ...
ann ich sicherstellen, dass Haskell atomare E / A ausführ
Ich habe zwei Threads in haskell, die IO ausführen. (Sie drucken nur). So etwas wie das folgende: thread1 :: IO () thread1 = putStrLn "One" thread2 :: IO () thread2 = putStrLn "Two" Ich erhalte derzeit folgende Ergebnisse: OnTwoe OTnweoWie kann ...
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 ...
Kann ich das irgendwie einschränken?
Ich habe zugeschautMike Actons Vortrag über datenorientiertes Design in C ++ [https://www.youtube.com/watch?v=rX0ItVEVjHc] in CppCon 2014, und er gibt dieses Beispiel: int Foo::Bar(int count) { int value = 0; for (int i = 0; i < count; i++) { ...
Java, verteilen Sie die eingehende Arbeit gleichmäßig über das Hashing in Multithread-Umgebungen.
Ich habe einen Java-Code implementiert, um eingehende Aufgaben auszuführen (alsRunnable) mit n Threads basierend auf ihrem hashCode ModulnThreads. Die Arbeit sollte sich im Idealfall gleichmäßig auf diese Fäden verteilen. Insbesondere haben wir ...
Slick 3.0-RC3 schlägt mit java.util.concurrent.RejectedExecutionException @ fe
Ich versuche mich mit Slick 3.0 und Futures vertraut zu machen (mit Scala 2.11.6). Ich benutze einfachen Code basierend auf Slicks Multi-DB Cake Pattern Beispiel [http://typesafe.com/activator/template/slick-multidb-3.0]. Warum wird der folgende ...
List <Future> to Future <List> sequence
Ich versuche zu konvertierenList<CompletableFuture<X>> zuCompletableFuture<List<T>>. Dies ist sehr nützlich, wenn Sie viele asynchrone Aufgaben haben und die Ergebnisse aller Aufgaben erhalten möchten. Wenn einer von ihnen versagt, versagt die ...
ReentrantLock liefert nicht das erwartete Ergebnis
Ich habe ein Producer-Consumer-Programm mit der Funktion "Threads (warten und benachrichtigen)" erstellt. Der Code ist - /** * Message.java ( Common object ) */ package threads; import java.util.concurrent.locks.ReentrantLock; /** * @author ...