需要 Python 线程编程方面的帮助

Question

我正在开发一个 UI，它有一个运行按钮来在命令提示符下运行某些测试。我尝试在此处实现线程以调用命令提示符并考虑监视线程。在测试运行（在命令提示符下）之前，我希望禁用运行按钮，并且仅在命令提示符关闭时才启用它。

我创建了一个 .bat 文件来在命令提示符中运行测试列表。

代码如下：

用于调用命令提示符的线程：

class RunMonitor(threading.Thread):
def run(self):
    print 'Invoking the command prompt .....'
    subprocess.call(["start", "/DC:\\Scripts", "scripts_to_execute.bat"], shell=True)

用于监视线程

def runscript(self):
    print 'Complete_file_Path inside Run script is : ' , self.complete_file_path
    file_operation.Generate_Bat_File(self.complete_file_path)

    run_monitor_object = RunMonitor()
    run_monitor_object.start()

    while True:
        if run_monitor_object.isAlive():
            print 'The thread is still alive....'
        else:
            print 'The Thread is not alive anymore'
            self.run_button.setEnabled(True)
            break

从上面的示例中，一旦我调用命令提示符，我就会运行一个 while 循环来监视状态，并且我希望该线程只要长时间处于活动状态因为命令提示符被调用，并且一旦我关闭命令提示符就会死掉。但就我而言，应用程序只是挂起......

几个问题： 1. 这是调用线程的正确方法吗？ 2. 这是监视线程状态的正确方法吗？ 3.有没有更好的方法来处理这个问题？

对此的任何帮助将不胜感激。

谢谢。

Answer 1

我几乎建议不要使用线程，但是，如果您仍然想这样做，主程序和线程之间通信的一种非常简单的方法是通过线程事件。这实际上只是一个布尔事件（打开或关闭），您可以在设置事件时采取操作。这是您的原始程序更新为使用此：

class RunMonitor(threading.Thread): 
    def __init__(self, quit_event):
        threading.Thread.__init__(self)
        self.quit_event = quit_event
    def run(self):     
        print 'Invoking the command prompt .....'     
        subprocess.call(["start", "/DC:\\Scripts", "scripts_to_execute.bat"], shell=True)
        self.quit_event.set()

def runscript(self):     
    print 'Complete_file_Path inside Run script is : ' , self.complete_file_path     
    file_operation.Generate_Bat_File(self.complete_file_path)      

    quit_event = threading.Event()
    run_monitor_object = RunMonitor(quit_event).start()

    while True:         
        if not quit_event.is_set():
             print 'The thread is still alive....'         
        else:
             print 'The Thread is not alive anymore'             
             self.run_button.setEnabled(True)             
             break 

因此，本质上，在启动线程之前，您创建一个 threading.Event() 对象并将其传递给您的线程。创建此事件后，您可以.set() 它来“打开”该事件，主程序只需等待该事件发生。

就像我说的，这非常简单，它只是一个布尔事件。如果您需要更复杂的东西，您可以添加更多事件，或使用 threading.Queue() 代替。

[编辑] 这是我创建的完整工作示例（而不是尝试将所有内容都塞进示例中）：

这是 python 文件，请注意对 subprocess.call< 的更改/code> 行：

import threading
import subprocess
import time

class RunMonitor(threading.Thread): 
    def __init__(self, quit_event):
        threading.Thread.__init__(self)
        self.quit_event = quit_event
    def run(self):     
        print 'Invoking the command prompt .....\n'   
        subprocess.call(["start", "/WAIT", "/DC:\\python27\\sample", "xxx12.bat"], shell=True)                
        self.quit_event.set()

class Something:
    def runscript(self):     
        print 'Starting the thread...'  

        quit_event = threading.Event()
        run_monitor_object = RunMonitor(quit_event).start()

        while True:         
            if not quit_event.is_set():
                 print 'The thread is still alive....'         
            else:
                 print 'The Thread is not alive anymore'             
                 break 
            time.sleep(1)

runme = Something()
runme.runscript()

请注意，我已在主循环中添加了睡眠，以便控制台不会填满“线程仍处于活动状态...”消息。

另外，这里供参考的是我的批处理文件（我将其命名为 xxx12.bat，如 python 代码中所引用），我只是用它来引起延迟，以便我可以证明线程正确终止：

echo wscript.sleep 2500 > xxx12.vbs
start /wait xxx12.vbs
dir c:\
start /wait xxx12.vbs
dir c:\
start /wait xxx12.vbs
dir c:\
start /wait xxx12.vbs
dir c:\
start /wait xxx12.vbs
dir c:\
exit

这里需要注意的重要一点是这个批处理文件中的“exit”命令至关重要，如果我们不将其放在那里，子进程调用将永远不会终止。希望这个例子能有所帮助。

Answer 2

问题是你如何监控线程。只要线程处于活动状态，runscript 就会通过循环执行来阻止程序，从而阻止 GUI 事件系统处理用户事件 - 这会导致您遇到“挂起”的情况。

GUI 编程中有许多与线程交互的技术，特别是 PyQt。在这种情况下我更喜欢使用计时器。启动工作线程后，还要创建一个计时器，每隔 100 毫秒左右调用一个方法（槽）。此计时器方法执行监视 - 检查工作线程是否仍处于活动状态等。由于显而易见的原因，这不会阻止事件循环。