fix: concurrency issue in session

This commit is contained in:
zhayujie
2026-03-12 17:08:09 +08:00
parent d78105d57c
commit 9879878dd0
2 changed files with 2 additions and 2 deletions

View File

@@ -431,7 +431,7 @@ class ChatChannel(Channel):
if session_id not in self.sessions:
self.sessions[session_id] = [
Dequeue(),
threading.BoundedSemaphore(conf().get("concurrency_in_session", 4)),
threading.BoundedSemaphore(conf().get("concurrency_in_session", 1)),
]
if context.type == ContextType.TEXT and context.content.startswith("#"):
self.sessions[session_id][0].putleft(context) # 优先处理管理命令