Python asyncio programu nie wypłynie

Question

Mam asyncio programu/Python z dwoma asyncio zadań:

• taki, który rozbija
• , który trwa przez wieki.

Chcę, aby mój cały program zakończył się po pierwszej awarii. Nie mogę tego zrobić.

import asyncio 
import time 

def infinite_while(): 
    while True: 
     time.sleep(1) 


async def task_1(): 
    await asyncio.sleep(1) 
    assert False 


async def task_2(): 
    loop = asyncio.get_event_loop() 
    await loop.run_in_executor(None, lambda: infinite_while()) 


loop = asyncio.get_event_loop() 
asyncio.set_event_loop(loop) 

tasks = asyncio.gather(task_2(), task_1()) 
try: 
    loop.run_until_complete(tasks) 
except (Exception, KeyboardInterrupt) as e: 
    print('ERROR', str(e)) 
    exit() 

Drukuje BŁĄD, ale nie wychodzi. Przy ręcznym zamknięciu program drukuje następujące ślad stosu:

Error in atexit._run_exitfuncs: 
Traceback (most recent call last): 
    File "/usr/lib/python3.5/concurrent/futures/thread.py", line 39, in _python_exit 
    t.join() 
    File "/usr/lib/python3.5/threading.py", line 1054, in join 
    self._wait_for_tstate_lock() 
    File "/usr/lib/python3.5/threading.py", line 1070, in _wait_for_tstate_lock 
    elif lock.acquire(block, timeout): 
KeyboardInterrupt 

Answer 1

gdy wyjątek powstał w zadaniu nie propaguje się do zakresu, w którym zadanie inicjowane eventloop, to znaczy, wywołanie loop.run_until_complete(tasks). Pomyśl o tym, jakby wyjątek został zgłoszony tylko w kontekście twojego zadania, a to jest zasięg najwyższego poziomu, na którym masz szansę go obsłużyć, w przeciwnym razie zostanie on podniesiony na "tle".

Ten powiedział, że nigdy nie będzie złapać Exception z zadania z tego:

try: 
    loop.run_until_complete(tasks) 
except (Exception, KeyboardInterrupt) as e: 
    print('ERROR', str(e)) 
    exit() 

... i to jest po prostu jak działa pętla zdarzeń. Wyobraź sobie, że jeśli masz usługę z kilkoma zadaniami, a jedna z nich zawiedzie, to zatrzyma całą usługę.

Możliwe jest ręczne wykonanie zdarzenia stop podczas wywołania wyjątku w task1, np.

async def task_1(): 
    await asyncio.sleep(1) 
    try: 
     assert False 
    except Exception: 
     # get the eventloop reference somehow 
     eventloop.stop() 

Jest to jednak bardzo brudny i rodzaj hacky, więc sugeruję raczej iść z rozwiązania, które @D-Von suggested, która jest znacznie czystsze i bezpieczniejsze.