python asyncio 异步编程出现Event loop is running，是什么原因？

Question

以下代码写在 asycio.Protocol 类的一个方法里

我有时候写：

self.loop = asyncio.get_event_loop()
res = self.loop.run_until_complete(self.resolver.query(host=host, qtype='A'))

他会报错 Event loop is running. 如果写成：

self.loop = asyncio.get_event_loop()
res = self.loop.run_until_complete(self.resolver.query(host=host, qtype='A'))

他会报错 loop argument must agree with Future 得

asyncio.ensure_future(self.resolver.query(host=host, qtype='A'), loop=self.loop).add_done_callback(fn)

这么写才行。

这个内部的原因是什么啊？

Answer 1

你不应该在 asyncio.Protocol 内部写 loop.run_xxx，因为那是启动 event loop 的命令，通常只再最最最外面用一次，之后的代码都应假设 loop 已经在运转了。

如果你想等待一个异步调用（比如你的 resolver.query()）返回结果，你写的 ensure_future().add_done_callback() 是一种方式，另外也可以考虑用 coroutine。