Python 3.9 关闭默认执行器

如何解决Python 3.9 关闭默认执行器

如果在使用 RuntimeError 后调用默认执行程序，Python 3.9 会引发 loop.shutdown_default_executor：

RuntimeError: Executor shutdown has been called

我这样开始我的程序：

b = Lambda()

try:
    b.loop.run_forever()
except:
    b.loop.run_until_complete(b.stop())
finally:
    b.release()

大多数情况下，except 子句在我结束所有任务的地方正常执行，包括关闭执行程序：

try:
    await asyncio.wait({asyncio.ensure_future(task)
        for task in [
            self.loop.shutdown_default_executor(),self.loop.shutdown_asyncgens(),self.session.close(),self.close(),]
    })
finally:
    tasks = [
        t for t in asyncio.all_tasks() 
        if t is not asyncio.current_task()
    ]
    [t.cancel() for t in tasks]

    await asyncio.gather(*tasks,return_exceptions=True)

但有一小部分时间，b.loop.run_forever 会捕获 KeyboardInterrupt，然后被 RuntimeError 捕获，因此不会执行常规的 except 块。

回溯仅指向 b.loop.run_forever 作为原始原因，但这是我使用执行程序的方式：

def _cancel(tasks): 
    async def wrapper():
        {t.cancel() for t in tasks}
        return await asyncio.gather(*tasks,return_exceptions=True)
    return asyncio.run_coroutine_threadsafe(wrapper(),self.loop).result()

self.loop.call_soon_threadsafe(self.loop.run_in_executor,None,lambda: _cancel(pending))

所以我认为我还需要停止该线程的循环，但我不确定。

如果它有一些意义，我正在手动创建和设置默认执行器：

executor  = concurrent.futures.ThreadPoolExecutor(max_workers=3)
self.loop.set_default_executor(executor)

很难重现错误，因为它不会每次都发生。我猜它会在我 KeyboardInterrupt 执行程序再次开始运行时发生。