인프런 커뮤니티 질문&답변

- concurrent.futures.process.BrokenProcessPool: A process in the process pool was terminated abruptly while the future was running or pending.

 

아래 코드를 실행했을 때 위와 같은 에러가 발생합니다. 순차실행시는 정상 작동하고, 리스트를 5개정도 줄였을 때도 작동하였습니다. stackoverflow 등을 찾아봤지만 전혀 답을 찾을 수 없어서 올립니다. 위 오류의 원인과 해결책을 알려주시면 감사하겠습니다.

 

 

if __name__ == "__main__":
    worker = min(10, len(process_list))
    # 시작 시간
    start_tm = time.time()
    # Futures
    futures_list = []

    with ProcessPoolExecutor(max_workers=worker) as excutor:
        for process_item in process_list:
            # future 반환
            future = excutor.submit(CODE_EXEC, process_item)
            futures_list.append(future)
            print('Scheduled for {} : {}'.format(process_list, future))

        # as_completed 결과 출력
        for future in as_completed(futures_list):
            result = future.result()
            done = future.done()
            cancelled = future.cancelled

            # future 결과 확인
            print('Future Result : {}, Done : {}'.format(result, done))
            print('Future Cancelled : {}'.format(cancelled))