如何使用 asyncio 并永远运行该函数。我知道有 run_until_complete(function_name) 但如何使用 run_forever 如何调用异步函数？

async def someFunction():
    async with something as some_variable:
        # do something

我不确定如何启动该功能。

最佳答案

run_forever 并不意味着异步函数将神奇地永远运行，它意味着 loop 将永远运行，或者至少直到有人调用 loop .停止()。要从字面上永远运行一个异步函数，您需要创建一个执行此操作的异步函数。例如:

async def some_function():
    async with something as some_variable:
        # do something

async def forever():
    while True:
        await some_function()

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

这就是 run_forever() 不接受参数的原因，它不关心任何特定的协程。典型的模式是使用 loop.create_task 添加一些协程。或调用 run_forever() 之前的等价物。但即使是一个不运行任何任务并闲置的事件循环也很有用，因为另一个线程可以调用 asyncio.run_coroutine_threadsafe并给它工作。

https://stackoverflow.com/questions/50473113/