Python Asyncio： RuntimeEror：这个事件循环已经在运行

Question

我正在处理ayncio模块，在终止程序时遇到问题。我正在终端中运行我的程序，而Ctrl C无法停止正在运行的程序。但是，如果我关闭终端并再次尝试运行程序，我会遇到以下问题：

INFO:root:In main
ERROR:root:This event loop is already running

下面是我的示例代码以供理解。

# all_tasks.py

import asyncio
import logging
# module imports
import settings

#configure logging into a file
logging.basicConfig(filename=settings.LOG_FILENAME,level=logging.DEBUG)


class AsyncTest(object):

    async def taskOne(self):
        while True:
            print("Task One") # Print is just an example, I am doing lot of stuff inside.
            await asyncio.sleep(60)

    async def taskTwo(self):
        while True:
            print("Task Two") # Print is just an example, I am doing lot of stuff inside.
            await asyncio.sleep(60) 

    async def main(self):
        try:
            loop = asyncio.get_event_loop()
                tasks = [
                        asyncio.ensure_future(self.taskOne()),
                        asyncio.ensure_future(self.taskTwo()),
                        ]
            loop.run_until_complete(asyncio.wait(tasks))
        except RuntimeError as error:
            logging.info("In main")
            logging.error(error)

if __name__ == '__main__':
    asynctest = AsyncTest()
    asyncio.run(asynctest.main())

Config:windows10，python3.7.0

文件名：所有任务.py

命令：pythonall_tasks.py

非常感谢您的帮助。谢谢

Answer 1

asyncio.run创建并运行事件循环。您不应该创建和运行一个，尤其是在协程（用async def定义的函数）中。在协程中，您应该只等待某些东西。

相应地修改代码：

# ...

    async def main(self):
        tasks = [
            asyncio.ensure_future(self.taskOne()),
            asyncio.ensure_future(self.taskTwo()),
        ]
        await asyncio.wait(tasks)

if __name__ == '__main__':
    asynctest = AsyncTest()
    asyncio.run(asynctest.main())

会起作用的。