失败的尝试，要么读不全，要么读重复

LiuJiewenTT · Jan 31, 2024 · c4e542d · c4e542d
1 parent 5eb10bb
commit c4e542d
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,2 +1,4 @@
 venv
 keep_local
+.idea
+__pycache__
diff --git a/src/CBJQ_SS_FrontEnd_tk/__init__.py b/src/CBJQ_SS_FrontEnd_tk/__init__.py
diff --git a/src/CBJQ_SS_FrontEnd_tk/main.py b/src/CBJQ_SS_FrontEnd_tk/main.py
@@ -198,6 +198,11 @@ def execAction_threading(self, **kwargs):
         thread.start()
 
     def execAction(self, **kwargs):
+
+        def waitlast():
+            nonlocal output
+            output = sp.stdout.readline()
+
         self.displayLog_text.insertAndScrollToEnd('[+]' + '运行前报告' + '=' * 15)
         self.displayLog_text.insertAndScrollToEnd(kwargs)
         launch_args = []
@@ -220,15 +225,22 @@ def execAction(self, **kwargs):
             with subprocess.Popen(launch_cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, encoding='utf-8') as sp:
                 self.displayLog_text.insertAndScrollToEnd(f'sp.pid: {sp.pid}')
                 self.displayLog_text.insertAndScrollToEnd('[+]' + '运行报告' + '-' * 15)
-                while sp.poll() is None:
+                thread = threading.Thread(target=waitlast)
+                while True:
                     # print('to read')
                     # output = sp.communicate(timeout=1)[0]
-                    output = sp.stdout.readline()
+                    if sp.poll() is not None:
+                        thread.start()
+                        if not thread.is_alive():
+                            break
+                    else:
+                        output = sp.stdout.readline()
                     # print(f'[stdout]: {i}', end='')
                     # self.displayLog_text.insert('end', i)
                     # self.displayLog_text.yview_moveto(1)
                     self.displayLog_text.insertAndScrollToEnd(output, end='')  # instance method
                     # self.displayLog_text.update()
+                thread.join(timeout=3)
                 print('')
                 self.displayLog_text.insertAndScrollToEnd('[-]' + '运行后报告' + '-' * 15)
             self.displayLog_text.insertAndScrollToEnd('[-]' + '' + '=' * 15)