from concurrent.futures.thread import ThreadPoolExecutor from concurrent.futures import as_completed import random import time def print_time(data): t = random.randint(1, 10) time.sleep(t) print("start_%s" % data) print("============") return t data = [] for i in range(50): data.append(i) with ThreadPoolExecutor(10) as executor: future_list = [] for i in range(10): # future = executor.submit(print_time,data) future = executor.submit(print_time, {"name": 111, "id": 222}) future_list.append(future) for res in as_completed(future_list): # 这个futrure_list是你future对象的列表 print(res.result())