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 ?

InformationsquelleAutor Nishant | 2012-05-29
Schreibe einen Kommentar