Suchergebnisse für Anfrage "concurrency"

1 die antwort

Transaktionsisolationsstufen und Unterabfragen

Wenn wir ein UPDATE mit einer Unterauswahl haben, kann die Unterabfrage gleichzeitig ausgeführt werden oder nicht, wenn READ COMMITTED isoliert ist? Mit anderen Worten, liegt eine Rennbedingung vor: update list set [state] = 'active' where id = ...

5 die antwort

Lösen von peinlich parallelen Problemen mit Python Multiprocessing

Wie benutzt manMehrfachverarbeitung [http://docs.python.org/library/multiprocessing.html]anzugehenpeinlich parallele Probleme [http://en.wikipedia.org/wiki/Embarrassingly_parallel]? Peinlich parallele Probleme bestehen typischerweise aus drei ...

3 die antwort

Apache Kafka - KafkaStream zum Thema / Partition

Ich schreibe Kafka Consumer für hochvolumige verteilte Hochgeschwindigkeitsanwendungen. Ich habe nur ein Thema, aber die Rate der eingehenden Nachrichten ist sehr hoch. Für diesen Anwendungsfall wäre es angemessen, mehrere Partitionen zu haben, ...

TOP-Veröffentlichungen

2 die antwort

Golang lädt mithilfe von Goroutinen mehrere Dateien gleichzeitig herunter

Ist es möglich, Dateien mithilfe von Goroutinen parallel herunterzuladen und zu speichern? Unten ist mein Code, der Dateien von meiner Dropbox herunterlädt: package main import ( "encoding/json" "fmt" "io" "io/ioutil" "net/http" "net/url" "os" ...

3 die antwort

Die Leistung von gleichzeitigem Code unter Verwendung von dispatch_group_async ist VIEL langsamer als bei einer Single-Thread-Version

Ich habe in letzter Zeit einige Experimente angestellt, um mit einer großen Anzahl von Zufallszahlen "normalverteilte" Glockenkurven zu erzeugen. Der Ansatz ist einfach: Erstellen Sie ein Array von Ganzzahlen und setzen Sie es auf Null. (Ich ...

3 die antwort

Die Initialisierung eines nichtflüchtigen Feldes mit einer Sperre schützen?

Zu Bildungszwecken schreibe ich eine einfache Version vonAtomicLong, wobei eine interne Variable von bewacht wirdReentrantReadWriteLock. Hier ist ein vereinfachtes Beispiel: public class PlainSimpleAtomicLong { private long value; private ...

2 die antwort

Ähnlichkeit zwischen Schlaf und Mitmachen in Java

Wie aus der Frage hervorgeht, möchte ich die Ähnlichkeit zwischen den Schlaf- und Verknüpfungsmethoden für den Thread kennen. Ich habe viele Fragen durchlaufen, die den Unterschied zwischen der Schlaf- und der Verbindungsmethode beschreiben. Ich ...

3 die antwort

WAITING at sun.misc.Unsafe.park (native Methode)

Eine meiner Anwendungen hängt sich unter Last auf. Weiß jemand, was diese Ausgabe in jstack verursachen kann? "scheduler-5" prio=10 tid=0x00007f49481d0000 nid=0x2061 waiting on condition [0x00007f494e8d0000] java.lang.Thread.State: WAITING ...

7 die antwort

Volatile vs Static in Java

Ist es richtig, das zu sagen?static bedeutet eine Kopie des Wertes für alle Objekte undvolatile bedeutet eine Kopie des Wertes für alle Threads? Wie auch immer astatic Der variable Wert wird auch ein Wert für alle Threads sein. Warum sollten wir ...

4 die antwort

Ist eine Sammlung threadsicher, wenn sie nur im Konstruktor geschrieben ist?

Vorausgesetzt, wir hatten diese Klasse final class Foo { private final Set<String> bar = new HashSet<>(); public Foo() { bar.add("one"); bar.add("two"); bar.add("three"); } public boolean contains(final String s) { return bar.contains(s); } ...