파이썬 AsyncResult.successful() 반환하지 않습니다

Question

나는 파이썬 다중 처리에 내 손을 노력하고 있어요. 나는 서로 독립적 인 두 개의 프로세스를 병렬로 실행하고 프로세스가 성공했는지 또는 ApplyAsync.successful() 유틸리티를 사용하지 않았는지 확인을 반환합니다. 그러나 내 서브 프로세스에 대한 콜백에서 성공적으로 호출하면 스크립트가 중단됩니다.

import multiprocessing as mp 
import time 

result_map = {} 

def foo_pool(x): 
    time.sleep(2) 
    print x 
    return x 


result_list = [] 
def log_result(result): 
    print result_map[result].successful() #hangs                        
    result_list.append(result) 


def apply_async_with_callback(): 
    pool = mp.Pool() 
    for i in range(10): 
     result_map[i] = pool.apply_async(foo_pool, args = (i,), callback = log_result) 

    pool.close() 
    pool.join() 

    print(result_list) 



if __name__ == '__main__': 
    apply_async_with_callback() 

Answer 1

당신은 결과가 성공적 일 때 콜백 만 호출되기 때문에 successful()을 확인 할 필요가 없습니다.

def _set(self, i, obj): 
    self._success, self._value = obj 
    if self._callback and self._success: # <----- 
     self._callback(self._value)  # <----- 
    self._cond.acquire() 
    try: 
     self._ready = True 
     self._cond.notify() 
    finally: 
     self._cond.release() 
    del self._cache[self._job]