如何在后台运行任务直到用户输入？

Question

我来自 .NET 背景，但我注意到 asyncio 的行为与 .NET 中的 async 和 await 不同：

我正在努力实现以下目标：

1. 启动一项计算任务 (a)
2. 启动一个等待用户输入退出的任务 (b)
3. 等待任务b（用户已退出）
4. 取消任务a

以下根本不执行任务a：

processing = asyncio.create_task(do_processing())

user_finished = asyncio.create_task(stdin_listener())

await user_finished

processing.cancel()

我理解的原因是因为从未等待processing，但是如果我等待此任务，它将永远不会返回，因为它永远不会到达cancel()。

我浏览了文档，但找不到这个简单的示例，或者无法将其拼凑在一起。只是对这个API不熟悉，请赐教。

编辑： 我发现上面的任务处理是正确的。但是，在方法@​​987654332@ 中，我调用了：

input("Press Q to quit\n")

这是阻塞的。我将研究此调用的其他方法。

Answer 1

我决定使用 SIGINT 来平仓：

exiting = False


        async def do_processing():
            global exiting
            while not exiting:
                await asyncio.sleep(1)
                # do processing here


        def handler(signal_received, frame):
            global exiting
            # Handle any cleanup here
            print('SIGINT or CTRL-C detected. Exiting gracefully')
            exiting = True

        signal(SIGINT, handler)

        await asyncio.create_task(do_processing())

        # post processing

进一步解释的链接： https://www.devdungeon.com/content/python-catch-sigint-ctrl-c