在异步任务之间自由切换的正确方法是什么?

正如在注释中提到的,通常异步协同路由会自动挂起那些将阻塞或休眠在等效同步咖啡中的调用。在您的例子中,协程是CPU受限的,因此等待阻塞调用是不够的,它需要偶尔将控制权交给事件循环,以允许系统的其余部分运行。

await asyncio.sleep(0) 为此,我将 work as intended ,它确实带来了风险:睡眠太频繁,并且通过不必要的切换来降低计算速度;睡眠太少,并且在单个协同进程中花费太多时间,从而占用了事件循环。

asyncio提供的解决方案是使用 run_in_executor . 等待它将自动暂停协程,直到CPU密集型任务完成,而不需要任何中间轮询。例如:

import asyncio

def do(id, amount):
    for i in range(amount):
        # Do some time-expensive work
        print(f'{id}: has done {i}')

    return f'{id}: done'

async def main():
    loop = asyncio.get_event_loop()
    res = await asyncio.gather(
        loop.run_in_executor(None, do, 'Task1', 5),
        loop.run_in_executor(None, do, 'Task2', 3))
    print(*res, sep='\n')

loop = asyncio.get_event_loop()
loop.run_until_complete(main())