lesson02_num_threads.py

# SuperFastPython.com
# example of setting a large number number of workers
from time import sleep
from concurrent.futures import ThreadPoolExecutor

# custom task function executed in the thread pool
def task(number):
    # block for a moment
    sleep(1)
    # report a message
    if number % 100 == 0:
        print(f'>task {number} done')

# protect the entry point
if __name__ == '__main__':
    # create a thread pool
    with ThreadPoolExecutor(1000) as exe:
        # issue many tasks to the pool
        _ = exe.map(task, range(1000))