每个 python 进程的 Asyncio 事件循环（aioprocessing，多个事件循环）

Question

我有两个进程；一个主进程和一个子进程。主进程是运行一个 asyncio 事件循环，并启动子进程。我想在子进程中启动另一个异步事件循环。我正在使用 aioprocessing 模块来启动子进程。

子进程函数为：

def subprocess_code():
     loop = asyncio.get_event_loop()
     @asyncio.coroutine
     def f():
        for i in range(10):
            print(i)
            yield from asyncio.sleep(1)
     loop.run_until_complete(f())

但是我得到一个错误：

    loop.run_until_complete(f())
  File "/usr/lib/python3.4/asyncio/base_events.py", line 271, in run_until_complete
    self.run_forever()
  File "/usr/lib/python3.4/asyncio/base_events.py", line 239, in run_forever
    raise RuntimeError('Event loop is running.')
RuntimeError: Event loop is running.

是否可以在子进程中启动一个新的或重新启动现有的 asyncio 事件循环？如果可以，怎么做？

Answer 1

抱歉打扰了！我找到了解决方案！

policy = asyncio.get_event_loop_policy()
policy.set_event_loop(policy.new_event_loop())
loop = asyncio.get_event_loop()

放置此代码以在从具有异步事件循环的进程启动的子进程中启动新的异步事件循环

每个 python 进程的 Asyncio 事件循环（aioprocessing，多个事件循环）

Asyncio event loop per python process (aioprocessing, multiple event loops)

python

python-asyncio