Tag: concurrency

In der informatik Parallelität ist eine Eigenschaft von Systemen, in denen mehrere Berechnungen durchgeführt werden können, in überlappende Zeiträume. Die Berechnungen können ausgeführt werden, auf mehrere Kerne in ein und demselben chip, präventiv Zeit-freigegebene threads auf den gleichen Prozessor, oder ausgeführt auf physisch getrennten Prozessoren.

Wie startet einen hintergrund-thread, der nicht blockiert den main thread in Java?

Anzahl der Antworten 2 Antworten
Habe ich den folgenden Java-code: public static void main(String args) { new Thread(new MyRunnable()).run(); showGUI(); } Mein problem ist, dass ab MyRunnable blockiert den main thread, verursacht showGUI nicht aufgerufen werden, bis es beendet wurde. Was würde

CompletableFuture supplyAsync

Anzahl der Antworten 1 Antworten
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

C++ - Bibliotheken, die zur Umsetzung von Go goroutines oder Gehen die Kanäle?

Anzahl der Antworten 4 Antworten
Arbeite ich mit einem mittleren C++ - code-Basis, die derzeit komplett single-threaded. Die Zeit ist gekommen, jedoch, zu verfolgen, Gleichzeitigkeit und Parallelität für Leistungssteigerungen. Ich bin sehr interessiert in der concurrency-Modell von Google ' s Go Programmiersprache,

Verständnis goroutines

Anzahl der Antworten 4 Antworten
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

Shared memory - Bedarf für Synchronisierung

Anzahl der Antworten 3 Antworten
Habe ich ein Projekt erlebt, in denen die Kommunikation zwischen Prozessen, die mit Hilfe von shared memory (z.B. mit ::CreateFileMapping unter Windows) und jedes mal, wenn einer der Prozesse wollte informieren, dass einige Daten im shared-memory, ein

Wie zu unterbrechen zugrunde liegenden Ausführung von CompletableFuture

Anzahl der Antworten 5 Antworten
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

Android: Einer gegen viele Instanzen von HttpClient pro Anwendung

Anzahl der Antworten 1 Antworten
Bis vor kurzem, unsere app gemeinsam einen einzelnen Apache-HttpClient-Instanz mithilfe der ThreadSafeClientConnManager über die gesamte Anwendung. Der http-client-Instanz wurde gehalten von einer singleton-Klasse. Da gefällt mir das singleton-pattern für seine zahlreichen Probleme, die ich umgestaltet werden, unsere

Ausnahme während der Ausführung Aufrufbar

Anzahl der Antworten 4 Antworten
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);

ConcurrentHashMap reorder-Anweisung?

