2016-04-13 20 views
0

Ich habe zwei Variablen, die nacheinander definiert werden müssen. Wie kann ich sie mit Multiprocessing definieren?Multiprocessing in Python 3

train_X = preprocess_data(train_X) 
test_X = preprocess_data(test_X) 

Antwort

0

A Pool macht dies einfach genug:

with multiprocessing.Pool() as pool: 
    train_X, text_X = pool.map(preprocess_data, (train_X, test_X)) 

So stellen Sie sicher, dass Sie genug Arbeit zu verarbeiten tun, dass sie die Daten kochend zu und von den untergeordneten Prozessen wert (was implizit geschieht, wenn Sie verwenden Pool Arbeiter).