the_pool = multiprocessing.Pool(3, worker_main, (the_queue,))
for i in range(5):
    the_queue.put('hello')
the_queue.put('world')
time.sleep(10)
Заполнение очереди и управление многопроцессорностью в python