python-multiprocessing

Multiprocessing ist ein Paket, das das Erstellen von Launch-Prozessen mit einer API unterstützt, die dem Threading-Modul in der Python-Programmiersprache ähnelt.
1
Antwort

Warum sterben Python Multiprocessing Workers nicht?

Ich verwende die Python-Multiprocessing-Funktionalität, um einige Funktionen über einige Elemente abzubilden. Etwas nach dem Motto: %Vor% Im Allgemeinen verwende ich Tests in ipython mit cPython und Pypy. Ich habe bemerkt, dass die erzeugten...
27.07.2015, 19:00
1
Antwort

Warum steigt die Geschwindigkeit, um 400.000.000 Zufallszahlen zu generieren?

Ich erzeuge auf einem Intel i7 mit 4 Kernen (8 Threads mit Hyperthreading) auf macOS mit 8 GB RAM etwa 400.000.000 (400 Millionen) Zufallszahlen parallel. Aber ich erzeuge auch 400.000.000 Zufallszahlen auf einem DigitalOcean-Server mit 20 Ke...
12.06.2017, 09:01
2
Antworten

zeromq und python multiprocessing, zu viele offene Dateien

Ich habe ein agentenbasiertes Modell, bei dem mehrere Agenten durch einen zentralen Prozess gestartet werden und über einen anderen zentralen Prozess kommunizieren. Jeder Agent und der Kommunikationsprozess kommunizieren über zmq. Wenn ich jedoc...
04.07.2015, 12:14
2
Antworten

Wie erstelle ich globale Sperre / Semaphor mit multiprocessing.pool in Python?

Ich möchte den Ressourcenzugriff in Kinderprozessen einschränken. Zum Beispiel - limit Ссылка , disk io , etc .. Wie kann ich erreichen, dass es diesen Basiscode erweitert? Bitte teilen Sie einige grundlegende Codebeispiele mit. %Vor%    ...
22.02.2015, 23:33
1
Antwort

Parallelisierung von Aufgaben in Luigi Orchestrator

Ich habe drei Aufgaben definiert: T1 , T2 und T3 und dann eine Aufgabe T4 wie folgt: %Vor% Gibt es eine natürliche Möglichkeit, Luigi mitzuteilen, dass diese Aufgaben T1 , T2 und T3 parallel ausgeführt werden sollen?     
07.12.2015, 05:58
2
Antworten

Wie kann ich eine Aufgabe in einem Multiprocessing.Pool nach einer Zeitüberschreitung abbrechen?

Ich versuche, das Multiprocessing-Paket von Python auf diese Weise zu verwenden: %Vor% Aus Prozessen des Pools möchte ich vermeiden, dass diejenigen, die mehr als 60 s benötigen, auf ihr Ergebnis warten. Ist das möglich?     
07.04.2015, 14:26
2
Antworten

Wo ist die Dokumentation für multiprocessing.pool.ApplyResult?

Es gibt erschreckend wenig strenge API-Dokumentation (lesen Sie: ZERO ) für multiprocessing.pool.ApplyResult . Die Multiprozessor-Erklärung doc spricht über ApplyResult s, definiert sie aber nicht. Dies scheint auch für multiprocessi...
23.11.2016, 20:49
2
Antworten

Bessere Möglichkeit, Speicher für Multiprozessing in Python freizugeben?

Ich habe dieses Problem jetzt seit einer Woche angepackt und es ist ziemlich frustrierend geworden, denn jedes Mal, wenn ich ein einfacheres, aber ähnlich großes Beispiel für das, was ich machen muss, umsetze, stellt sich heraus, dass Multiproze...
05.11.2015, 01:57
1
Antwort

Ändern der Puffergröße in Multiprocessing.Queue

Also ich habe ein System mit einem Produzenten und einem Verbraucher durch eine Warteschlange von unbegrenzter Größe verbunden, aber wenn der Verbraucher wiederholt ruft, bis die leere Ausnahme ausgelöst wird, wird die Warteschlange nicht gelösc...
29.11.2016, 17:16
2
Antworten

Ausführung von zwei Klassenmethoden gleichzeitig in Python

Ich bin sicher, viele ähnliche Fragen wurden schon früher gestellt, aber nachdem ich viele davon gelesen habe, bin ich mir immer noch nicht sicher, was ich tun soll. Also, ich habe ein Python-Skript, um einige externe Instrumente (eine Kamera un...
05.02.2018, 13:20