asyncio + 멀티 + 유닉스

Question

나는 다음과 같은 논리를 갖는 애완 동물 프로젝트가 있습니다. 하지만 제가이해야 할 것은 대신 start() 코 루틴하게하는 것입니다 : 여기

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

문제입니다 :

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

그것을 실행하기를, 내가 그런 일을해야 할 하위 프로세스가 생성 될 때, 이 복제 된 전체 파이썬 환경을 얻는다, 그래서 이벤트 루프가 이미 실행 중입니다

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. 

내가 행운과 서브 프로세스 측면에서 그것을 파괴하려고하지만 올바른 방법으로 홍보라고 생각합니다 이벤트가 서브 프로세스와 공유된다. 어떻게 든 가능할까요?

UPDATE : 여기 전체 실패 코드입니다. 당신은 항상 당신이 코드를합니다 (if __name__ == '__main__': 부분을 실행하는 방법을 확인하기 위해 검사를 추가해야

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

첫째, 당신은을 사용하는 것이 좋습니다 루프 내에서 파이썬 하위 프로세스를 실행하려는 경우 ProcessPoolExecutor으로을 입력하십시오. 문제에 관해서는, 당신은 새로운 루프를 설정 event loop policy 기능을 사용할 수 있습니다

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

귀하의 하위 프로세스는 모든 것을 실행 당신에게 슬픔 (저항 할 수 없었다)을주는 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())