파이썬 : 맵 및 다중 처리 사용

Question

두 개의 인수를 취하여 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

다중 프로세스 풀 모듈은 다중 처리 할 인수 목록을 가져와 하나의 인수 만 지원합니다. 당신은 다음을 수행하여이 문제를 해결할 수 있습니다

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() 

내가 여기했던 당신이 입력으로 원하는 두 개의 인수되는 각 요소 목록으로이 반복 가능 객체를 압축 무엇. 자, 함수의 입력을 변경하여 처리 할 수 ​​있도록 인수를 푸십시오.