asyncio +マルチプロセッシング+ UNIX

Question

は、私は次のロジックを持つペットのプロジェクトを持っています。しかし、私がしなければならない代わりにstart()コルーチンようにすることです。それを実行するには

async def start(): 
    multiprocessing.Process(target=sub_loop).start() 

を、私はそのような何かしなければならない。ここで

asyncio.get_event_loop().run_until_complete(start()) 

することは問題である：サブプロセスが作成されたとき、それはクローン化された全体のPython環境を取得しますので、イベントループは、すでにそこに実行されています

Process Process-1: 
Traceback (most recent call last): 
    File "/usr/lib/python3.5/multiprocessing/process.py", line 249, in _bootstrap 
    self.run() 
    File "/usr/lib/python3.5/multiprocessing/process.py", line 93, in run 
    self._target(*self._args, **self._kwargs) 
    File "test.py", line 7, in sub_loop 
    asyncio.get_event_loop().run_until_complete(sub_main()) 
    File "/usr/lib/python3.5/asyncio/base_events.py", line 361, in run_until_complete 
    self.run_forever() 
    File "/usr/lib/python3.5/asyncio/base_events.py", line 326, in run_forever 
    raise RuntimeError('Event loop is running.') 
RuntimeError: Event loop is running. 

私は運とサブプロセス側でそれを破壊しようとしたが、私は正しい方法でのPRであることを考えますイベントをサブプロセスと共有します。どういうわけか可能ですか？

UPDATE：ここ 完全な失敗コードです：

import asyncio, multiprocessing 

import asyncio.unix_events 

async def sub_main(): 
    print('Hello from subprocess') 

def sub_loop(): 
    asyncio.get_event_loop().run_until_complete(sub_main()) 


async def start(): 
    multiprocessing.Process(target=sub_loop).start() 

asyncio.get_event_loop().run_until_complete(start()) 

Answer 1

まず、あなたはを使用することを検討すべきですループ内からPythonのサブプロセスを実行する予定の場合はProcessPoolExecutorのを使用してください。私は完全な答えのための時間を持っていませんが、（a）は、あなたのマルチプロセッシングのものがあるデザインを検討する必要があります

import asyncio 
from concurrent.futures import ProcessPoolExecutor 

async def sub_main(): 
    print('Hello from subprocess') 

def sub_loop(): 
    loop = asyncio.new_event_loop() 
    asyncio.set_event_loop(loop) 
    loop.run_until_complete(sub_main()) 

async def start(executor): 
    await asyncio.get_event_loop().run_in_executor(executor, sub_loop) 

if __name__ == '__main__': 
    executor = ProcessPoolExecutor() 
    asyncio.get_event_loop().run_until_complete(start(executor)) 

Answer 2

あなたはいつもあなたがコード（if __name__ == '__main__':一部を実行しているかを確認するためのチェックを追加する必要がありますにあなたのサブプロセスがすべてを実行しています。あなた悲しみ（抵抗できなかった）を与えて、2回目のモジュール。

import asyncio, multiprocessing 

async def sub_main(): 
    print('Hello from subprocess') 

def sub_loop(): 
    asyncio.get_event_loop().run_until_complete(sub_main()) 


async def start(): 
    multiprocessing.Process(target=sub_loop).start() 

if __name__ == '__main__': 
    asyncio.get_event_loop().run_until_complete(start())