Task是asyncio中对协程的封装，用于并发调度和管理。通过asyncio.create_task()创建后自动运行，支持状态查询、结果获取、取消操作及回调绑定，并可结合gather()实现多任务并发执行。
在 Python 中，Task 是对协程的封装，用于实现并发执行。它由 asyncio 库提供，允许你将一个协程调度到事件循环中运行，并对其进行管理，比如追踪执行状态、取消任务等。
Task 的作用与创建方式
Task 包装一个协程，使其自动加入事件循环，在后台运行。相比直接 await 协程，Task 可以并发启动多个任务而不阻塞。
使用 asyncio.create_task() 来创建 Task：
该函数接收一个协程对象并返回一个 Task 实例Task 一旦创建，就会被自动调度执行适合在主函数中并发启动多个异步操作
AI封面生成器
专业的AI封面生成工具，支持小红书、公众号、小说、红包、视频封面等多种类型，一键生成高质量封面图片。
108 查看详情
立即学习“Python免费学习笔记（深入）”；
import asyncioasync def say_hello(delay, msg):await asyncio.sleep(delay)print(msg)
async def main():
创建两个任务，并发执行
task1 = asyncio.create_task(say_hello(1, "Hello"))task2 = asyncio.create_task(say_hello(2, "World"))# 等待任务完成await task1await task2asyncio.run(main())
Task 的状态与控制
Task 提供了多种方法来检查和控制协程的执行过程。
task.done()：判断任务是否已完成task.result()：获取任务返回值（需任务已完成）task.cancel()：主动取消任务task.add_done_callback(callback)：任务完成后调用回调函数立即学习“Python免费学习笔记（深入）”；
async def slow_task(): await asyncio.sleep(2) return "完成"async def main():task = asyncio.create_task(slow_task())
# 可以检查状态print("任务完成了吗？", task.done()) # Falseresult = await taskprint("结果：", result)print("任务完成了吗？", task.done()) # True并发等待多个 Task
可以使用
asyncio.gather()或asyncio.wait()同时处理多个 Task。
gather()更常用，能按顺序返回结果wait()返回完成和未完成的任务集合立即学习“Python免费学习笔记（深入）”；
async def main(): tasks = [ asyncio.create_task(say_hello(1, "A")), asyncio.create_task(say_hello(2, "B")), ]await asyncio.gather(*tasks)基本上就这些。Task 让协程不只是“可等待对象”，而是可调度、可管理的执行单元，是构建高效异步程序的核心工具。
以上就是python中Task封装协程的详细内容，更多请关注php中文网其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/614803.html
微信扫一扫 
支付宝扫一扫 
