Ich habe mit Multithreading und Parallelverarbeitung experimentiert und brauchte einen Zähler, um eine grundlegende Zählung und statistische Analyse der Verarbeitungsgeschwindigkeit durchzuführen. Um Probleme bei der gleichzeitigen Verwendung meiner Klasse zu vermeiden, habe ich eine Sperranweisung...
Wie breche ich aus einer parallel.for- Schleife aus? Ich habe eine ziemlich komplexe Aussage, die wie folgt aussieht: Parallel.ForEach<ColorIndexHolder>(ColorIndex.AsEnumerable(), new Action<ColorIndexHolder>((ColorIndexHolder Element) => { if (Element.StartIndex <= I...
Eines der wichtigsten Beispiele für die Demonstration der Leistungsfähigkeit von MapReduce ist der Terasort-Benchmark . Ich habe Probleme, die Grundlagen des in der MapReduce-Umgebung verwendeten Sortieralgorithmus zu verstehen. Für mich bedeutet das Sortieren einfach, die relative Position eines...
Ich möchte mein Python-Programm parallelisieren, damit es mehrere Prozessoren auf dem Computer verwenden kann, auf dem es ausgeführt wird. Meine Parallelisierung ist sehr einfach, da alle parallelen "Threads" des Programms unabhängig sind und ihre Ausgabe in separate Dateien schreiben. Ich brauche...
Wie kann man einfach warten, bis der gesamte Thread-Prozess abgeschlossen ist? Nehmen wir zum Beispiel an, ich habe: public class DoSomethingInAThread implements Runnable{ public static void main(String[] args) { for (int n=0; n<1000; n++) { Thread t = new Thread(new
Angesichts dieses Codes: var arrayStrings = new string[1000]; Parallel.ForEach<string>(arrayStrings, someString => { DoSomething(someString); }); Werden alle 1000 Threads fast gleichzeitig
Ich versuche zu verstehen, was der Unterschied zwischen SLURMs srunund sbatchBefehlen ist. Ich freue mich über eine allgemeine Erklärung und nicht über spezifische Antworten auf die folgenden Fragen, aber hier sind einige spezifische Verwirrungspunkte, die als Ausgangspunkt dienen und eine...
Die Dokumentation für das multiprocessingModul zeigt, wie eine Warteschlange an einen Prozess übergeben wird, mit dem begonnen wurde multiprocessing.Process. Aber wie kann ich eine Warteschlange für asynchrone Arbeitsprozesse freigeben, mit denen begonnen wurde apply_async? Ich brauche keine...
Gibt es eine Möglichkeit, Threads zum gleichzeitigen Ausführen mehrerer Methoden zu erstellen? Auf diese Weise sollten alle anderen Threads beendet werden, wenn eine Methode zwischen allen anderen Threads
In meiner jüngsten Arbeit mit Gibbs samplinghabe ich das sehr gut genutzt, RVarwas meiner Ansicht nach eine nahezu ideale Schnittstelle zur Erzeugung von Zufallszahlen bietet. Leider konnte ich Repa nicht verwenden, da ich keine monadischen Aktionen in Karten verwenden konnte. Während eindeutig...
Ich habe derzeit das aktuelle Skript. #!/bin/bash # script.sh for i in {0..99}; do script-to-run.sh input/ output/ $i done Ich möchte es parallel mit xargs ausführen. Ich habe versucht script.sh | xargs -P8 Dies wird jedoch nur einmal ausgeführt. Auch mit -n8 kein Glück. Wenn Sie &...
Wie groß ist Scalas Thread-Pool für Futures? Meine Scala-Anwendung macht viele Millionen future {}s und ich frage mich, ob ich irgendetwas tun kann, um sie durch Konfigurieren eines Thread-Pools zu optimieren. Vielen Dank.
Ich versuche, mehrere Funktionen auszuführen, die eine Verbindung zu einem Remotestandort (über das Netzwerk) herstellen, und eine generische Liste zurückzugeben. Aber ich möchte sie gleichzeitig ausführen. Zum Beispiel: public static List<SearchResult> Search(string title) {...
Welche Faktoren bestimmen ein optimales chunksizeArgument für Methoden wie multiprocessing.Pool.map()? Die .map()Methode scheint eine beliebige Heuristik für ihre Standard-Blockgröße zu verwenden (siehe unten). Was motiviert diese Wahl und gibt es einen nachdenklicheren Ansatz, der auf einer...
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...
Eine JVM wird in einem einzelnen Prozess ausgeführt, und Threads in einer JVM teilen sich den zu diesem Prozess gehörenden Heap. Wie nutzt JVM dann mehrere Kerne, die mehrere Betriebssystem-Threads für eine hohe Parallelität bereitstellen?
Ich suche eine einfache prozessbasierte parallele Map für Python, also eine Funktion parmap(function,[data]) Das würde die Funktion für jedes Element von [Daten] in einem anderen Prozess ausführen (nun, auf einem anderen Kern, aber AFAIK, die einzige Möglichkeit, Dinge auf verschiedenen...
Ich habe Probleme, das Konzept der blockierenden und nicht blockierenden Kommunikation in MPI zu verstehen. Was sind die Unterschiede zwischen den beiden? Was sind die Vor- und Nachteile?
Ich bin gespannt, wie die F # -Leistung mit der C ++ - Leistung verglichen wird. Ich habe eine ähnliche Frage in Bezug auf Java gestellt, und ich hatte den Eindruck, dass Java nicht für starkes Zahlenkalkulieren geeignet ist. Ich habe gelesen, dass F # skalierbarer und leistungsfähiger sein soll,...
Ich habe mich gefragt, ob es eine Parallel.For- Entsprechung zur .net-Version für Java gibt. Wenn es jemanden gibt, geben Sie bitte ein Beispiel an. Vielen Dank!