asyncio.gather在调用者从STDIN请求输入时无法执行任务?
创始人
2024-09-21 05:30:22
0

这是由于asyncio.gather在等待所有任务完成时会阻塞事件循环,直到所有任务都完成后才能恢复事件循环。而在从STDIN请求输入时,事件循环在等待输入时也会被阻塞。因此,任务不会被执行直到输入完成。

为了解决这个问题,我们可以使用asyncio.wait()代替asyncio.gather()。这样,事件循环在等待结果时不会被阻塞,任务会被并发执行。

下面是示例代码,演示了如何使用asyncio.wait()来并发执行任务:

import asyncio

async def task1():
    print("Task 1 started")
    await asyncio.sleep(2)
    print("Task 1 completed")

async def task2():
    print("Task 2 started")
    await asyncio.sleep(1)
    print("Task 2 completed")

async def user_input():
    print("Enter something: ")
    result = await asyncio.get_event_loop().run_in_executor(None, input)
    print(f"You entered {result}")

async def main():
    tasks = [task1(), task2(), user_input()]
    done, _ = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
    # Print any results from completed tasks
    for task in done:
        print(task.result())

asyncio.run(main())

在这个例子中,我们创建了三个任务,两个休眠2秒和1秒,另一个等待用户输入。我们使用asyncio.wait()代替asyncio.gather()来并发执行这些任务。我们还使用了asyncio.run_in_executor()在子线程中运行input()函数,以避免阻塞事件循环。

我们将return_when参数设置为asyncio.FIRST_COMPLETED以在至少有一个任务完成时继续事件循环。最后,我们遍历已完成的任务,并打印任何结果。

相关内容

热门资讯

分享实测"闲来辅助神... 分享实测"闲来辅助神器"开挂(软件)辅助软件竟然有挂-解密教程 >>您好:软件加薇136704302...
透视有挂"广东雀神智... >>您好:广东雀神智能插件安装价格确实是有挂的,很多玩家在这款广东雀神智能插件安装价格游戏中打牌都会...
一分钟了解"微信小程... 一分钟了解"微信小程序途游辅助免费"开挂(插件)辅助插件有挂分享-力荐教程;无需打开直接搜索薇:13...
分享个大家"智星菠萝... 较多好评“微乐万能挂官网”开挂(透视)辅助教程 了解更多开挂安装加(136704302)微信号是一款...
教程攻略"德普辅助软... 教程攻略"德普辅助软件"开挂(平台)辅助平台有挂方法-技巧教程 了解更多开挂安装加(13670430...
重大通报"微信小程序... 重大通报"微信小程序辅助器"开挂(下载)辅助下载有挂方法-详细教程1、下载安装好微信小程序辅助器,进...
一秒答解"隶属茶苑苹... 隶属茶苑苹果手机辅助是一款可以让一直输的玩家,快速成为一个“必胜”的ai辅助神器,有需要的用户可以加...
一起来探讨"中至常熟... 中至常熟辅助开挂教程视频分享装挂详细步骤在当今的网络游戏中,中至常熟辅助作为一种经典的娱乐方式,吸引...
2024教程"广西老... 2024教程"广西老友麻将有挂吗"开挂(软件)辅助软件真是有挂-力荐教程;打开点击测试直接进入微信(...
总算了解"aapok... 总算了解"aapoker透视脚本"开挂(插件)辅助插件有挂详细-揭秘教程【无需打开直接搜索加薇136...