multiprocessing with a queue and pool

mp.py

// https://stackoverflow.com/questions/17241663/filling-a-queue-and-managing-multiprocessing-in-python
import time
import os
import multiprocessing as mp
from multiprocessing import Queue, Pool

the_queue = Queue()

def worker_main(queue):
    print(f"{os.getpid()} working")
    while True:
        item = queue.get(True)
        print(f"{os.getpid()} got {item}")
        time.sleep(1) # simulate a "long" operation

the_pool = Pool(3, worker_main,(the_queue,))
#                           don't forget the comma here  ^

for i in range(5):
    the_queue.put("hello")
    the_queue.put("world")

time.sleep(10)