Demo script to illustrate how multiprocessing.Pool.map is blocking

multiprocessing.py

import time
import multiprocessing


def delay_print(message):
    time.sleep(1)
    print(message)


for i in range(10):
    # multiprocessing.Pool.map is blocking.
    # The next iteration of the loop will not run until after all workers have completed their tasks.
    multiprocessing.Pool(1).map(delay_print, [i])