Refactor core queue initialization: move queue definitions to `constants.py` and clean up redundant imports in `main.py` for better modularity.

src/VoiceDialogue/main.py

@@ -1,7 +1,6 @@
 import argparse
 import time
 import typing
-from multiprocessing import Queue
 from pathlib import Path
 
 import uvicorn
@@ -14,6 +13,13 @@ from services.audio.audio_generator.models import tts_config_registry, TTSConfig
 from services.audio.aec_audio_capture import EchoCancellingAudioCapture
 from services.audio.audio_answer import TTSAudioGenerator
 from services.audio.audio_player import AudioStreamPlayer
+from services.core.constants import (
+    audio_frames_queue,
+    user_voice_queue,
+    transcribed_text_queue,
+    text_input_queue,
+    audio_output_queue
+)
 from services.speech.speech_monitor import SpeechStateMonitor
 from services.speech.asr_service import ASRWorker
 from services.text.text_generator import LLMResponseGenerator
@@ -56,11 +62,6 @@ def launch_system(
         该函数会阻塞运行，直到系统被外部停止或发生异常
     """
 
-    audio_frames_queue = Queue()
-    user_voice_queue = Queue()
-    transcribed_text_queue = Queue()
-    text_input_queue = Queue()
-    audio_output_queue = Queue()
     threads = []
     #
     audio_frame_probe = EchoCancellingAudioCapture(audio_frames_queue=audio_frames_queue)

src/VoiceDialogue/services/core/constants.py

@@ -1,3 +1,4 @@
+import multiprocessing
 import threading
 import uuid
 from collections import OrderedDict
@@ -27,6 +28,15 @@ SAMPLE_RATE_WINDOW_SIZE_MAPPING = {
 DEFAULT_SAMPLE_RATE = 16000
 DEFAULT_WINDOW_SIZE = 512
 
+# ======================= 队列变量 =======================
+
+# 音频处理相关队列
+audio_frames_queue = multiprocessing.Queue()
+user_voice_queue = multiprocessing.Queue()
+transcribed_text_queue = multiprocessing.Queue()
+text_input_queue = multiprocessing.Queue()
+audio_output_queue = multiprocessing.Queue()
+
 # ======================= 全局状态实例 =======================
 
 # 语音状态管理器实例