Asyncio Ereignisschleife pro Python-Prozess (AIOprocessing, mehrere Ereignisschleifen)

Question

Ich habe zwei Prozesse; ein Hauptprozess und ein Subprozess. Der Hauptprozess führt eine asyncio Ereignisschleife aus und startet den Subprozess. Ich möchte eine weitere asyncio-Ereignisschleife im Subprozess starten. Ich benutze das Modul aioprocessing, um den Subprozess zu starten.

Die subprocess Funktion ist:

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()) 

Aber ich erhalte eine Fehlermeldung:

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. 

Ist es möglich, eine neue zu starten, oder starten Sie den bestehenden, asyncio Ereignisschleife im subprocess ? Wenn das so ist, wie?

Answer 1

Entschuldigung für stören! Ich habe eine Lösung gefunden!

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

Put dieser Code neu asycnio Ereignisschleife innerhalb von subprocess zu starten begannen aus dem Prozess mit asyncio Ereignisschleife