multi_thread.py

import concurrent.futures

from tqdm import tqdm

import random
import time

def run_on_thread_example(packed_args):
    arg_one, arg_two = packed_args

    time.sleep(int(random.random() * 2))
    result = arg_one * arg_two
    print(f"arg_one: {arg_one}, arg_two: {arg_two:.2f}, result: {result:.2f}")

    return {
        "index": arg_one,
        "result": result,
    }

if __name__ == "__main__":

    arg_list_one = [i for i in range(50)]
    arg_list_two = [random.random() for _ in range(len(arg_list_one))]

    with concurrent.futures.ThreadPoolExecutor() as executor:
        results = list(tqdm(executor.map(run_on_thread_example, zip(arg_list_one, arg_list_two)), total=len(arg_list_one)))

    print(results)