如何在非asyncio感知代码的回调中处理asyncio事件？

由于foo是同步封装函数，在主线程调用bar时，asyncio事件循环处于阻塞状态（被foo的同步逻辑占据）。要处理其他线程投递到主线程事件循环的事件，需要在bar中手动触发事件循环处理待处理的回调任务。

方法1：触发单次事件循环切换（安全通用） #

通过让事件循环运行一个立即完成的协程，触发一次事件处理迭代，处理所有就绪的回调：

import asyncio

def bar():
    loop = asyncio.get_running_loop()
    # 运行sleep(0)协程，迫使事件循环处理就绪任务
    loop.run_until_complete(asyncio.sleep(0))

asyncio.sleep(0)会触发事件循环切换上下文，处理所有已通过loop.call_soon_threadsafe投递的事件，这是最稳妥的通用方式。

方法2：批量处理所有积压事件（高效） #

如果需要一次性处理所有积压的事件，可以直接驱动事件循环完成多次迭代，直到无待处理任务或超时：

import asyncio
import time

def bar():
    loop = asyncio.get_running_loop()
    while True:
        start = time.monotonic()
        # 执行一次事件循环迭代
        loop._run_once()
        # 检查是否还有待处理任务，或避免死循环超时退出
        if not loop._ready and loop._selector.select(0) is None:
            break
        if time.monotonic() - start > 0.01:
            break

_run_once是CPython asyncio实现的半私有方法，会处理一轮事件循环的所有就绪任务，适合需要清空事件队列的场景。

之前尝试失败的原因 #

你之前的代码直接调用asyncio.sleep(0)或asyncio.gather(*asyncio.all_tasks())，但这些函数返回的是协程对象，并不会自动被事件循环执行。必须通过loop.run_until_complete()让事件循环实际调度并执行这些协程，才能触发事件处理逻辑。

内容的提问来源于stack exchange，提问作者kostrykin