This commit is contained in:
retoor 2025-09-15 00:58:29 +02:00
parent b28ba3c47d
commit 1af739cac2

View File

@ -29,7 +29,8 @@ class ChannelMessageService(BaseService):
self._max_workers = 1
def get_or_create_executor(self, uid):
if not uid in self._executor_pools:
self._executor_pools[uid] = ProcessPoolExecutor(max_workers=5)
self._executor_pools[uid] = ProcessPoolExecutor(max_workers=1)
print("Executors available", len(self._executor_pools))
return self._executor_pools[uid]
def delete_executor(self, uid):