Python example thread pool executor

tp_exec.py

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


def task():
    sleep_time = randint(1, 10)
    print(f'sleeping {sleep_time}')
    sleep(sleep_time)
    return 5 * 5


def task_master(arr):
    total = 0
    with ThreadPoolExecutor() as executor:
        for future in as_completed([executor.submit(func) for func in arr]):
            total += future.result()
    return total


if __name__ == '__main__':
    res = task_master([task, task, task, task])
    print(res)