python  asyncio常规操作记录

while True:
    events = poll_for_ready_events()   # 检查就绪事件（IO完成、定时器到期、回调投递）
    for event in events:
        execute(event.callback)        # 逐个执行

async def main():
    task1 = asyncio.create_task(fetch_a())   # 立即调度，不等完成
    task2 = asyncio.create_task(fetch_b())   # 两个协程并发运行
    result_a = await task1                   # 需要结果时再 await
    result_b = await task2

async def main():
    # time.sleep 是同步阻塞的，直接调用会卡死整个 loop
    await asyncio.to_thread(time.sleep, 5)   # 丢到线程池，loop 继续处理别的
    # 典型场景：CPU 密集计算、没有 async 版本的阻塞 IO 库
    data = await asyncio.to_thread(read_big_file, path)

# 在非 asyncio 的普通线程中：
future = asyncio.run_coroutine_threadsafe(play_audio(data), main_loop)
result = future.result(timeout=10)   # 阻塞等待结果（在当前线程阻塞，不影响 loop）

loop.call_soon_threadsafe(callback, *args)

# 从 WebSocket 线程把音频流注册到主线程的 Mixer
self._main_loop.call_soon_threadsafe(mixer.add_stream, stream)

create_task              → 同 loop 内并发跑协程
to_thread                → 把同步阻塞的东西丢出去，别卡我的 loop
run_coroutine_threadsafe → 从外面往别人的 loop 里塞协程
call_soon_threadsafe     → 从外面往别人的 loop 里塞回调

主线程 event loop                     WebSocket 线程 event loop
┌───────────────────┐                ┌───────────────────┐
│  Mixer 协程        │                │  ws.recv() 协程 A  │
│  其他音频处理 ...   │  ◄── call_soon │  ws.recv() 协程 B  │
│                   │   threadsafe   │  ws.recv() 协程 C  │
└───────────────────┘                └───────────────────┘