concurrency2.py

from multiprocessing import Process

def multiprocess_scheduler(instances: int, worker: Callable, args):
    processes = [
        Process(target=worker, args=args) 
        for _ in range(instances)
    ]
    
    for process in processes:
        process.start()
    
    for process in processes:
        process.join()        

print("Multiprocess Execution, CPU bound")
with timer():
    multiprocess_scheduler(8, cpu_worker, [10_000_000, 49])

print("Multiprocess Execution, I/O bound")
with timer():
    multiprocess_scheduler(8, io_worker, [3])