diff --git a/common/global_thread_pool.py b/common/global_thread_pool.py index ef9a356..917d262 100644 --- a/common/global_thread_pool.py +++ b/common/global_thread_pool.py @@ -30,7 +30,10 @@ def _initialize(self, max_workers): self.executor = ThreadPoolExecutor(max_workers=max_workers) - self.loop = asyncio.get_running_loop() # 获取当前的事件循环 + try: + self.loop = asyncio.get_running_loop() # 获取当前的事件循环 + except: + self.loop = asyncio.new_event_loop() self.task_map = {} # def __new__(cls, *args, **kwargs):