From ee30fa5d1d095382528555edfa6791d5f3c05667 Mon Sep 17 00:00:00 2001 From: Windpicker-owo <3431391539@qq.com> Date: Sat, 13 Dec 2025 21:06:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=B6=88=E6=81=AF=E7=AE=A1?= =?UTF-8?q?=E7=90=86=E4=B8=AD=E7=9A=84=E5=BC=82=E6=AD=A5=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/chat/message_manager/message_manager.py | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/src/chat/message_manager/message_manager.py b/src/chat/message_manager/message_manager.py index e55fe077e..91a9ed5db 100644 --- a/src/chat/message_manager/message_manager.py +++ b/src/chat/message_manager/message_manager.py @@ -109,15 +109,11 @@ class MessageManager: context = chat_stream.context if not (context.stream_loop_task and not context.stream_loop_task.done()): # 异步启动驱动器任务；避免在高并发下阻塞消息入队 - context.stream_loop_task = asyncio.create_task( - stream_loop_manager.start_stream_loop(stream_id) - ) - - # 并行触发打断检查，不阻塞消息入队 - context.interruption_task = asyncio.create_task( - self._check_and_handle_interruption(chat_stream, message) - ) - + await stream_loop_manager.start_stream_loop(stream_id) + + # 检查并处理消息打断 + await self._check_and_handle_interruption(chat_stream, message) + # 入队消息 await chat_stream.context.add_message(message)