This commit is contained in:
retoor 2025-09-15 02:09:04 +02:00
parent 1af739cac2
commit 0518cdce0b

View File

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