Wie nutzt man Multiprocessing , um peinlich parallele Probleme anzugehen ? Peinlich parallele Probleme bestehen normalerweise aus drei Grundteilen: Lesen Sie Eingabedaten (aus einer Datei, Datenbank, TCP-Verbindung usw.). Führen Sie Berechnungen für die Eingabedaten aus, wobei jede Berechnung von...
Ich versuche, eine Lösung zu codieren, bei der ein einzelner Thread E / A-intensive Aufgaben erzeugt, die parallel ausgeführt werden können. Jede Aufgabe verfügt über signifikante In-Memory-Daten. Daher möchte ich in der Lage sein, die Anzahl der Aufgaben zu begrenzen, die gerade anstehen. Wenn...
Der folgende Code gibt einen Kompilierungsfehler mit der Meldung "Unerwartetes Los" aus: x := go doSomething(arg) func doSomething(arg int) int{ ... return my_int_value } Ich weiß, ich kann den Rückgabewert abrufen, wenn ich die Funktion normal aufrufe, ohne Goroutine zu verwenden. Oder ich kann...
Warum gibt es keine Schlüsselwörter für Synchronisation / Parallelität? Bisher gibt mir meine Forschung eine Lösung: Sie wickeln einige Klassen auf hoher Ebene ein und verwenden sie, um die Parallelität zu behandeln. Was ist bei einem Projekt in reinem Kotlin zu tun, wenn eine kleine,...
Gibt es eine Möglichkeit, sich vor gleichzeitigen Änderungen desselben Datenbankeintrags durch zwei oder mehr Benutzer zu schützen? Es wäre akzeptabel, dem Benutzer, der den zweiten Commit / Save-Vorgang ausführt, eine Fehlermeldung anzuzeigen, aber die Daten sollten nicht stillschweigend...
Wie lösche ich das ConcurrentBag? Es gibt keine Methode wie Clearoder RemoveAll...
Eine meiner Anwendungen hängt unter einer gewissen Zeit unter Last. Weiß jemand, was eine solche Ausgabe in jstack verursachen könnte: "scheduler-5" prio=10 tid=0x00007f49481d0000 nid=0x2061 waiting on condition [0x00007f494e8d0000] java.lang.Thread.State: WAITING (parking) at...
Gibt es nur false zurück, wenn das Wörterbuch keinen Wert für den angegebenen Schlüssel enthält, oder gibt es aufgrund von Thread-Race-Bedingungen auch false zurück, wie wenn ein anderer Thread etwas hinzufügt / aktualisiert? Frage im Code: ConcurrentDictionary<int, string> cd = new...
Das ereignisgesteuerte Programmiermodell von node.js macht es etwas schwierig, den Programmfluss zu koordinieren. Einfache sequentielle Ausführung wird in verschachtelte Rückrufe umgewandelt, was einfach genug ist (obwohl es etwas kompliziert ist, es aufzuschreiben). Aber wie wäre es mit...
Ich habe gerade CompletionService in diesem Blog-Beitrag gefunden . Dies zeigt jedoch nicht wirklich die Vorteile von CompletionService gegenüber einem Standard-ExecutorService. Der gleiche Code kann mit beiden geschrieben werden. Wann ist ein CompletionService nützlich? Können Sie ein kurzes...
C ++ 17 hinzugefügt std::hardware_destructive_interference_sizeundstd::hardware_constructive_interference_size . Zuerst dachte ich, es sei nur eine tragbare Möglichkeit, die Größe einer L1-Cache-Zeile zu ermitteln, aber das ist eine übermäßige Vereinfachung. Fragen: Wie hängen diese...
Ich habe versucht, Erlang / OTP zu lernen, und als Ergebnis habe ich über das Schauspielermodell gelesen (okay, überfliegen). Soweit ich weiß, besteht das Akteurmodell lediglich aus einer Reihe von Funktionen (die in einfachen Threads ausgeführt werden, die in Erlang / OTP als "Prozesse"...
Geschlossen . Diese Frage basiert auf Meinungen . Derzeit werden keine Antworten akzeptiert. Möchten Sie diese Frage verbessern? Aktualisieren Sie die Frage, damit sie durch Bearbeiten dieses Beitrags mit Fakten und Zitaten beantwortet werden kann . Geschlossen vor 3 Jahren . Verbessere diese...
Ich versuche, zwei gleichzeitig ausgeführte TaskObjekte mit dem relativ neuen asyncioModul von Python 3 richtig zu verstehen und zu implementieren . Kurz gesagt, Asyncio scheint für asynchrone Prozesse und die gleichzeitige TaskAusführung über eine Ereignisschleife ausgelegt zu sein. Es fördert...
Geschlossen. Diese Frage entspricht nicht den Richtlinien für Stapelüberlauf . Derzeit werden keine Antworten akzeptiert. Möchten Sie diese Frage verbessern? Aktualisieren Sie die Frage so dass es beim Thema für Stack - Überlauf. Geschlossen vor 5 Jahren ....
Ich lese über flüchtige Schlüsselwörter in Java und verstehe den theoretischen Teil davon vollständig. Was ich aber suche, ist ein gutes Fallbeispiel, das zeigt, was passieren würde, wenn die Variable nicht flüchtig wäre und wenn es so wäre. Das folgende Code-Snippet funktioniert nicht wie...
Ich bin dabei, ein System zu entwerfen, das eine Verbindung zu einem oder mehreren Datenfeeds herstellt und eine Analyse der Daten durchführt, um Ereignisse basierend auf dem Ergebnis auszulösen. In einem typischen Multithread-Producer / Consumer-Setup werden mehrere Producer-Threads Daten in eine...
Ich versuche zu konvertieren List<CompletableFuture<X>>zu CompletableFuture<List<T>>. Dies ist sehr nützlich, wenn Sie viele asynchrone Aufgaben haben und Ergebnisse von allen erhalten möchten. Wenn einer von ihnen fehlschlägt, schlägt die endgültige Zukunft fehl. So habe...
Ich hatte immer etwas Ähnliches verwendet, um dies zu erreichen: INSERT INTO TheTable SELECT @primaryKey, @value1, @value2 WHERE NOT EXISTS (SELECT NULL FROM TheTable WHERE PrimaryKey = @primaryKey) ... aber einmal unter Last ist eine Primärschlüsselverletzung aufgetreten. Dies ist...
Ich habe eine große JUnit-Testsuite, in der ich aus zwei Gründen alle Tests gleichzeitig ausführen möchte: Nutzen Sie mehrere Kerne, um die gesamte Testsuite schneller auszuführen Hoffentlich werden einige Fehler aufgrund nicht threadsicherer globaler Objekte erkannt Ich erkenne, dass dies mich...