refactor: 使用异步生成器迁移到事件驱动模型以进行聊天流管理

- 用异步生成器替换了无限循环任务,以处理聊天流事件。
引入了`ConversationTick`数据模型来表示会话事件。
- 更新了`StreamLoopManager`,以使用新的基于生成器的方法来管理聊天流。
- 在聊天流处理过程中增强了错误处理和日志记录功能。
- 改进了聊天流的生命周期管理,包括启动和停止方法。
- 删除了与之前的循环工作线程实现相关的遗留代码。
This commit is contained in:
Windpicker-owo
2025-12-04 22:40:12 +08:00
parent 1dfa44b32b
commit 2e7b434537
2 changed files with 415 additions and 517 deletions

View File

@@ -1,14 +1,25 @@
""" """
消息管理器模块 消息管理器模块
提供统一的消息管理、上下文管理和流循环调度功能 提供统一的消息管理、上下文管理和流循环调度功能
基于 Generator + Tick 的事件驱动模式
""" """
from .distribution_manager import StreamLoopManager, stream_loop_manager from .distribution_manager import (
ConversationTick,
StreamLoopManager,
conversation_loop,
run_chat_stream,
stream_loop_manager,
)
from .message_manager import MessageManager, message_manager from .message_manager import MessageManager, message_manager
__all__ = [ __all__ = [
"ConversationTick",
"MessageManager", "MessageManager",
"StreamLoopManager", "StreamLoopManager",
"conversation_loop",
"message_manager", "message_manager",
"run_chat_stream",
"stream_loop_manager", "stream_loop_manager",
] ]

File diff suppressed because it is too large Load Diff