python - 在 Python3.6.1 中调用 loop.close asyncio.get_event_loop 后无法创建新的事件循环

标签 python python-3.x python-asyncio

在Python3.6.1中,在从asyncio.get_event_loop()获取的循环中调用loop.close()后,能否创建一个新的循环?

我看过其他帖子,其中包含正确关闭循环的答案,以及如何使用 task.cancel(),但无法以允许新循环的方式使用这些示例中的任何一个在第一个关闭后创建。我还尝试显式设置执行器,然后调用 executor.shutdown(wait=True),但这没有帮助。我还尝试了“del loop”和 del 其他一些东西。

文档表明关闭事件循环是幂等且不可逆的。这是否也意味着无法创建新循环?

下面是一些简单的示例代码来演示这个问题: `

#!/usr/bin/env python3.6
'''
为了演示一个问题,以下代码改编自:
https://docs.python.org/3/library/asyncio-eventloop.html
'''
导入异步

def hello_world(循环):
    打印(' Hello World ')
    循环停止()

loop = asyncio.get_event_loop()
loop.call_soon(hello_world, loop)
loop.run_forever()
# loop.close()


'''
如果上面注释掉的loop.close()没有被注释掉,
以下代码将失败:
    追溯(最近一次通话):
        文件“./aquestion.py”,第 28 行,在  中
            loopNew.call_soon(hello_world, loopNew)
        文件“/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/base_events.py”,第 573 行,在 call_soon
        self._check_closed()
        文件“/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/base_events.py”,第 357 行,在 _check_closed
            raise RuntimeError('事件循环关闭')
    RuntimeError:事件循环已关闭

'''
loopNew = asyncio.get_event_loop()
loopNew.call_soon(hello_world, loopNew)
loopNew.run_forever()

`

如果您尝试回答我的问题,我们将不胜感激。

或者,创建一个事件循环,将其用于各种目的,然后在长时间运行的程序即将退出时关闭该循环是否是一种不好的形式?这似乎是错误的。

最佳答案

asyncio.get_event_loop 返回当前循环。它不关注循环的状态。如果您在关闭一个循环后需要一个新循环,您可以使用 asyncio.new_event_loop

请注意,获取新循环不会影响对 get_event_loop 的后续调用。如果您希望返回新循环而不是原始循环(特别是因为您可能已经关闭了它),您需要自己调用 asyncio.set_event_loop

import asyncio

async def f():
    await asyncio.sleep(0)

loop = asyncio.get_event_loop()
loop.run_until_complete(f())
loop.close()

loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)

关于python - 在 Python3.6.1 中调用 loop.close asyncio.get_event_loop 后无法创建新的事件循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43646768/

相关文章:

python - 异步将对象转换为协程。加载对象字段

python - 我应该如何在不干扰其他调用者的情况下在库中使用 asyncio?

python - 我如何才能准确找出是哪个包导致了 pip 回溯问题?

python - SQLAlchemy:具有动态 'association_proxy' 创建函数的多重继承

python - 在python中查找嵌套列表中元素的索引

python - 对值递减的列表运行 for 循环

python - 如何使用python获取列表中单个字符串中的值而不用逗号分隔csv文件中的值?

python - 将文件夹从 Google Colab 移动到 Google Drive

python - Jupyter、asyncio 和 Slack

python - 逐列连接两个带有字符串的df