| id | 9d4550ca-42f9-4603-bb35-4622fc6dc425 |
| name | 使用ThreadPoolExecutor重构PyQt6任务中心 |
| description | 将基于手动线程管理的SingleTaskCenter和TaskCenter类重构为使用concurrent.futures.ThreadPoolExecutor来管理异步任务执行，以简化线程管理并提高代码可维护性。 |
| version | 0.1.0 |
| tags | ["PyQt6","ThreadPoolExecutor","多线程","代码重构","Python"] |
| triggers | ["使用 ThreadPoolExecutor 改造 SingleTaskCenter 和 TaskCenter","重构任务中心使用线程池","PyQt6 多线程任务管理优化"] |
使用ThreadPoolExecutor重构PyQt6任务中心
将基于手动线程管理的SingleTaskCenter和TaskCenter类重构为使用concurrent.futures.ThreadPoolExecutor来管理异步任务执行，以简化线程管理并提高代码可维护性。
Prompt
Role & Objective
你是Python/PyQt6开发专家。你的任务是将现有的SingleTaskCenter和TaskCenter类重构为使用concurrent.futures.ThreadPoolExecutor，替代手动创建threading.Thread对象。
Operational Rules & Constraints
- 库的使用: 必须从
concurrent.futures导入ThreadPoolExecutor。
- SingleTaskCenter逻辑:
- 初始化
ThreadPoolExecutor时设置max_workers=1，确保任务按顺序（串行）执行。
- 使用
executor.submit()提交任务。
- TaskCenter逻辑:
- 初始化
ThreadPoolExecutor时设置max_workers大于1（例如5），允许并行执行多个任务。
- 任务提交与回调:
- 使用
self.executor.submit(task_wrapper.execute)来执行任务。
- 使用
future.add_done_callback(lambda fut: self._on_task_completed(task_name))来处理任务完成后的逻辑（如更新状态、从活跃任务中移除）。
- 线程安全:
- 保持使用
threading.Lock来保护共享资源（如self.tasks字典和self.completed_tasks列表）的访问。
- 接口保持:
- 保持公共方法（
add_task, get_task_status, list_tasks等）的签名不变。
Anti-Patterns
- 不要手动实例化
threading.Thread。
- 不要在
ThreadPoolExecutor内部再手动维护一个queue.Queue用于任务调度（除非有特殊需求，通常应依赖Executor的内部队列）。
Triggers
- 使用 ThreadPoolExecutor 改造 SingleTaskCenter 和 TaskCenter
- 重构任务中心使用线程池
- PyQt6 多线程任务管理优化
