asyncio + многопроцессорная + Unix

Question

У меня есть любимый проект со следующей логикой:

import asyncio, multiprocessing 

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

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

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

start() 

Если вы запустите ее, вы увидите:

Hello from subprocess 

Это хорошо. Но то, что я должен сделать, это сделать 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. 

Я пытался уничтожить его на подпроцесс стороне не повезло, но я думаю, что правильный путь к пр однако его совместное использование с подпроцессом. Возможно ли это как-то?

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

Во-первых, вы должны рассмотреть возможность использования loop.run_in_executor с ProcessPoolExecutor, если вы планируете запускать подпроцессы python из цикла. Что касается вашей проблемы, вы можете использовать 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

Вы всегда должны добавить проверку, чтобы увидеть, как вы работаете код (в 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())