thread_pool_test.py

import subprocess
from concurrent.futures import ThreadPoolExecutor, as_completed


def invoke_command():
    subprocess.run(["sleep", "5"])
    print("done")


def main():
    params = list(range(3))
    with ThreadPoolExecutor(max_workers=5) as executor:
        f = executor.map(
            lambda f: invoke_command(), params, timeout=600
        )
        as_completed(f)


if __name__ == '__main__':
    main()