使用名称取消异步任务

import threading
import time

class TaskManager:
    def __init__(self):
        self.tasks = {}

    def register_task(self, name, task_func):
        thread = threading.Thread(target=task_func)
        thread.start()
        self.tasks[name] = thread

    def cancel_task(self, name):
        if name in self.tasks:
            thread = self.tasks[name]
            # 发送取消信号
            thread.cancel()
            del self.tasks[name]

# 示例任务函数
def example_task(name):
    print(f"Task {name} started")
    try:
        for i in range(5):
            time.sleep(1)
            print(f"Task {name} working... {i+1}/5")
    except threading.ThreadError:
        print(f"Task {name} cancelled")

# 创建任务管理器
task_manager = TaskManager()

# 注册任务
task_manager.register_task("Task1", lambda: example_task("Task1"))
task_manager.register_task("Task2", lambda: example_task("Task2"))

# 取消任务
time.sleep(2)
task_manager.cancel_task("Task1")