Simple demo of processes with queues to drive control.

mp_demo.py

import multiprocessing as mp

def do_run(i: int, q: mp.Queue):
    while True:
        item = q.get()
        if item is None:  # Sentinel.
            return
        print(i, item)


COUNT = 4
qs = [mp.Queue() for _ in range(COUNT)]
ps = [mp.Process(target=do_run, args=(i, q)) for i, q in enumerate(qs)]
for p in ps: p.start()
for i in range(12):
    qs[i%COUNT].put(i)
for p, q in zip(ps, qs):
    q.put(None)
    p.join()
print('Done!')

single_producer_multi_consumer.py

import multiprocessing as mp

def do_run(i: int, q: mp.Queue):
    while True:
        item = q.get()
        if item is None:  # Sentinel.
            return
        print(i, item)


COUNT = 4
q = mp.Queue()
ps = [mp.Process(target=do_run, args=(i, q)) for i in range(COUNT)]
for p in ps: p.start()
for i in range(12):
    q.put(i)

# Technically this is probably not guaranteed to terminate; e.g. one process
# could be fastest and starve all the others out.
for p in ps:
    while p.is_alive():
        q.put(None)
    p.join()
print('Done!')