Example for concurrent.futures

main.py

import os
import threading
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
from time import sleep

def writer(value):
    sleep(1)
    print("PID={}, ThreadID={}: {}".format(os.getpid(), threading.get_ident(), value))


def main():
    # executor_class = ThreadPoolExecutor
    executor_class = ProcessPoolExecutor
    executor = executor_class(max_workers=3)
    tasks = []
    print("--start--")
    for i in range(10):
        tasks.append(executor.submit(writer, i))
    while not all([t.done() for t in tasks]):
        sleep(0.1)
    print("--done--")

if __name__ == '__main__':
    main()