Standardize service lifecycle management by replacing `stop` with `exit` and introducing `is_exited` check

- Replace `stopped` with `is_exited` across all services for consistency and clarity.
- Add `_exit_event` in `core/base.py` for improved control over service termination.
- Update related methods and properties across audio, text, and speech services.
- Refactor system routes to align with new service lifecycle methods.

src/voice_dialogue/api/core/service_manager.py

@@ -115,7 +115,7 @@ class ServiceManager:
             service = self.services[service_name]
             logger.info(f"正在停止服务: {service_name}")
 
-            service.stop()
+            service.exit()
 
             # 等待服务停止（最多等待5秒）
             timeout = 5

src/voice_dialogue/api/routes/system_routes.py

@@ -120,7 +120,7 @@ async def stop_system(request: Request):
                 audio_capture_service = service_manager.get_service("audio_capture")
                 if audio_capture_service:
                     try:
-                        audio_capture_service.stop()
+                        audio_capture_service.exit()
                         logger.info("音频捕获服务已停止")
 
                         # 等待服务停止

src/voice_dialogue/core/base.py

@@ -5,14 +5,17 @@ class BaseThread(threading.Thread):
 
     def __init__(self, group=None, target=None, name=None, args=(), kwargs=None, *, daemon=None):
         super().__init__(group, target, name, args, kwargs, daemon=daemon)
-        self._stop_event = threading.Event()
+
+        self._exit_event = threading.Event()
         self._is_ready_event = threading.Event()
+        self._stop_event = threading.Event()
 
-    def stop(self):
-        self._stop_event.set()
+    def exit(self):
+        self._exit_event.set()
 
-    def stopped(self):
-        return self._stop_event.is_set()
+    @property
+    def is_exited(self):
+        return self._exit_event.is_set()
 
     @property
     def is_ready(self):
@@ -24,3 +27,13 @@ class BaseThread(threading.Thread):
             self._is_ready_event.set()
         else:
             self._is_ready_event.clear()
+
+    def stop(self):
+        self._stop_event.set()
+
+    @property
+    def is_stopped(self):
+        return self._stop_event.is_set()
+
+    def resume(self):
+        self._stop_event.clear()

src/voice_dialogue/services/audio/capture.py

@@ -47,7 +47,7 @@ class EchoCancellingAudioCapture(BaseThread):
         self.is_ready = True
 
         try:
-            while not self.stopped():
+            while not self.is_exited:
                 size = ctypes.c_int(0)
                 is_voice_active = ctypes.c_bool(False)
                 # 获取音频数据

src/voice_dialogue/services/audio/generator.py

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

src/voice_dialogue/services/audio/player.py

@@ -29,7 +29,7 @@ class AudioStreamPlayer(BaseThread):
     def run(self):
         self.is_ready = True
 
-        while not self.stopped():
+        while not self.is_exited:
 
             try:
                 voice_task: VoiceTask = self.audio_playing_queue.get(block=False, timeout=0.1)
@@ -82,8 +82,10 @@ class AudioStreamPlayer(BaseThread):
 
                 voice_state_manager.set_audio_playing(task_id)
                 voice_state_manager.reset_task_id()
-                audio_data, sample_rate = voice_task.tts_generated_sentence_audio
-                self.playing_audio(audio_data, sample_rate)
+
+                if not self.is_stopped:
+                    audio_data, sample_rate = voice_task.tts_generated_sentence_audio
+                    self.playing_audio(audio_data, sample_rate)
 
                 if self.audio_playing_queue.empty():
                     print(f'回答播放完了')

src/voice_dialogue/services/speech/monitor.py

@@ -217,7 +217,7 @@ class SpeechStateMonitor(BaseThread):
         is_audio_sent_for_processing = False
         is_audio_frames_empty = True
 
-        while not self.stopped():
+        while not self.is_exited:
             try:
                 # 1. 管理任务生命周期
                 self.task_id = voice_state_manager.task_id

src/voice_dialogue/services/speech/recognizer.py

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

src/voice_dialogue/services/text/generator.py

@@ -202,7 +202,7 @@ class LLMResponseGenerator(BaseThread):
         self.is_ready = True
 
         """主运行循环"""
-        while not self.stopped():
+        while not self.is_exited:
             try:
                 voice_task: VoiceTask = self.user_question_queue.get(block=False, timeout=0.1)
                 self._process_voice_task(voice_task)