스레드

Question

에 asyncio 중지부터 시작 (결국 정지) 스레드 그래서 같은 asyncio 루프가 이것은 asyncio.CancelledError 제기 때문에 작동하지 않습니다 ... stop 방법의 어디서나 그들을 잡는 것은 도움이되지 않는 것 같습니다.

@pytest.mark.asyncio으로 표시되지 않은 테스트 코드를 실행하면 Task was destroyed but it is pending!이라는 메시지가 나타납니다.

내가 뭘 잘못하고 있니?

Answer 1

여기에 몇 가지 문제가 있습니다.

1. Task.cancel()은 쿠로틴 내부에서 asyncio.CancelledError()를 발생시킵니다. 코 루틴에서 "try/exec CancelledError"를 추가하여 예외를 처리해야합니다.

2. 는 또 다른 방법은 데프 정류장에서 CancelledError 예외를 억제 할 수있는 것은 :

   from asyncio import CancelledError 
   from contextlib import suppress 
   
   def stop(self): 
       self._logger.info("Thread has been asked to stop!") 
       if self.loop.is_running(): 
        self._logger.debug("Asked running asyncio loop to stop.") 
        self.loop.call_soon_threadsafe(self.loop.stop) 
        for task in asyncio.Task.all_tasks(): 
         task.cancel() 
         with suppress(CancelledError): 
          loop.run_until_complete(task) 
   

3. 전에 몇 초를 기다려야

   loop.run_until_complete(loop.shutdown_asyncgens())