asyncio的核心是“不阻塞”而非“快”,通过事件循环调度awaitable对象(协程、Task、Future)实现高并发I/O;误用同步调用、漏await任务、混用同步/异步队列是常见陷阱。

asyncio 的核心不是“快”,而是“不阻塞”——它不会让你的单个请求变快,但能让成百上千个 I/O 等待任务共享一个线程而不互相卡住。
为什么 await 后面必须是可等待对象(awaitable)?
因为 await 实际上是把控制权交还给事件循环,而事件循环只认三类东西:coroutine、Task、Future。传入普通函数或 int 会直接报 TypeError: object X can't be used in 'await' expression。
- 常见误用:
await time.sleep(1)→ 应改用await asyncio.sleep(1) - 自定义 awaitable:只要实现
__await__方法并返回迭代器即可,不一定非得是async def定义的协程 -
requests.get()不能直接 await —— 它是同步阻塞调用,必须用loop.run_in_executor包装,或换aiohttp
asyncio.create_task() 和直接 await 的区别在哪?
前者把协程调度为并发任务,后者是顺序等待。关键差异在执行时机和生命周期管理:
- 直接
await func():当前协程暂停,等func执行完才继续,串行 -
task = asyncio.create_task(func()):立刻提交到事件循环,当前协程可继续跑别的逻辑;task 独立存活,即使创建它的协程结束了,task 默认仍运行(除非被 cancel) - 漏掉
await task或没加asyncio.gather()收集,会导致 task 被丢弃且无报错——这是最常被忽略的资源泄漏点
实战中 asyncio.Queue 比 queue.Queue 多了什么?
asyncio.Queue 是为协程设计的线程/任务安全队列,所有操作(put、get)都原生支持 await,且内置了协程级阻塞语义:
立即学习“Python免费学习笔记(深入)”;
-
await q.get()在空时自动挂起当前协程,而不是忙等或抛异常 -
await q.put(item)在满时自动等待空间释放(如果设了maxsize) - 不能混用:
q.put_nowait()是同步非阻塞,但若队列满会直接抛asyncio.QueueFull;而queue.Queue.put_nowait()属于线程模块,不能在协程里安全调用
import asyncioasync def worker(q: asyncio.Queue): while True: item = await q.get() print(f"处理: {item}") q.task_done()
async def main(): q = asyncio.Queue(maxsize=2)
启动消费者
asyncio.create_task(worker(q)) # 生产者 for i in range(5): await q.put(f"job-{i}") # 自动等待空位 await q.join() # 等所有 task_done()真正难的从来不是写
async def,而是判断哪些 IO 调用天然不支持协程、哪些第三方库只是“假装异步”、以及什么时候该用run_in_executor而不是硬改同步逻辑。这些边界问题,文档不讲,报错也不明说。










