Refactor threading in `launcher.py` to standardize worker initialization, enforce daemon mode, and improve naming consistency.

src/voice_dialogue/core/launcher.py

@@ -61,41 +61,24 @@ def launch_system(
 
     threads = []
 
-    # 音频采集
-    enable_echo_cancellation = not disable_echo_cancellation
-    audio_frame_probe = AudioCapture(
-        audio_frames_queue=audio_frames_queue,
-        enable_echo_cancellation=enable_echo_cancellation
-    )
-    audio_frame_probe.start()
-    threads.append(audio_frame_probe)
-
-    # 语音状态监测
-    enable_vad = disable_echo_cancellation
-    user_voice_checker = SpeechStateMonitor(
-        audio_frame_queue=audio_frames_queue,
-        user_voice_queue=user_voice_queue,
-        enable_vad=enable_vad
-    )
-    user_voice_checker.start()
-    threads.append(user_voice_checker)
-
     # 语音识别
-    whisper_worker = ASRWorker(
+    asr_worker = ASRWorker(
         user_voice_queue=user_voice_queue,
         transcribed_text_queue=transcribed_text_queue,
         language=user_language
     )
-    whisper_worker.start()
-    threads.append(whisper_worker)
+    asr_worker.daemon = True
+    asr_worker.start()
+    threads.append(asr_worker)
 
     # 文本生成
-    answer_generator_worker = LLMResponseGenerator(
+    text_generator = LLMResponseGenerator(
         user_question_queue=transcribed_text_queue,
         generated_answer_queue=text_input_queue
     )
-    answer_generator_worker.start()
-    threads.append(answer_generator_worker)
+    text_generator.daemon = True
+    text_generator.start()
+    threads.append(text_generator)
 
     # 动态获取TTS配置
     tts_speaker_config = get_tts_config_by_speaker_name(speaker)
@@ -105,18 +88,41 @@ def launch_system(
         raise ValueError(f"不支持的TTS说话人: {speaker}。可用说话人: {', '.join(available_speakers)}")
 
     # 语音合成
-    audio_generator_worker = TTSAudioGenerator(
+    audio_generator = TTSAudioGenerator(
         text_input_queue=text_input_queue,
         audio_output_queue=audio_output_queue,
         tts_config=tts_speaker_config
     )
-    audio_generator_worker.start()
-    threads.append(audio_generator_worker)
+    audio_generator.daemon = True
+    audio_generator.start()
+    threads.append(audio_generator)
 
     # 音频播放
-    audio_playing_worker = AudioStreamPlayer(audio_playing_queue=audio_output_queue)
-    audio_playing_worker.start()
-    threads.append(audio_playing_worker)
+    audio_player = AudioStreamPlayer(audio_playing_queue=audio_output_queue)
+    audio_player.daemon = True
+    audio_player.start()
+    threads.append(audio_player)
+
+    # 语音状态监测
+    enable_vad = disable_echo_cancellation
+    speech_monitor = SpeechStateMonitor(
+        audio_frame_queue=audio_frames_queue,
+        user_voice_queue=user_voice_queue,
+        enable_vad=enable_vad
+    )
+    speech_monitor.daemon = True
+    speech_monitor.start()
+    threads.append(speech_monitor)
+
+    # 音频采集
+    enable_echo_cancellation = not disable_echo_cancellation
+    audio_capture = AudioCapture(
+        audio_frames_queue=audio_frames_queue,
+        enable_echo_cancellation=enable_echo_cancellation
+    )
+    audio_capture.daemon = True
+    audio_capture.start()
+    threads.append(audio_capture)
 
     # 等待所有线程准备就绪
     while not all([thread.is_ready for thread in threads]):