| from managers.global_chat_manager import GlobalChatManager | |
| import uvicorn | |
| import signal | |
| import sys | |
| import multiprocessing | |
| import asyncio | |
| from rich.console import Console | |
| console = Console() | |
| async def init_chat_queue(): | |
| # 初始化全局chat manager | |
| chat_manager = GlobalChatManager( | |
| console=console, | |
| queue_type="deque", | |
| ) | |
| await chat_manager.initialize_queue() | |
| if __name__ == "__main__": | |
| asyncio.run(init_chat_queue()) |