From d751945a0e6581fb1d724e0410e2c7a8aa2af888 Mon Sep 17 00:00:00 2001
From: Windpicker-owo <3431391539@qq.com>
Date: Fri, 7 Nov 2025 21:16:58 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D:=20=E6=9B=B4=E6=96=B0?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=88=86=E5=8F=91=E7=AE=A1=E7=90=86=E5=99=A8?=
 =?UTF-8?q?=E4=BB=A5=E6=8F=90=E9=AB=98=E6=80=A7=E8=83=BD=E5=92=8C=E7=A8=B3?=
 =?UTF-8?q?=E5=AE=9A=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chat/message_manager/scheduler_dispatcher.py | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/src/chat/message_manager/scheduler_dispatcher.py b/src/chat/message_manager/scheduler_dispatcher.py
index b56144b22..e8c93136b 100644
--- a/src/chat/message_manager/scheduler_dispatcher.py
+++ b/src/chat/message_manager/scheduler_dispatcher.py
@@ -32,13 +32,10 @@ class SchedulerDispatcher:
     def __init__(self):
         # 追踪每个流的 schedule_id
         self.stream_schedules: dict[str, str] = {}  # stream_id -> schedule_id
-
-        # 用于保护 schedule 创建/删除的锁，避免竞态条件
-        self.schedule_locks: dict[str, asyncio.Lock] = {}  # stream_id -> Lock
-
+     
         # Chatter 管理器
         self.chatter_manager: ChatterManager | None = None
-
+        
         # 统计信息
         self.stats = {
             "total_schedules_created": 0,
@@ -85,12 +82,6 @@ class SchedulerDispatcher:
         self.chatter_manager = chatter_manager
         logger.debug(f"设置 Chatter 管理器: {chatter_manager.__class__.__name__}")
 
-    def _get_schedule_lock(self, stream_id: str) -> asyncio.Lock:
-        """获取流的 schedule 锁"""
-        if stream_id not in self.schedule_locks:
-            self.schedule_locks[stream_id] = asyncio.Lock()
-        return self.schedule_locks[stream_id]
-
     async def on_message_received(self, stream_id: str) -> None:
         """消息接收时的处理逻辑