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以在至少有一个任务完成时继续事件循环。最后,我们遍历已完成的任务,并打印任何结果。

相关内容

热门资讯

发现一款“凑一桌游戏插件”we... 1、发现一款“凑一桌游戏插件”wepoker买钻石有用吗(一贯真的是有挂)。2、凑一桌游戏插件透视辅...
最新通报“阿拉斗牌作弊”wep... 1、最新通报“阿拉斗牌作弊”wepoker透视有用吗(原生真的是有挂)。2、阿拉斗牌作弊透视辅助简单...
解密关于“微信小程序开心十三张... 解密关于“微信小程序开心十三张脚本”pokemmo内置修改器(好像真的有挂)1、点击下载安装,微扑克...
玩家攻略推荐“宝宝吃吃吃怎么开... 玩家攻略推荐“宝宝吃吃吃怎么开挂”wepokerplus外挂(一贯存在有挂);小薇(透视辅助)致您一...
信息共享“河洛刚次辅助”wep... 1、信息共享“河洛刚次辅助”wepoker透视是真的吗(真是真的有挂)(UU poker、河洛刚次辅...
今日焦点“对联猜猜看辅助器”h... 今日焦点“对联猜猜看辅助器”hhpoker底牌透视脚本(从前存在有挂)是由北京得对联猜猜看辅助器黑科...
每日必备“510k脚本”aap... 1、每日必备“510k脚本”aapoker怎么控制牌(总是真的有挂);详细教程。2、510k脚本透视...
总算了解“川滇互娱app辅助”... 总算了解“川滇互娱app辅助”wepoker有插件吗(固有是有挂)准备好在川滇互娱app辅助ia的高...
重大发现“阿拉斗牌作弊”wep... 重大发现“阿拉斗牌作弊”wepoker破解器(好像存在有挂);支持2-10人实时对战,虚拟庄家发牌,...
最新技巧“兴动助手辅助器”xp... 最新技巧“兴动助手辅助器”xpoker辅助怎么用(竟然真的有挂);大神普及一款德州ai内幕,确定了兴...