如何使用ThreadPoolExecutor跟踪输入参数和结果

import concurrent.futures

class TrackedTask:
    def __init__(self, func, *args, **kwargs):
        self.func = func
        self.args = args
        self.kwargs = kwargs
        self.result = None

    def __call__(self):
        self.result = self.func(*self.args, **self.kwargs)

def track_input_result(func):
    def wrapper(*args, **kwargs):
        task = TrackedTask(func, *args, **kwargs)
        return task
    return wrapper

# 创建线程池
executor = concurrent.futures.ThreadPoolExecutor()

# 使用装饰器跟踪输入参数和结果
@track_input_result
def my_task(param1, param2):
    # 执行任务逻辑
    result = param1 + param2
    return result

# 提交任务到线程池
task = executor.submit(my_task, 1, 2)

# 获取任务的结果
result = task.result()

# 输出结果
print(result)