modify stop function

asr/sherpa_ncnn_asr.py

@@ -65,7 +65,7 @@ class SherpaNcnnAsr(AsrBase):
             self._notify_complete('介绍中国5000年历史文学')
             logger.info(f'_recognize_loop111')
             segment_id += 1
-            time.sleep(50)
+            time.sleep(5)
             logger.info(f'_recognize_loop222')
         logger.info(f'_recognize_loop exit')
 '''

human/audio_inference_handler.py

@@ -135,4 +135,6 @@ class AudioInferenceHandler(AudioHandler):
     def pause_talk(self):
         print('AudioInferenceHandler pause_talk', self._audio_queue.size(), self._mal_queue.size())
         self._audio_queue.clear()
+        print('AudioInferenceHandler111')
         self._mal_queue.clear()
+        print('AudioInferenceHandler222')

human/human_render.py

@@ -86,7 +86,7 @@ class HumanRender(AudioHandler):
     #     return self._voice_render.size()
 
     def pause_talk(self):
-        pass
+        logging.info('hunan pause_talk')
         # self._voice_render.pause_talk()
         # self._video_render.pause_talk()
 

nlp/nlp_base.py

@@ -51,7 +51,9 @@ class NLPBase(AsrObserver):
         logger.info('NLPBase stop')
         self._is_running = False
         self._ask_queue.add_task(self._on_close)
+        logger.info('NLPBase add close')
         self._ask_queue.stop()
+        logger.info('NLPBase _ask_queue stop')
 
     def pause_talk(self):
         logger.info('NLPBase pause_talk')

nlp/nlp_doubao.py

@@ -66,3 +66,9 @@ class DouBao(NLPBase):
         logger.info('AsyncArk close')
         if self.__client is not None and not self.__client.is_closed():
             await self.__client.close()
+
+    def stop(self):
+        print('doubao stop00')
+        self.__client.close()
+        print('doubao stop11')
+        super().stop()