如何在服务结构中使用“执行器重建器”机制来调度任务？

import concurrent.futures
import time

class ExecutorRebuilder:
    def __init__(self, max_workers=5):
        self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=max_workers)
        self.tasks = []

    def submit_task(self, task_func, *args, **kwargs):
        future = self.executor.submit(task_func, *args, **kwargs)
        self.tasks.append(future)

    def rebuild_executor(self):
        self.executor.shutdown(wait=True)
        self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=len(self.tasks))

    def wait_for_completion(self):
        concurrent.futures.wait(self.tasks)

def example_task(task_id):
    print(f"Task {task_id} started")
    time.sleep(2)
    print(f"Task {task_id} completed")

if __name__ == "__main__":
    rebuilder = ExecutorRebuilder()

    for i in range(10):
        rebuilder.submit_task(example_task, i)

    # Simulate executor rebuild
    time.sleep(5)
    rebuilder.rebuild_executor()

    rebuilder.wait_for_completion()