Gewusst wie: abrufen mehrerer Werte, die einer Funktion namens durch multiprocessing.Prozess
Habe ich ein Szenario wie dieses :
for each in content :
pdf_output,job_id=createpdf(each)
if pdf_output :
pdf_output = pdf_output + pdf_output
Ich versuche zu parallelisieren des gesamten Prozesses .So etwas
jobs=[]
for each in content :
jobs.append(multiprocessing.Process(target=self.createpdf, args=(content)))
for each in jobs :
jobs.start()
for each in jobs :
jobs.join()
Wie kann ich vernünftig die Aufgabe der
if pdf_output :
pdf_output = pdf_output + pdf_output
Für jeden job ? Wie Kriege ich die 2-retun-Werte gesendet von createpdf und arbeiten ?
Ich denke, multiprocessing.Queue ist ein Anhaltspunkt , aber wie implementiere ich diese ?
Du musst angemeldet sein, um einen Kommentar abzugeben.
Brauchen Sie keine Warteschlangen für so eine simple Aufgabe. Ich würde empfehlen, um pools zu nutzen. Die
Pool.map
Methode anwenden können, eine Funktion eine Reihe von Werten parallel: