Executor pools.

This commit is contained in:
retoor 2025-09-08 01:09:22 +02:00
parent 939e63f244
commit 18be3fdc19

View File

@ -16,7 +16,7 @@ class ChannelMessageService(BaseService):
def get_or_create_executor(self, user_uid):
if not user_uid in self._executor_pools:
self._executor_pools[user_uid] = ThreadPoolExecutor(max_workers=5)
self._executor_pools[user_uid] = ThreadPoolExecutor(max_workers=1)
return self._executor_pools[user_uid]
async def maintenance(self):