Suchergebnisse für Anfrage "multiprocessing"
Python Multiprocessing führt zu vielen Zombieprozessen
Ich habe die Multiprozessorbibliothek von Python mithilfe eines Pools von Arbeitern implementiert. Ich habe den folgenden Code implementiert import main1 t1 = time.time() p = Pool(cores) result = p.map(main1, client_list[client]) if result == ...
multiprocessing queue full
Ich verwende concurrent.futures, um Multiprocessing zu implementieren. Ich erhalte eine Warteschlange. Voller Fehler, der seltsam ist, weil ich nur 10 Jobs zugebe. A_list = [np.random.rand(2000, 2000) for i in range(10)] ...
Wie kann ich den Prozess mit Pythons Multiprocessing beenden?
Ich habe Code, der auf mehreren anderen Systemen ausgeführt werden muss, die möglicherweise hängen bleiben oder Probleme haben, die nicht unter meiner Kontrolle stehen. Ich würde gerne Pythons Multiprocessing verwenden, um untergeordnete Prozesse ...
multiprocessing: TypeError: 'int' Objekt ist nicht iterierbar
Ich benutze dasmultiprocessing -Modul in Python 3, aber aus irgendeinem Grund wirft esTypeError: 'int' object is not iterable wenn ich das Programm starte. Das habe ich gemacht: def main(i): global urlDepth global row global counter urlDepth = ...
Wie übergeben Sie eine Warteschlangenreferenz an eine von pool.map_async () verwaltete Funktion?
Ich möchte, dass ein Prozess mit langer Laufzeit seinen Fortschritt über eine Warteschlange (oder etwas Ähnliches) zurückgibt, die ich einem Fortschrittsbalkendialogfeld zuführe. Ich brauche das Ergebnis auch, wenn der Prozess abgeschlossen ist. ...
Kann keine Klassenvariablen mit Multiprocessing.Process-Objekt in Python3 ändern
Wenn ich eine Klasse mit einer Klassenvariablen schreibe, zwei Klassenobjekte generiere und den Wert der Klassenvariablen mithilfe einer Methode eines der beiden Objekte ändere, wird der Wert der Klassenvariablen natürlich auch für das andere ...
Python Cassandra Treiber gleiche Insert-Performance wie copy
Ich versuche, Python async mit Cassandra zu verwenden, um festzustellen, ob ich Datensätze schneller als mit dem Befehl CQL COPY in Cassandra schreiben kann. Mein Python-Code sieht so aus: from cassandra.cluster import Cluster from cassandra ...
Lesen, komprimieren, schreiben mit Multiprocessing
Ich komprimiere Dateien. Ein einzelner Prozess ist für einige von ihnen in Ordnung, aber ich komprimiere Tausende von ihnen. Dies kann (und hat) mehrere Tage in Anspruch genommen, daher möchte ich ihn mit Multiprocessing beschleunigen. Ich ...
Pathos Multiprocessing kann kein Paket und keine Funktion in der Klasse @ aufrufe
Ich möchte Multiprocessing in der Klasse durchführen. Es scheint, als ob nur pathos.multiprocessing mir helfen kann. Wenn ich es implementiere, kann es jedoch nicht die Pakete laden, die ich in der Hauptfunktion verwende. from ...
Warum haben neue Objekte in der Mehrfachverarbeitung dieselbe ID?
Ich habe versucht, ein neues Objekt in einem Prozess zu erstellen, wenn das Multiprocessing-Modul verwendet wurde. Allerdings verwirrt mich etwas. Wenn ich ein Multiprocessing-Modul verwende, ist die ID des neuen Objekts dieselbe for i in ...