Python：マップとマルチプロセッシングを使用

Question

私は2つの引数をとり、それをmultiprocessing.Poolに追加して並列化できる関数を作成しようとしています。 この単純な関数を書くときにいくつかの問題がありました。

df = pd.DataFrame() 
df['ind'] = [111, 222, 333, 444, 555, 666, 777, 888] 
df['ind1'] = [111, 444, 222, 555, 777, 333, 666, 777] 

def mult(elem1, elem2): 
    return elem1 * elem2 

if __name__ == '__main__': 
    pool = Pool(processes=4) 
    print(pool.map(mult, df.ind.astype(int).values.tolist(), df.ind1.astype(int).values.tolist())) 
    pool.terminate() 

それはエラーを返します：

TypeError: unsupported operand type(s) for //: 'int' and 'list' 

私が間違っているかを理解することはできません。 誰でもこのエラーの意味と解決方法を説明できますか？

Answer 1

マルチプロセスプールモジュールでは、複数の処理を行う引数のリストを取り込み、1つの引数のみを取り入れることができます。あなたは、次の手順を実行して、この問題を解決することができます

from multiprocessing import Pool 
import pandas as pd 

df = pd.DataFrame() 
df['ind'] = [111, 222, 333, 444, 555, 666, 777, 888] 
df['ind1'] = [111, 444, 222, 555, 777, 333, 666, 777] 

def mult(elements): 
    elem1,elem2 = elements 
    return elem1 * elem2 

if __name__ == '__main__': 
    pool = Pool(processes=4) 
    inputs = zip(df.ind.astype(int).values.tolist(), df.ind1.astype(int).values.tolist()) 
    print(pool.map(mult, inputs)) 
    pool.terminate() 

私はここでやったことは、各要素は、あなたが入力したかった二つの引数であることをリストにあなたの2回の反復可能オブジェクトを圧縮されます。さて、あなたの関数の入力を変更して、それらの引数を解凍して処理できるようにします。