Anzahl der Antworten 3 Antworten
Ich bin auf der Suche in ConcurrentHashMap Umsetzung und eine Sache machen, die mich verwirrt. /* Specialized implementations of map methods */ V get(Object key, int hash) { if (count != 0) { //read-volatile HashEntry<K,V> e =

Verschachtelte Java 8 parallele forEach-Schleife durchführen Armen. Ist dieses Verhalten zu erwarten?

Anzahl der Antworten 3 Antworten
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

Was ist der beste Weg, die Parallelität zu verwalten, in einer Datenbank-access-Anwendung?

Anzahl der Antworten 2 Antworten
Vor einer Weile schrieb ich eine Anwendung von mehreren Benutzern verwendet, um zu behandeln trades Schöpfung. Ich habe nicht getan, die Entwicklung für einige Zeit jetzt, und ich kann mich nicht erinnern wie ich es geschafft die

Golang laden Sie mehrere Dateien parallel mit goroutines

Anzahl der Antworten 2 Antworten
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"

Gleichzeitige anzeigen/foreach in scala

Anzahl der Antworten 7 Antworten
Ich habe eine iteration vals: Iterable[T] und eine lang andauernde Funktion ohne relevante Nebenwirkungen: f: (T => Unit). Das ist im Augenblick angewendet, um vals in der offensichtlichen Weise: vals.foreach(f) Ich würde gerne die Aufrufe f zu

Mehrere Java-threads scheinbar Verriegelung gleichen monitor?

Anzahl der Antworten 4 Antworten
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

Die sichere Löschung von pthreads mit einem cleanup-handler in C

Anzahl der Antworten 1 Antworten
Die wir gegeben haben, etwas code zu schauen, in Vorbereitung für eine Prüfung in Bezug auf pthreads und löscht Sie richtig. Wir haben darum gebeten worden zu erklären, was falsch ist, und korrigieren Sie es. Meine Antwort:

Wie stellen Sie die Aktualisierung BigDecimal innerhalb ConcurrentHashMap thread-sichere

Anzahl der Antworten 4 Antworten
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

Tabelle Ebene Sperren in Hibernate

Anzahl der Antworten 1 Antworten
Verwende ich Hibernate version 4. Wir haben ein problem im batch-Prozess. Unser system funktioniert wie folgt Wählen Sie Datensätze, die in den "PENDING" Zustand Sofort aktualisiert 'IN PROGRESS' state Prozess und update auf "ABGESCHLOSSEN" Stand Das problem,

threading.Bedingung vs threading.Event

Anzahl der Antworten 2 Antworten
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

Alle praktischen Beispiel LockSupport & AbstractQueuedSynchronizer verwenden?

Anzahl der Antworten 5 Antworten
Jungs, kann jemand geben ein einfaches Beispiel aus der Praxis LockSupport & AbstractQueuedSynchronizer verwenden? Beispiel in javadocs ist ziemlich angespannt. Nutzung von Semaphore erlaubt ist verstanden von mir. Vielen Dank für jede Antwort. InformationsquelleAutor |

LINQ To SQL-exception mit Attach(): Cannot add ein Unternehmen, das mit einem Schlüssel wird bereits verwendet

Anzahl der Antworten 2 Antworten
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

Wie neu zu starten, zu planen, Wann scheduleWithFixedDelay eine exception wirft?

Anzahl der Antworten 4 Antworten
Benutze ich ScheduledExecutorService planen einige Aufgaben, die brauchen, um ausführen regelmäßig. Ich möchte wissen, ob dieser code funktioniert nach Wiederherstellung der Zeitplan, wenn eine Ausnahme passiert. ScheduledExecutorService service = Executors.newScheduledThreadPool(1); this.startMemoryUpdateSchedule(service);//See below method //Recursive method to handle

Warum ist QThread::finished signal nicht emittiert werden?

Anzahl der Antworten 1 Antworten
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

Java: Caching von nicht-volatile-Variablen von verschiedenen threads

Anzahl der Antworten 3 Antworten
Die situation ist folgende: Ich habe ein Objekt mit viel setter und Getter. Instanz dieses Objekts erstellt wird, in einem bestimmten thread, wo alle Werte eingestellt sind. Zunächst erstelle ich ein "leeres" Objekt mithilfe von new-Anweisung und

Warum ConcurrentHashMap.putifAbsent sicher ist?

Anzahl der Antworten 4 Antworten
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

Soll ich überschreiben die Standard-ExecutionContext?

Anzahl der Antworten 3 Antworten
Bei der Verwendung von futures in scala die Vorgabe ist die Verwendung der Standard-Implicits.globalen Ausführungskontext. Es scheint, dies standardmäßig zu machen, ein thread pro Prozessor. In einer eher traditionellen threaded-web-Anwendung, dies scheint wie eine schlechte Standardeinstellung bei

Wie man ein hintergrund Verfahren ständig überprüfen, während für die Eingangs - threading?

Anzahl der Antworten 3 Antworten
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

Wie, um sicherzustellen, dass std::thread erstellt werden in multi-core?

Anzahl der Antworten 3 Antworten
Ich bin mit visual studio 2012. Ich habe ein Modul, wo ich gelesen haben, eine riesige Menge von Dateien von der Festplatte nach der Durchquerung Ihre entsprechenden Pfade über eine xml. Für diese mache ich std::vector<std::thread> m_ThreadList;

führen Sie mehrere Instanzen von python-Skript gleichzeitig

Anzahl der Antworten 1 Antworten
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

Java-Massive-Multiplayer-Game-Server-Skalierbarkeit

Anzahl der Antworten 3 Antworten
Habe ich ein massive-multiplayer-online-Spiel für Android namens Infinite Black: https://market.android.com/details?id=theinfiniteblack.client In meiner Naivität, ich hatte erwartet, mäßige Wachstumsrate von über 1.000 Spieler im Monat, und benötigen, um zu verwalten, ~20 live-TCP/IP-clients tops. Das Spiel hat unerwartet Explosives

Pure-Ruby gleichzeitige Hash

Anzahl der Antworten 10 Antworten
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

Speicher Barrieren und coding-Stil über eine Java-VM

Anzahl der Antworten 2 Antworten
Angenommen ich habe eine statische komplexe Objekt wird in regelmäßigen Abständen aktualisiert, die durch einen pool von threads, und Lesen Sie mehr oder weniger ständig in eine lang andauernde-thread. Das Objekt selbst ist immer unveränderlich und spiegelt

Wie Clojure-Agenten vergleichen zu Scala ' s actors?

Anzahl der Antworten 1 Antworten
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

Java: Synchronisation auf primitive?

Anzahl der Antworten 11 Antworten
In unserem system, wir haben eine Methode, tun einige Arbeit, wenn es heißt, mit einer bestimmten ID: public void doWork(long id) { /* ... */ } Nun, diese arbeiten zu können, gleichzeitig für verschiedene IDs, aber wenn

Wie können zwei threads kommunizieren, während beide laufen?

Anzahl der Antworten 5 Antworten
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

Das code-Beispiel, die sich als "volatile" deklarieren sollte verwendet werden

Anzahl der Antworten 6 Antworten
Derzeit kann ich nicht verstehen, wenn wir volatile zum deklarieren von Variablen. Ich habe zu tun einige Studie und suchte einige Materialien über die für eine lange Zeit und weiß, dass, wenn ein Feld deklariert ist flüchtig,

Parallelität in web-Anwendungen

Anzahl der Antworten 7 Antworten
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

Spring Security / abgelaufen-url keine url-Weiterleitung

Anzahl der Antworten 1 Antworten
Hallo Im arbeiten mit Frühling, und ich habe ein problem, versucht die concurrency-control und authentication-failure-url. Ich versuche zu tun, dass der gleiche Benutzer können sich nicht anmelden in der Anwendung gleichzeitig. Also für das, dass ich definierte

Einzelne Instanziierung mit Argumenten

Anzahl der Antworten 3 Antworten
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

Java EE 7 - Injektion in Runnable/Callable-Objekt

Anzahl der Antworten 2 Antworten
Concurrency Utilities(JSR-236) wurde in Java EE 7. Gibt es eine Möglichkeit, wie man Spritzen meine EJBs in Runnable/Callable-Objekt? Speziell möchte ich so etwas wie dieses: ejb mit business-Logik @LocalBean public class MyEjb { public void doSomeStuff() {

Ist das hinzufügen von Aufgaben zu BlockingQueue von ThreadPoolExecutor ratsam?

Anzahl der Antworten 5 Antworten
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

Wie funktioniert shared memory vs. message-passing-Handhabung von großen Daten-Strukturen?

Anzahl der Antworten 10 Antworten
In der Suche bei Go und Erlang-Ansatz, um die Parallelität bemerkte ich, dass Sie beide verlassen sich auf message-passing. Dieser Ansatz offensichtlich verringert die Notwendigkeit für komplexe sperren, da es keinen gemeinsamen Staat. Jedoch den Fall betrachten,

ConcurrentHashMap.setzen V. S. ConcurrentHashMap.ersetzen

Anzahl der Antworten 3 Antworten
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

Ist F# wirklich schneller als Erlang am laichen und zu töten Prozesse?

Anzahl der Antworten 2 Antworten
Aktualisiert: Diese Frage enthält einen Fehler, die macht der Maßstab bedeutungslos. Ich werde versuchen, bessere benchmark-Vergleich F# und Erlang die grundlegende Parallelität Funktionalität und erkundigen Sie sich über die Ergebnisse in einer anderen Frage. Ich versuche, verstehen

Der beste Weg, um eine DB-Tabelle als eine Warteschlange (eine.k.eine batch-queue oder Warteschlange)

Anzahl der Antworten 5 Antworten
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

NSOperationQueue mainQueue vs performSelectorOnMainThread?

Anzahl der Antworten 1 Antworten
Was ist der Unterschied zwischen diesem: [[NSOperationQueue mainQueue] addOperationWithBlock:^{ [self doSomthing:object]; }]; und so: [self performSelectorOnMainThread:@selector(doSomething:) withObject:object waitUntilDone:NO] InformationsquelleAutor ma11hew28 | 2012-05-09

Putting einen thread schlafen, bis Ereignis X Eintritt

Anzahl der Antworten 3 Antworten
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

Sperren einer MySQL-Datenbank, so dass nur eine person auf einmal kann eine Abfrage ausführen?

Anzahl der Antworten 4 Antworten
Habe ich ein paar Probleme, wenn Menschen versuchen, Zugriff auf eine MySQL-Datenbank und Sie werden versuchen, zu aktualisieren Tabellen mit den gleichen Informationen. Habe ich eine Webseite geschrieben mit PHP. In dieser Webseite ist eine Abfrage um

Lookup [HOST]: no such host Fehler in Gehen

Anzahl der Antworten 2 Antworten
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

Starten Sie eine Java-Klasse, die in verschiedenen threads

Anzahl der Antworten 2 Antworten
Frage ich mich, wie ich eine Klasse aus verschiedenen threads, und alle Anrufe laufen in einem eigenen thread? Können sagen, ich habe drei threads, und jeder von Ihnen benötigen, rufen Sie anotherClass.getBS(), aber die Anrufe kommen könnten,

Ist mit std::async oft für kleine Aufgaben performance-freundlich?

Anzahl der Antworten 1 Antworten
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