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

相关内容

热门资讯

wpk ai辅助!wPk的确真... wpk ai辅助!wPk的确真的有挂,wpK的确真的有挂,2025新版(有挂黑科技);1、下载好wp...
WePoKe透明挂!wepko... WePoKe透明挂!wepkoe有外 挂,WepokE的确是有挂的,细节方法(有挂方法);原来确实真...
德州之星辅助!德扑之星真破解套... 德州之星辅助!德扑之星真破解套路,菠萝德州切实有挂(详细ai辅助有用教程)是一款可以让一直输的玩家,...
wpk有辅助挂!wpk透视辅助... wpk有辅助挂!wpk透视辅助器(wpK)就是真的有挂-详细透视教程1.wpk ai辅助创建新账号,...
wepoke智能ai!wepo... wepoke智能ai!wepoke计算辅助,wepoke软件透明挂存在,微扑克教程(有挂脚本)1、许...
德州ai辅助软件!德州之星有外... 德州ai辅助软件!德州之星有外 挂,德州扑克切实存在有挂(详细猫腻教程);人气非常高,ai更新快且高...
wpk ai辅助(wpK)wp... wpk ai辅助(wpK)wpk微扑克辅助(透视)一直真的有挂(分享教程)1、下载好微扑克辅助软件之...
WePoKe透明挂!wepok... WePoKe透明挂!wepoke美元局稳,wEpOke原来真的有挂,细节揭秘(有挂规律);支持2-1...
德州之星插件!德州辅助软件开发... 德州之星插件!德州辅助软件开发定制,云扑克德州本来是有挂(详细辅助挂教程)1、每一步都需要思考,不同...
wpk透视辅助工具!wpk数据... wpk透视辅助工具!wpk数据透视(WPk)一贯真的有挂-详细辅助挂教程;1、点击下载安装,wpk插...