전문가를 위한 파이썬(2판)

810

4

부

제어 흐름

results.put(PrimeResult(0, False, 0.0)) ❿

def start_jobs(

procs: int, jobs: JobQueue, results: ResultQueue ⓫

) -> None:

for n in NUMBERS:

jobs.put(n) ⓬

for _ in range(procs):

proc = Process(target=worker, args=(jobs, results)) ⓭

proc.start() ⓮

jobs.put(0) ⓯

❶

threading

을 모방하기 위해

multiprocessing

은

multiprocessing

.

SimpleQueue

를 제공하지

만, 이 메서드는 더 하위 수준인

BaseContext

클래스에 미리 정의된 인스턴스에 바인딩되었다. 우리는

SimpleQueue

를 호출해야 하지만, 자료형 힌트에는 사용할 수 없다.

❷ 자료형 힌트에 필요한

SimpleQueue

는

multiprocessing

.

queues

에 있다.

❸ 소수인지 검사할 숫자는

PrimeResult

에 있다.

n

과 여러 결과 필드를 함께 모아 놓으면 나중에 결과를

간단히 출력할 수 있다.

❹ 작업을 수행할 프로세스들에

main

()

함수(예제

19

-

14

)가 숫자를 전달하는 데 사용할

SimpleQueue

의 별칭이다.

❺

main ...