Increase queue timeout in audio and text processing services for smoother task handling

src/voice_dialogue/services/audio/generator.py

@@ -60,7 +60,7 @@ class TTSAudioGenerator(BaseThread):
 
         while not self.is_exited:
             try:
-                voice_task: VoiceTask = self.text_input_queue.get(block=False, timeout=0.1)
+                voice_task: VoiceTask = self.text_input_queue.get(block=False, timeout=1)
             except Empty:
                 continue
 

src/voice_dialogue/services/audio/player.py

@@ -33,7 +33,7 @@ class AudioStreamPlayer(BaseThread):
         while not self.is_exited:
 
             try:
-                voice_task: VoiceTask = self.audio_playing_queue.get(block=False, timeout=0.1)
+                voice_task: VoiceTask = self.audio_playing_queue.get(block=False, timeout=1)
             except Empty:
                 continue
 

src/voice_dialogue/services/speech/recognizer.py

@@ -33,7 +33,7 @@ class ASRWorker(BaseThread):
 
         while not self.is_exited:
             try:
-                voice_task: VoiceTask = self.user_voice_queue.get(block=False, timeout=0.1)
+                voice_task: VoiceTask = self.user_voice_queue.get(block=False, timeout=1)
             except Empty:
                 continue
 

src/voice_dialogue/services/text/generator.py

@@ -214,7 +214,7 @@ class LLMResponseGenerator(BaseThread):
         """主运行循环"""
         while not self.is_exited:
             try:
-                voice_task: VoiceTask = self.user_question_queue.get(block=False, timeout=0.1)
+                voice_task: VoiceTask = self.user_question_queue.get(block=False, timeout=1)
                 self._process_voice_task(voice_task)
             except Empty:
                 continue