병렬 처리 할 수 ​​있습니까?

Question

오일러 프로젝트 # 4에 대한 대답입니다.

회문수는 같은 방법으로 읽습니다. 2 자리 숫자 두 자리의 곱으로 만들어진 최대 회문은 9009 = 91 99입니다.

두 자리 3 자리 숫자의 곱으로 만들어진 최대 회 전기를 찾으십시오.

답변 :

906609 

코드는 :이 실행할 때

from multiprocessing import Pool 
from itertools import product 

def sym(lst): 
    rst=[] 
    for x,y in lst: 
     tmp=x*y 
     if rec(tmp): 
      rst.append(tmp) 
    return rst 

def rec(num): 
    num=str(num) 
    if num == "".join(reversed(num)): return True 
    else: return False 

if __name__ == "__main__": 
    pool=Pool(processes=8) 
    lst=product(xrange(100,1000),repeat=2) 
    rst=pool.map(sym,lst) 
    #rst=sym(lst) 
    print max(rst) 

:

# TypeError:'int' object is not iterable 

하지만 난 그것을 이해할 수 없다 ... 반복자를 나열하지 않습니다 ? 또는 내 코드에 오류가 있습니까?

Answer 1

문제는 sym입니다.

sym은 제품 반복 가능 제품의 첫 번째 요소로 전달됩니다. (예 : lst = (100,100)). 당신이 for 루프에 도착하면, 당신은 lst 반복하고 두 개의 숫자로 압축을 해제하려는 -에 해당 : 분명한 이유 실패

for x,y in (100,100): 
    ... 

합니다.

아마 for 루프를 모두 없애고 싶다고 생각합니다. 아마도 직렬 버전의 아티팩트 일 것입니다.

def sym(lst): 
    x,y=lst 
    tmp=x*y 
    if rec(tmp): 
     return tmp 
    else: 
     return None #max will ignore None values since None > x is always False. 

역 추적

다소 비밀이었다 - 분명히 역 추적 한 다음 다시 제기 가져옵니다 Pool에 반환됩니다 ...하지만 그것을 수행하는 방법은 추적하기가 조금 어렵습니다.

가끔 디버깅 할 때 Pool.map()을 일반 버전 map으로 바꾸는 것이 좋습니다. 그런 다음 발생하는 모든 예외가 주요 "스레드"에서 발생하며 추적 기능이 조금 더 쉽게 따라갈 수 있습니다.