asyncio-多次等待协程（定期任务）

Question

我正在尝试为asyncio事件循环创建一个定期任务，如下所示，但是我遇到了“ RuntimeError：无法重用已经等待的协程”异常。显然，asyncio不允许等待与该bug线程中讨论的相同的等待功能。这是我尝试实现的方法：import asyncio    class AsyncEventLoop:        def __init__(self):        self._loop = asyncio.get_event_loop()    def add_periodic_task(self, async_func, interval):        async def wrapper(_async_func, _interval):            while True:                await _async_func               # This is where it goes wrong                await asyncio.sleep(_interval)        self._loop.create_task(wrapper(async_func, interval))        return    def start(self):        self._loop.run_forever()        return由于我的while循环，相同的等待函数（_async_func）将在它们之间的睡眠间隔内执行。我如何从asyncio定期执行功能中获得了执行定期任务的灵感？ 。从上面提到的错误线程中，我推断出RuntimeError背后的想法是，使开发人员不会意外地等待相同的协程两次或多次，因为协程将被标记为完成，并且产生None而不是结果。有没有办法我可以多次等待相同的功能？

Answer 1

似乎您在将异步函数（协程函数）与协程（这些异步函数产生的值）混淆了。

考虑以下异步功能：

async def sample():

    await asyncio.sleep(3.14)

您正在传递其呼叫的结果：add_periodic_task(sample(), 5)。

相反，您应该传递异步函数对象本身：add_periodic_task(sample, 5)，并在包装器中调用它：

while True:

    await _async_func()

    await asyncio.sleep(_interval)