Python的async/await是基于事件循环的协程机制,用于高并发I/O密集型任务;async def定义协程函数,await只能用于协程对象、Future或实现__await__的对象;需用asyncio.run()启动,用gather或create_task实现并发。

Python 的 async/await 是编写非阻塞 I/O 代码的核心机制,它不等于多线程或多进程,而是基于事件循环的协程调度,适合高并发、I/O 密集型任务(如网络请求、数据库查询、文件读写)。
普通函数加 async 前缀就变成协程函数,调用后返回一个协程对象,不会立即执行:
await 在另一个协程中调用,或通过事件循环运行(如 asyncio.run())await,会报 SyntaxError
async def fetch_data(): return await aiohttp.get(...);❌ 错误:def bad(): await fetch_data()
await 后面必须是以下三类之一:
async def 函数返回)asyncio.Future 或 concurrent.futures.Future(需用 asyncio.wrap_future)__await__ 方法的对象(如 asyncio.sleep()、aiohttp 的响应对象)常见错误:对普通函数、列表、字符串或同步库(如 requests.get)使用 await,会触发 TypeError: object XXX can't be used in 'await' expression。
立即学习“Python免费学习笔记(深入)”;
最简入口方式,自动创建并关闭事件循环:
asyncio.run(main()) 是推荐的顶层调用方式(Python 3.7+)loop.run_until_complete()(除非需要精细控制)asyncio.run() 每次调用都会新建事件循环,不可在已有运行中的循环内重复调用(比如 Jupyter 或某些 Web 框架中)避免串行等待,提升吞吐量:
await asyncio.gather(a(), b(), c()):并发启动并等待全部完成,返回结果列表task = asyncio.create_task(a()):提前“调度”协程,适合需要部分等待或条件取消的场景gather 更简洁;create_task 支持单独取消(task.cancel())、检查状态(task.done())例如发 10 个 HTTP 请求,用 gather 可让总耗时接近单个最慢请求,而非 10 倍相加。
不复杂但容易忽略:async/await 不会自动加速 CPU 密集型任务,这类场景仍需 loop.run_in_executor 或切换到 multiprocessing。
以上就是Python async await用法_Python怎么用async/await编写非阻塞代码的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号