Tag: Multiprocessing

Multiprozess mit seriellem Objekt als Parameter

Ich habe ein Problem mit Python und übergeben ein serielles Objekt als Parameter zu einem separaten Prozess. Das Programm wird in Windows 8 ausgeführt, also mit globalen Variablen ist keine Option. from multiprocessing import Queue from multiprocessing import Process import os import serial from serial.tools import list_ports from time import sleep displayMessages = Queue() modemPort […]

So verwenden Sie IPython.parallel map () mit Generatoren als Eingabe zur Funktion

Ich versuche, IPython.parallel Karte zu verwenden. Die Eingänge der Funktion, die ich parallelisieren möchte, sind Generatoren. Wegen der Größe / des Gedächtnisses ist es mir nicht möglich, die Generatoren in Listen umzuwandeln. Siehe Code unten: from itertools import product from IPython.parallel import Client c = Client() v = c[:] c.ids def stringcount(longstring, substrings): scount = […]

Python Multiprocessing mit unerwünschten identischen Prozessen

Diese Frage ist eine Gabel von: Multiprocessing / Threading: Daten anhängen & Ausgabe zurück Ich habe mehr oder weniger die gleiche "Run" -Funktion unten, außer dass anstatt ein Plotly Trace-Objekt anhängen, bin ich anhängen die x, y und z Vektoren, die ich danach verarbeiten werde. Der Inhalt von "run" wird zufällig (für argument sake) x, […]

Parallelverarbeitung – Pool – Python

Ich versuche zu lernen, wie man Multiprocessing in Python verwenden kann. Ich las über Multiprocessing , und ich versuche so etwas zu machen: Ich habe die folgende Klasse (Teilcode), die eine Methode hat, um voronoi Diagramme zu produzieren: class ImageData: def generate_voronoi_diagram(self, seeds): """ Generate a voronoi diagram with *seeds* seeds :param seeds: the number […]

Teilen Sie eine Variable zwischen den Mitarbeitern mit Python-Multiprocessing

Diese Frage hat hier schon eine Antwort: Python–Multiprocessing und ein gemeinsamer Zähler 2 antwortet Wie kann ich eine Variable zwischen mehreren Mitarbeitern in Python lesen und aktualisieren? Zum Beispiel scanne ich durch eine Liste von Dateien mit mehreren Prozessen in Python, und möchte überprüfen, ob das übergeordnete Verzeichnis gescannt wurde oder nicht. def readFile(filename): """ […]

Multiprocessing-Code arbeitet beim Import, bricht beim Aufrufen

In einer Datei namens test.py habe ich print 'i am cow' import multi4 print 'i am cowboy' Und in multi4.py habe ich import multiprocessing as mp manager = mp.Manager() print manager Ich bin verwirrt durch die Art und Weise, wie dieser Code funktioniert. Auf der Kommandozeile, wenn ich python und dann in der import test.py […]

Wie kann man ein in Python in einer Klasse parallelisieren?

Ich habe eine Python-Funktion funz , die jedes Mal ein anderes Array von Länge p zurückgibt. Ich muss diese Funktion verschiedene Zeiten ausführen und dann den Mittelwert jedes Wertes berechnen. Ich kann das mit einer for-Schleife machen, aber es dauert viele Male. Ich versuche, das Multiprocessing der Bibliothek zu benutzen, aber ich komme in einen […]

Lese Prozess und verketten Pandas Dataframe parallel mit demk

Ich versuche, parallel eine Liste von csv-Dateien zu lesen und zu verarbeiten und die Ausgabe in einem einzigen pandas dataframe zur Weiterverarbeitung zu verketten. Mein Arbeitsablauf besteht aus 3 Schritten: Erstellen Sie eine Reihe von Pandas Dataframe durch das Lesen einer Liste von csv-Dateien (alle mit der gleichen Struktur) def loadcsv(filename): df = pd.read_csv(filename) return […]

Python-Multiprocessing einer Summe

Ich bekomme nicht meinen Code zu laufen, und als andere habe ich Probleme zu verstehen, wie Multiprocessing funktioniert. Hier ist mein code so weit if __name__ == "__main__": start = time.clock() bins = np.linspace(0,5 * 2 ** 15, 2 ** 15, endpoint=False) # 1e3 t_full = np.linspace(0, 0.2, 2 * bins.shape[0], endpoint=False) po = Pool() […]

Python multiprocess update Wörterbuch synchron

Ich versuche, ein gemeinsames Wörterbuch durch mehrere Prozesse zu aktualisieren. Könnten Sie mir bitte helfen, herauszufinden, was ist das Problem mit diesem Code? Ich bekomme folgende Ausgabe: inside function {1: 1, 2: -1} comes here inside function {1: 0, 2: 2} comes here {1: 0, 2: -1} Vielen Dank. from multiprocessing import Lock, Process, Manager […]

Python ist die beste Programmiersprache der Welt.