from multiprocessing import Process, Queue, current_process
from time import sleep
#проверяю есть ли в списке живые процессы
def is_alive(processes):
    for process in processes:
        if process.is_alive():
            return True
#пишу в очередь
def worker_write(q):
    for i in xrange(1000):
        q.put({"key1": 'test', 'key2': 'test', 'key3': 'test'})
    print(current_process().name + ' -> End.')
raw = Queue()
pr = []
for i in xrange(2):
    process = Process(target=worker_write, args=(raw,))
    process.start()
    pr.append(process)
while is_alive(pr):
    sleep(1)

for i in xrange(1)

for i in xrange(2)

from multiprocessing import Process, Queue, current_process
 
def worker_write(q):
    for i in xrange(1000):
        q.put({"key1": 'test', 'key2': 'test', 'key3': 'test'})
    q.put(None)
    print(current_process().name + ' -> End.')
 
if __name__ == '__main__':
    results = Queue()
    pr = []
    num_workers = 2
    for i in xrange(num_workers):
        process = Process(target=worker_write, args=(results,))
        process.start()
        pr.append(process)
    
    while num_workers:
        item = results.get()
        if item is None:
            num_workers -= 1
    for process in pr:
        process.join()