python asyncio任务调度与取消的核心是task生命周期、事件循环协作及安全中断协程：create_task()自动注册并调度任务；cancel()抛出cancellederror需协程响应；需用gather/wait_for等批量管理，避免忽略异常、finally中误await、子任务未联动取消等陷阱。
Python asyncio 中的任务调度和取消，核心在于理解 asyncio.Task 的生命周期、事件循环的协作机制，以及如何安全地中断正在运行的协程。
任务创建与自动调度
调用 asyncio.create_task() 会立即把协程包装为 Task 对象，并将其注册到当前事件循环中，进入“待执行”（pending）状态。事件循环在下一次轮询时自动调度它——无需手动触发。
- 推荐始终使用
create_task()而非ensure_future()，语义更清晰，且明确绑定到当前 loop - 直接
await coro不会创建 task，是同步等待；只有显式创建 task 才实现真正并发 - 未被 await 或未被加入事件循环的 task 不会运行，也不会自动清理
主动取消任务的正确方式
调用 task.cancel() 并不会立刻终止协程，而是向其抛出 CancelledError 异常。协程需在可中断点（如 await 表达式）响应并退出，否则会继续执行直到下一个挂起点。
- 取消后应
await task或调用task.exception()来确保异常被处理，避免 “unhandled exception” 警告 - 若协程内部捕获了
CancelledError却没重新抛出，取消将失效（常见于错误的 try/except 块） - 长时间计算型代码（无 await）无法被取消，需主动插入
await asyncio.sleep(0)提供中断机会
批量管理与超时控制
实际项目中很少单独操作单个 task，更多是分组调度、统一取消或设置超时。
立即学习“Python免费学习笔记（深入）”；
- 用
asyncio.gather(*tasks, return_exceptions=True)并发运行多个 task，支持统一取消和异常聚合 -
asyncio.wait_for(coro, timeout)可对单个协程设超时，超时后自动取消对应 task - 用
asyncio.all_tasks()获取当前所有活跃 task，配合asyncio.current_task()排查泄漏或调试调度逻辑
避免常见陷阱
任务管理出问题，往往不是 API 用错，而是忽略了异步的协作本质。
- 不要在非 async 函数里调用
create_task()后就丢弃引用——task 可能运行失败却无人捕获异常 - 不要在 finally 块里 await 其他协程，除非确认不会引发新的取消链（容易导致死锁或异常传播混乱）
- 取消一个 task 后，它的子 task 不会自动取消，需手动追踪或使用结构化并发（如
anyio或 Python 3.11+ 的asyncio.TaskGroup）
