풀 및 다중 처리를 사용하여 두 개의 목록에 동시에 두 개의 함수 적용

Question

남성 및 여성 에이전트가있는 (큰) 목록이 있습니다.

서로 다른 기능을 적용하고 싶습니다.

그런 경우 어떻게 풀을 사용할 수 있습니까? 에이전트는 서로 독립적이라는 것을 감안할 때.

예제는 다음과 같습니다

from multiprocessing import Pool 
p = Pool(processes=2) 
p.map() # Here is the problem 

내가 좋아하는 뭔가하고 싶은 :

males = ['a', 'b', 'c'] 
females = ['d', 'e', 'f'] 
for m in males: 
    func_m(m) 
for f in females: 
    func_f(f) 

내가 그렇게 시작

p.ZIP(func_f for f in females, func_m for m in males) # pseudocode 

Answer 1

map_async을 사용하여 계산을 비동기 적으로 시작할 수 있습니다. 이렇게하면 필요한 모든 작업이 시작되고 결과에 get 메서드를 사용하여 단일 목록에서 해당 작업을 수집 할 수 있습니다.

from multiprocessing import Pool 

pool = Pool(4) 
res_male = pool.map_async(func_m, males) 
res_females = pool.map_async(fun_f, females) 

res = res_male.get() 
res.extend(res_females.get()) 

또한 계산 이런 종류의 직관적 인 현대 concurrent.futures API에 볼 수 있었다.

Answer 2

안 좋은 대답을하지만, 마음에 드는 것 :

import itertools 
f = lambda t: func_m(t[0]) if t[1] else func_f(t[0]) 
p.map(f, itertools.chain(((0,x) for x in females), ((1,x) for x in males)))