超时后返回多处理中已完成的任务值- python

import concurrent.futures
import time

def task_function(task_id):
    # 模拟任务执行时间
    time.sleep(2)
    return f"Task {task_id} completed"

def run_tasks_with_timeout(tasks, timeout):
    results = {}
    with concurrent.futures.ThreadPoolExecutor() as executor:
        future_to_task = {executor.submit(task_function, task): task for task in tasks}
        for future in concurrent.futures.as_completed(future_to_task, timeout=timeout):
            task = future_to_task[future]
            try:
                result = future.result()
                results[task] = result
            except Exception as exc:
                results[task] = f"Task {task} generated an exception: {exc}"
    return results

# 示例任务列表
tasks = [1, 2, 3]

# 设置超时时间为1秒
results = run_tasks_with_timeout(tasks, timeout=1)

for task, result in results.items():
    print(f"Task {task}: {result}")