async Python3 code using blocking-function

async_threadpool_blocking_fn.py

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

TPOOL_SIZE = 8


def blocking(pid):
    """ a non-deterministic "blocking" ? task
    """
    sleep_for = random.randint(0, 3) * 0.001
    time.sleep(sleep_for)
    return pid, sleep_for


def main():
    pool = ThreadPoolExecutor(TPOOL_SIZE)
    futures = []

    for pid in range(TPOOL_SIZE):
        futures.append(pool.submit(blocking, pid))

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


if __name__ == "__main__":
    main()