发布时间 - 2026-01-03 00:00:00 点击率：次

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

asyncio 的核心不是“快”，而是“不阻塞”——它不会让你的单个请求变快，但能让成百上千个 I/O 等待任务共享一个线程而不互相卡住。

因为 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

前者把协程调度为并发任务，后者是顺序等待。关键差异在执行时机和生命周期管理：

直接 await func()：当前协程暂停，等 func 执行完才继续，串行
task = asyncio.create_task(func())：立刻提交到事件循环，当前协程可继续跑别的逻辑；task 独立存活，即使创建它的协程结束了，task 默认仍运行（除非被 cancel）
漏掉 await task 或没加 asyncio.gather() 收集，会导致 task 被丢弃且无报错——这是最常被忽略的资源泄漏点

asyncio.Queue 是为协程设计的线程/任务安全队列，所有操作（put、get）都原生支持 await，且内置了协程级阻塞语义：

await q.get() 在空时自动挂起当前协程，而不是忙等或抛异常
await q.put(item) 在满时自动等待空间释放（如果设了 maxsize）
不能混用：q.put_nowait() 是同步非阻塞，但若队列满会直接抛 asyncio.QueueFull；而 queue.Queue.put_nowait() 属于线程模块，不能在协程里安全调用

import asyncio

async 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 而不是硬改同步逻辑。这些边界问题，文档不讲，报错也不明说。