Process Pool Executor

processpoolexecutor.py

from concurrent.futures import ProcessPoolExecutor, as_completed
from time import sleep
from random import randint

def take_sometime(number):
    sleep(randint(1, 5))
    return f'Return of {number}'

executor = ProcessPoolExecutor(max_workers=5)
futures = []
for i in range(5):
    futures.append(executor.submit(take_sometime, i))

for i in as_completed(futures):
    print(i.result())