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.
ProcessPoolExecutor aus der gleichzeitigen.futures Weise langsamer als multiprocessing.Pool
1 Antworten
Ich war das Experimentieren mit neuen glänzenden gleichzeitige.futures - Modul eingeführt, in Python 3.2, und ich habe bemerkt, daß, mit fast identischen code, mit dem Pool von gleichzeitigen.futures ist Weg langsamer als mit multiprocessing.Pool. Dies ist die
was ist der Vorteil der Verwendung von FutureTask mehr Aufrufbar?
2 Antworten
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 =
Gehen http.Bekommen, Parallelität und "Connection reset by peer"
4 Antworten
Habe ich zwischen 1000-2000 Webseiten zum download von einem server, und ich bin mit go-Routinen und-Kanäle zum erzielen einer hohen Effizienz. Das problem ist, dass jedes mal, wenn ich aus meinem Programm bis zu 400 Anfragen fehl
ConcurrentHashMap für c++
3 Antworten
Gibt es eine ConcurrentHashMap für c++ - Implementierung oder etwas ähnliches irgendwo? Ich kann nicht verstehen, warum multithreading in c++ ist so schwer als Java! Multi-threading ist so schwer, weil vor dem C++11-standard veröffentlicht wurde, gab es
Java Iterator-Implementierung - next() und hasNext() erzwingen, um
8 Antworten
Habe ich eine Implementierung von java.util.Iterator die erfordert, dass der Aufruf next() sollte immer vorgegangen werden, indem ein Aufruf an hasNext(). (Dies ist, weil die Ergebnisse zurückgegeben asynchronosly in einer multi-threaded Umgebung, und es ist nie klar,
Was ist der Unterschied zwischen einem Future und einem Versprechen?
7 Antworten
Was ist der Unterschied zwischen Future und Promise? Sie beide wirken wie Platzhalter für künftige Ergebnisse, aber wo ist der Unterschied? Sie können eine Promise und es ist bis zu Ihnen, es zu halten. Wenn jemand anderes
Implementieren Sie einen blockierenden Funktionsaufruf in Java
3 Antworten
Was ist die empfohlene /beste Weg, um zu implementieren ein blockierender Funktionsaufruf in Java, das kann später aufgehoben durch einen Aufruf aus einem anderen thread? Grundsätzlich möchte ich zwei Methoden auf ein Objekt, wo der erste Anruf
ConcurrentHashMap computeIfAbsent
3 Antworten
Gibt es eine neue computeIfAbsent API eingeführt in Java 8. Die javadocs für ConcurrentHashMap ist impelementation es Zustand: Wenn der angegebene Schlüssel nicht bereits im Zusammenhang mit einem Wert, versucht zu berechnen, dessen Wert mit dem angegebenen
Wie unit-Tests, dass ExecutorService erzeugt neuen thread für die Aufgabe?
1 Antworten
Wie funktioniert ein unit-test, dass ein neuer thread hervorgebracht wurde für ein Runnable task, wenn mit einem ExecutorService? Grundsätzlich habe ich einen statischen thread-pool für meine Anwendung. public static final ExecutorService executorService = Executors.newCachedThreadPool(); Ich möchte in
Wie zum Herunterfahren alle Vollzieher beim beenden einer Anwendung?
5 Antworten
Laut Brian Goetz Java Concurrency in der Praxis JVM kann nicht verlassen, bis alle (nondaemon) threads beendet haben, so Versagen Sie Herunterfahren, einen Testamentsvollstrecker könnte verhindern, dass die JVM beenden. I. e. System.exit(0) nicht unbedingt wie erwartet
Frühjahr: Singleton/session Bereiche und Parallelität
3 Antworten
Tut singleton/session Bereiche der Spring-Bean erforderlich, die den Zugriff auf alle seine Felder, die synchronisiert werden müssen? Sagen durch "synchronized" - Schlüsselwort oder mit einigen Klassen aus dem Paket "java.util.concurrent". Als Beispiel, ist dieser code nicht thread-sicher?
Stark konkurrierenden HTTP mit Netty und NIO
1 Antworten
Arbeite ich durch die Beispiel Netty HTTP-Client-code um http-Anfragen innerhalb von einer gleichzeitigen, Multithread-Umgebung. Jedoch, mein system bricht komplett (mit ein paar Ausnahmen) ziemlich geringen Durchsatz. In fast pseudo-code: ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory()) bootstrap.setPipelineFactory(new HttpClientPipelineFactory());
Verständnis Von Linux-Kernel-Ringpuffer
1 Antworten
Gibt es einen Artikel unter: http://lwn.net/Articles/378262/, beschreibt die Linux-Kernel Ringpuffer-implementation. Ich habe einige Fragen: Hier ist der "Produzent": spin_lock(&producer_lock); unsigned long head = buffer->head; unsigned long tail = ACCESS_ONCE(buffer->tail); if (CIRC_SPACE(head, tail, buffer->size) >= 1) { /*
Wie ändern Sie die Priorität eines benutzerdefinierten GCD Warteschlange?
3 Antworten
Habe ich einen GCD Warteschlange wie diese: dispatch_queue_t q = dispatch_queue_create("com.testcompany.myqueue", NULL); Wenn ich Versand der Aufgaben an die Warteschlange, es ist irgendwie langsamer als einfach Ausführung der Aufgabe auf dem Haupt-thread. dispatch_async(q, ^(void) { [self performHeavyCalculationAndUpdateUI];
AWS lambda und Java concurrency
2 Antworten
Es ist bekannt, dass AWS lambda kann Wiederverwendung früh erstellt Objekte von Prozeduren, und es funktioniert wirklich (siehe FAQ): F: Wird AWS Lambda-Wiederverwendung-Funktion-Instanzen? Um die Leistung zu verbessern, AWS Lambda können wählen, um zu behalten, eine Instanz
Mehrere Parameter übergeben Zug um Zug.futures.Executor.Karte?
4 Antworten
Den gleichzeitige.futures.Executor.map nimmt eine variable Anzahl von iterables, aus dem die Funktion aufgerufen wird. Wie soll ich es nennen, wenn ich einen generator erzeugt Tupel, die sind normalerweise ausgepackt in Ort? Folgende funktioniert nicht, weil jeder der
Warum Gehen Panik auf das schreiben zu einem geschlossenen Kanal?
1 Antworten
Warum Gehen Panik auf das schreiben zu einem geschlossenen Kanal? Während die value, ok := <-channel idiom für das Lesen von Kanälen, und so ist die ok-Ergebnis getestet werden kann, zur Kollision mit einem geschlossenen Kanal: //reading
@Kontext HttpServletRequest Umfang in Jersey ContainerResponseFilter
2 Antworten
Schreibe ich eine Jersey-Response-filter. Ich bin mit Jersey 1.17. Ich möchte den Zugriff auf einige Attribute des httpServletRequest in der filter-API. Die Art und Weise, was ich jetzt tun ist als unten. Ist es sicher zu injizieren,
producer/consumer-Arbeit Warteschlangen
3 Antworten
Ich bin Ringen um die beste Art der Umsetzung meiner Bearbeitung pipeline. Meine Produzenten feed Arbeit auf eine BlockingQueue. Auf der consumer-Seite, ich Umfrage der Warteschlange, wickeln, was ich in ein Runnable task, und senden Sie es
Was bedeutet Thread-Affinität zu bedeuten???
4 Antworten
Irgendwo habe ich gehört, um die Thread-Affinität und Thread-Affinität Testamentsvollstrecker. Aber ich finde keine richtige Referenz für die es zumindest in java. Kann mir jemand bitte erklären, was es damit auf sich? InformationsquelleAutor Hossein | 2013-10-25
Ist die Zuweisung eines Zeigers atomic in golang?
2 Antworten
Übergibt einen Zeiger atomic-in gehen? Muss ich zuweisen, die einen Zeiger in einem Schloss? Nehmen wir an, ich möchte nur ordnen Sie die Zeiger auf null, und möchten, dass andere threads in der Lage sein, um es
C# Concurrent List Fragen
4 Antworten
Habe ich eine situation, in C#, wo ich eine Liste mit einfachen Typen. Diese Liste kann aufgerufen werden, indem mehrere threads: Einträge können Hinzugefügt oder entfernt werden, und die Existenz eines Eintrages überprüft werden kann. Ich habe
Zuverlässigkeit Atomare Zähler in DynamoDB
3 Antworten
War ich mit dem Gedanken Amazon DynamoDB in meiner Anwendung, und ich habe eine Frage bezüglich seiner Atomare Zähler Zuverlässigkeit. Ich bin Aufbau einer verteilten Anwendung, muss gleichzeitig, und konsequent, Inkrement/Dekrement einen Zähler, gespeichert in einer Dynamo-Attribut.
Wie die bluebird Parallelität option für die map-Funktion
1 Antworten
Ich bin versucht, bluebird ' s map-Funktion mit der integrierten Steuerung der Gleichzeitigkeit. Möchte ich zum abrufen einer Liste der Namen, dann machen Sie eine Reihe von POST-Anfragen für jeden Namen. Zum Beispiel möchte ich eine Anfrage
Warum ist mein JTextArea nicht updaten?
5 Antworten
Habe ich den code wie folgt: class SimplifiedClass extends JApplet { private JTextArea outputText; //Lots of methods public void DoEverything() { String output = ""; for(int i = 0; i <= 10; i++) { output += TaskObject.someLongTask(i);
der gleichzeitige Zugriff auf MySQL-Datenbank mit der gespeicherten Prozedur
4 Antworten
Ich habe eine gespeicherte Prozedur, die wird gelesen und dann Inkrementieren eines Wertes in der Datenbank. Dieses Besondere Verfahren wird von vielen Programmen zur gleichen Zeit. Ich bin besorgt über die Parallelität Fragen, insbesondere die reader-writer-problem. Kann
bash-Herde: exit, wenn nicht Sperre
2 Antworten
Den folgenden lock-Mechanismus verwendet wird zum verhindern, dass ein cron job von gleichzeitig ausgeführt: #!/bin/bash echo "Before critical section" ( flock -e 200 echo "In critical section" sleep 5 ) 200>/tmp/blah.lockfile echo "After critical section" Beim laufen
Wie man jobs in einer Kategorie für Gas Gleichzeitige Baut-plugin für Jenkins
1 Antworten
Heruntergeladen habe ich das TCB-plugin für Jenkins. Ich habe mehrere builds, tests ausführen. Diese baut muss einzeln ausgeführt werden, als Sie Zugriff ähnliche Dateien, die verursachen können, tests fehlschlagen, wenn mehr als ein Testlauf ausgeführt wird. Ich
Java-Multi-Core-Verarbeitung
3 Antworten
Ich würde gerne lernen über Java-multi-core-Verarbeitung. Von dem was ich verstehe, ist, dass Threading ist eine Art von multi-core-ich glaube, ich habe einen anständigen Griff. Ich weiß, es gibt andere Wege, um multi-core-Verarbeitung, aber ich weiß nicht,
Empfehlen, eine gute Ressource für die Ansätze der parallelen Programmierung?
4 Antworten
Ich gelesen habe, verschiedenen bits und Stücke auf Parallelität, aber war in der Hoffnung zu finden, eine einzige Ressource, die details und vergleicht die verschiedenen Ansätze. Idealerweise nehmen in threads, co-Routinen, message passing, Schauspieler, futures... was anderes
Auger-Datei schreiben
6 Antworten
gewusst wie: schreiben einer text-Datei zugegriffen werden kann, die von mehreren Quellen (evtl. in einer gleichzeitigen Art und Weise) um sicherzustellen, dass keine schreib-operation verloren geht? Gerne, wenn zwei unterschiedliche Prozesse sind, schreiben in der gleichen Zeit,
Festlegen einer maximalen Ausführungszeit für eine Methode/thread
2 Antworten
Ich habe eine Methode, die in die Datenbank schreibt. Die Voraussetzung ist, um sicherzustellen, dass diese Methode nicht ausgeführt werden, nachdem eine bestimmte Zeit verstreicht. Wenn Sie gibt vor, dann sollte nichts getan werden. Die einen grundlegenden
Select MAX(Feld)+1 AUS ... parallelitätsproblemen
2 Antworten
Hallo, ich fürchte über die Parallelität auf partner-Anwendung verursachen, die in den letzten Tagen war es Probleme mit den CRUDS Operationen, insbesondere mit Einlagen. Also lief ich den SQL Profiler, und beachten Sie, dass diese insert-Anweisung nicht
Wie erklären Sie den "deadlock" besser?
14 Antworten
Ich bin kämpfen, um zu "erklären " deadlock" in threads, in einfachen Worten, so bitte helfen. Was könnte sein das beste Beispiel von "deadlock" (z.B. in Java), und wie es geschieht in Schritten und wie es zu
Doctrine2 ORM select for update
2 Antworten
Bitte könnten Sie mir empfehlen einige Ansatz, wie umsetzen SELECT FOR UPDATE mit der Lehre? Muss ich Lesen Sie einige counter-Wert, verwenden Sie es in PHP-code und sofort erhöhen Sie den Wert, bevor es jemand anderes (von
Golang Kontext.WithValue: so fügen Sie mehrere Schlüssel-Wert-Paare
3 Antworten
Mit Go context Paket es ist möglich, pass-request-spezifische Daten auf den stack request-handling-Funktionen, die mit func WithValue(parent Context, key, val interface{}) Context Erzeugt einen neuen Context eine Kopie des Elternteils und enthält den Wert val zu dem
Warum nicht diesen thread pool bekommen Müll gesammelt?
5 Antworten
In diesem code-Beispiel, das ExecutorService verwendet und erlaubte, zu gehen, out of scope. public static void main(String args) { ExecutorService executorService = Executors.newFixedThreadPool(3); executorService.submit(new Runnable() { public void run() { System.out.println("hello"); } }); } Einmal executorService ist
Zu behandeln, wie der gleichzeitige Zugriff auf ein Scala-Kollektion?
4 Antworten
Habe ich ein Schauspieler, der - in seinem Wesen - verwaltet eine Liste von Objekten. Es hat drei grundlegende Operationen, add, update und remove (wo manchmal der remove-Aufruf der add-Methode, aber davon abgesehen), und arbeitet mit einer
Wie zur Verbesserung der Leistung " = SimpleDateFormat verpackt in ThreadLocal?
4 Antworten
Dies ist auf Java 7 (51) auf RHEL mit 24 cores Wir werden bemerken, dass ein Anstieg der durchschnittlichen Reaktionszeiten von java " = SimpleDateFormat verpackt in thread-lokalen wie erhöhen wir die thread-pool-Größe. Ist dies zu erwarten?
Was ist der Unterschied zwischen linearizability und serialisierbarkeit?
4 Antworten
Was ist der Unterschied zwischen linearizability und serialisierbarkeit (im Zusammenhang mit Java)? Kannst du bitte erklären den Unterschied zwischen diesen mit einem Beispiel oder eine gute Referenz? Kann ich nicht empfehlen Herlihy ' s "Kunst des Multiprozessor-Programmierung",
Was ist der empfohlene Weg, zu warten, bis die Ausfüllbaren Zukunft threads beenden
2 Antworten
Ich bin mit CompletableFuture wie unten im code. Aber über die Art und Weise ich sollte warten, bis alle runnables fertig, fand ich zwei Wege, und ich weiß nicht, der Unterschied zwischen Ihnen-und welche ist die beste
Warum verwenden Sie Thread.currentThread().isInterrupted() anstelle von isInterrupted()?
4 Antworten
Ich habe eine Frage bezüglich der Umsetzung einer Widerrufsbelehrung für einen Thread-Unterklasse. Es scheint üblich zu sein, es zu tun mögen dieses: class A extends Thread { [...] public final void run() { try { while(!Thread.currentThread().isInterrupted()) {
Java-Thread warten() => blockiert?
6 Antworten
Laut Java thread state info Aufruf von wait() wird ein thread zu gehen, im BLOCKIERTEN Zustand. Aber dieses Stück code wird das Ergebnis (nach Aufruf) in einen Thread in den Wartezustand. class bThread extends Thread { public
Java ExecutorService pausieren/fortsetzen der einen bestimmten thread
2 Antworten
Gibt es eine Möglichkeit zur Nutzung von ExecutorService pausieren/fortsetzen einen bestimmten thread? private static ExecutorService threadpool = Executors.newFixedThreadPool(5); Vorstellen, dass ich aufhören will zu dem thread wich wie die id=0 (unter der Annahme, dass zu jedem einer
Spring JMS-listener-container-Parallelität-Attribut nicht funktioniert
3 Antworten
Hallo, ich Lerne Spring JMS mit ActiveMQ. In meinem Beispiel-Szenario ist Produzent Anwendung sendet rund 50 Meldungen in der Warteschlange und wenn ich start Consumer-Anwendung beginnt es zu konsumieren diese Nachrichten. Nun möchte ich mehrere Konsumenten-threads zu
Wie zum übergeben von Parametern an ein Thread-Objekt?
7 Antworten
Arbeite ich mit einem C++ - Klassen-Bibliothek, die eine Thread-Basis-Klasse, wo der Benutzer hat, um implementieren Sie eine run() Methode. Gibt es eine empfohlene Art und Weise, wie Parameter übergeben, die run() Methode? Jetzt Ich bevorzuge, Sie
JavaFX gleichzeitige Aufgabe, die Einstellung Zustand
1 Antworten
Schaffe ich das UI für meine Anwendung, welche Aktien ein core-Modul mit Versionen für andere Plattformen. In JavaFX, ich versuche, Tasks um Sachen im hintergrund, aber ich kann nicht herausfinden, wie zu aktualisieren, die Task-Status. Dies ist,
Thread.drin schlafen Scala Akteure
1 Antworten
Ist es nicht richtig zu verwenden Thread.sleep(5000); im inneren ein Schauspieler? Tut es tatsächlich machen Schauspieler Schlaf für 5 Sekunden? Gibt es eine einfache alternative, um Schauspieler zu schlafen für einige Sekunden? InformationsquelleAutor As As | 2014-09-11
Die Aktualisierung von Feldern mit Werten in Z. B. concurrentdictionary
3 Antworten
Ich bin versucht, zu aktualisieren Einträge in einer Z. B. concurrentdictionary so etwas wie dieses: class Class1 { public int Counter { get; set; } } class Test { private ConcurrentDictionary<int, Class1> dict = new ConcurrentDictionary<int, Class1>();
CountDownLatch vs. Semaphore
6 Antworten
Ist dort jeder möglicher Vorteil der Verwendung von java.util.gleichzeitige.CountdownLatch statt java.util.gleichzeitige.Semaphor? Soweit ich sagen kann, die folgenden Fragmente sind fast äquivalent: 1. Semaphore final Semaphore sem = new Semaphore(0); for (int i = 0; i < num_threads;