프로세스가 파이썬 다중 처리 풀에서 멈출 수 없습니다.

Question

파이썬 다중 처리를 사용하는 프로그램이 있습니다. 주 프로그램에서 생성 된 모든 프로세스가 완료 될 수 있지만 주 프로그램은 항상 반환 값을 기다리고 중지 할 수 없음을 발견했습니다. 아무도 나 에게이 문제를 해결하는 방법에 대한 몇 가지 제안을 줄 수 있습니까? 다음

코드 단편

입니다

메인 프로그램 : I는 모든 "서브 기능을 수행"출력을 볼 수

# doing some other jobs 
result = {.....} # a large dictionary 
print 'done with sub functions' 
return result # if I change it to "return 1", it can finish successfully 

workers = multiprocessing.Pool(4) 
args = [arg1, arg2, arg3, arg4] 
results = workers.map(subfunc, args) 
print "we are in main functions " 

subfunc (* ARG) main에서 생성 된 프로세스이지만 "우리는 주요 기능에 있습니다"출력이 없습니다. 아무도 내가 문제를 알 수있게 도와 줄 수 있니?

Answer 1

subfunc이 결과를 반환 한 후에도 하위 프로세스는 결과를 피킹하고 프로세스 간 통신을 통해 마스터 프로세스에 보내야합니다. 그래서 그들은 서브 프로세스가 실제로 종료 준비가되기 전에 "done"을 인쇄하고 있습니다.

"fake"을 반환하여 문제가 없는지 확인한 다음 결과를 프로세스간에보다 신속하게 전달할 수있는 방법에 대해 생각해보십시오. 예를 들어, 목록의 내용에 따라 내용을보다 엄격한 형식으로 패키지화 할 수 있거나 공유 메모리가 실행 가능한 옵션 일 수 있습니다.