Tag: concurrency

Ich habe gerade erst begonnen zu erkunden einige concurrency-features von Java 8. Eine Sache verwirrt mich ein bisschen ist diese zwei statischen Methoden: CompletableFuture<Void> runAsync(Runnable runnable) CompletableFuture<U> supplyAsync(Supplier<U> supplier) Tun, wer weiß, warum Sie wählen, um Schnittstelle

Ich versuche zu verstehen, die Parallelität Gehen. Insbesondere, schrieb ich diesen thread-unsafe-Programm: package main import "fmt" var x = 1 func inc_x() { //test for { x += 1 } } func main() { go inc_x() for

Ich weiß, dass CompletableFuture design hat keine Kontrolle über seine Ausführung mit Unterbrechungen, aber ich nehme an, einige von Euch haben dieses problem. CompletableFutures sind sehr gute Art und Weise zu Komponieren asynchrone Ausführung, aber gegeben der

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);

Hinweis: ich habe bereits angesprochen, dieses problem in einem anderen, SO post - Die Verwendung einer semaphore innerhalb einer geschachtelten Java 8 parallel-stream handeln, kann der DEADLOCK. Ist das ein bug? -, aber der Titel von diesem

Ist es möglich, zum herunterladen und speichern von Dateien in parallel mit goroutines? Unten ist mein code, mit dem herunterladen von Dateien aus meiner dropbox: package main import ( "encoding/json" "fmt" "io" "io/ioutil" "net/http" "net/url" "os" "path/filepath"

In einer Java-threaddump ich Folgendes gefunden: "TP-Processor184" daemon prio=10 tid=0x00007f2a7c056800 nid=0x47e7 waiting for monitor entry [0x00007f2a21278000] java.lang.Thread.State: BLOCKED (on object monitor) at org.apache.jackrabbit.core.state.SharedItemStateManager.getNonVirtualItemState(SharedItemStateManager.java:1725) - locked <0x0000000682f99d98> (a org.apache.jackrabbit.core.state.SharedItemStateManager) at org.apache.jackrabbit.core.state.SharedItemStateManager.getItemState(SharedItemStateManager.java:257) "TP-Processor137" daemon prio=10 tid=0x00007f2a7c00f800 nid=0x4131 waiting for

Ich versuche eine Anwendung, die dauert ein paar journal-Einträge und die Summe berechnen. Ist unten Weg, es zu tun ist thread/concurrency sicher, wenn es mehrere threads Aufruf der addToSum() Methode. Ich möchte sicherstellen, dass jeder Aufruf aktualisiert

Ich habe noch zu finden, eine eindeutige Erklärung der Unterschiede zwischen Condition und Event Klassen in der threading Modul. Gibt es eine klare Anwendungsfall, in dem ein hilfreicher wären als die anderen? Alle Beispiele, die ich finden

Betrachten Sie diese typischen disconnected Szenario: laden ein Customer-Objekt von SQL Server mithilfe von LINQ To SQL Benutzer änderungen der Entität und der präsentationsebene sendet wieder die Einheit geändert werden. die Daten-Schicht, mit L2S, müssen senden Sie

Habe ich mein eigenes erstellt TestService läuft auf einem separaten QThread, aber wenn die MainLoop beendet die QThread::finished signal nicht ausgegeben. Ich sah eine ähnliche Frage, aber das problem war etwas anders da, weil der OP war

Habe ich gelesen, für concurency seit gestern und ich weiß nicht viel Sachen... Aber einige Dinge beginnen zu bekommen, klar,... Ich verstehe, warum double-check-locking nicht sicher (ich Frage mich, was ist die propability der seltene Zustand zu

Habe ich kleine server und-client Python-Skripte, in denen der client sendet einen string, und der server antwortet mit der Rückseite. Wenn der Kunde einen quit-string, der client beendet und dann den server verlässt. Ich möchte den server

Ich versuche zu erstellen 86 Instanzen task.py gleichzeitig laufen lassen. import sys import subprocess for file in range(86): subprocess.call([sys.executable,'task.py',str(file)+'in.csv',str(filen)+'out.csv']) Was ist das problem? das problem war "Teilprozess.Anruf wartet auf den Befehl zu vervollständigen. Verwenden Teilprozess.Popen statt:" InformationsquelleAutor

Was ist der beste Weg zur Implementierung eines Hash geändert werden kann über mehrere threads, aber mit der kleinsten Anzahl von sperren. Für die Zwecke dieser Frage, können Sie davon ausgehen, dass der Hash gelesen werden-schwer. Es

Schrieb ich eine simulation der Ring-Netzwerk-Topologie in Scala (Quelle hier) (Scala 2.8 RC7) und Clojure (Quelle hier) (Clojure 1.1) für einen Vergleich der Akteure und Agenten. Während die Scala-version zeigt nahezu Konstante message exchange rate wie erhöhe

Ich habe versucht, mir beibringen, Parallelität, und ich habe ein Problem. Ich verstehe, dass zwei Java-threads können miteinander kommunizieren über wait() und notify(). Dies erfordert jedoch, dass ein thread inaktiv sein und im wesentlichen "nur herumsitzen", bis

So, in letzter Zeit gab es sehr viel Wert, die von fast allen Plattform-Anbietern, um neue tools/language Konstrukte für eine bessere Parallelität. Und das ist auch einer der Gründe, warum viele der Ideen aus den funktionalen Programmiersprachen

Habe ich eine Klasse (RInterfaceHL), die Anrufe einer anderen Klasse (JRIEngine), die native Methoden auf einem single-threaded-Anwendung. Also ich will nur eine einzige Instanz meiner Klasse (RInterfaceHL) pro JVM. Kann ich die singleton-Muster mit statischen Initialisierung, um

In der JavaDoc für ThreadPoolExecutor ist unklar, ob es akzeptabel ist, fügen Sie die Aufgaben direkt auf die BlockingQueue sichern der Vollstrecker. Die docs sagen aufrufen executor.getQueue() "soll in Erster Linie für debugging und monitoring". Ich Baue

Aus der Javadoc-ich weiß ConcurrentHashMap.replace atomar ist, aber was ist mit ConcurrentHashMap.put? Ich sehe, Sie sind unterschiedlich implementiert in den source code, aber ich bin nicht in der Lage, herauszufinden, Ihre Unterschiede. Alle gurus geben einige Richtlinien

Habe ich ein Datenbanken-Tabelle mit ~50K Zeilen, jede Zeile steht für eine Aufgabe, die getan werden müssen. Ich habe ein Programm, dass Extrakte einen job aus der DB, macht den job und legt das Ergebnis wieder in

Ich bin das schreiben, um viele Dateien in einer Multithread-Anwendung und ich bin momentan dabei, einen handler pro file. Ich habe HandlerFactory-Klasse, verwaltet die Verteilung dieser Handler. Was ich tun möchte, ist, dass thread Anfragen und bekommt

Habe ich dieses test-Programm fetch url parallele, aber wenn ich steigen die parallele Zahl auf etwa 1040, ich fange an lookup www.httpbin.org: no such host Fehler. Nach etwas Google fand ich andere sagen, dass Sie nicht das

Geben ein paar Informationen zum hintergrund, ich bin Verarbeitung einer Datei gespeichert haben, und nach der Verwendung des regulären Ausdrucks, so teilen Sie die Datei in die Komponente Gegenstände, die ich dann verarbeiten muss, das Objekt die