Fix loop.shutdown_default_executor()

python · aeros · Sep 24, 2019 · Sep 24, 2019 · Sep 24, 2019 · Sep 24, 2019
commit 2b1f35dfcfbf2d5d45deb82c2175147193486237
@@ -567,6 +567,11 @@ async def shutdown_default_executor(self, timeout=None):
         finally:
             thread.join(timeout)
 
+        if (thread.is_alive()):
+            warnings.Warning("The ThreadPoolExecutor did not finishing joining"
+                             f"its threads within {timeout} seconds.")
+            self._default_executor.shutdown(wait=False)
+
     def _do_shutdown(self, future):
         try:
             self._default_executor.shutdown(wait=True)