concurrency3.py

from multiprocessing import Process

def multithread_scheduler(instances: int, worker: Callable, args: List[Any]) -> None:
    threads = [
        Thread(target=worker, args=args) 
        for _ in range(instances)
    ]
    
    for thread in threads:
        thread.start()
    
    for thread in threads:
        thread.join()

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

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