Tkinter GUI在使用多处理时冻结。过程

Question

你能解释一下，当作为一个单独的进程执行辅助函数时，我是如何防止python GUI冻结的吗？

我编写了一个python GUI，点击一个按钮，就可以通过多处理模块启动一个进程。我决定使用多处理而不是线程，因为我喜欢选择启动、暂停、恢复和终止进程。

不幸的是，当辅助进程运行时，GUI会冻结并失去响应，因此我无法按下“暂停”按钮。

图形用户界面的冻结问题在stackoverflow上报告过几次，但是这个问题似乎没有一个单一的来源，也没有一个统一的解决方案。因此我的问题不是重复的。

我目前完全不知道如何解决这个冰冻问题。到目前为止，我对解决方案的唯一猜测是为Tkinter使用一个名为mtTkinter的线程安全包装器，希望它也能帮助进行多处理。但它什么也没做。

也许需要在GUI和工作进程之间html" target="_blank">添加另一层。

欢迎提供任何建议、提示和解决方案。

最小代码：

import Tkinter as tk
import time
import multiprocessing
import psutil


def test_function():        
    print 'Test process starting.'
    for i in range(11):
        print "Test process running, step: ", i
        time.sleep(1)
    print 'Test process finished.'


   class MainScreen(tk.Tk):

       def __init__(self):
           tk.Tk.__init__(self)
           self.title("CardZilla 0.1")
           self.resizable(0, 0)

           self.s_button = tk.Button(self, text="START", command=self.on_start)
           self.p_button = tk.Button(self, text="PAUSE", state='disabled',  command=self.on_pause)

           self.s_button.pack(side=tk.LEFT)
           self.p_button.pack(side=tk.LEFT)

       def update_all(self): #updates button states
           b_list= {self.s_button, self.p_button}
           for b in b_list:
               b.update()

       def on_start(self):
           if self.s_button["text"] == "RESUME":
               self.s_button["text"] = "START"
               self.p_button["text"] = "PAUSE"
               self.ps.resume() #resume command for process
           else:
               str = 'test arg'
               #queue = Queue()
               p = multiprocessing.Process(None, test_function)
               p.start()
               self.ps = psutil.Process(p.pid) #getting pid of process, how to move self.ps under def __init__(self): ?

               self.s_button["state"] = 'disabled'
               self.p_button["state"] = 'normal'
               self.update_all()

               p.join() #ending process

               self.s_button["state"] = 'normal'
               self.p_button["state"] = 'disabled'
               self.update_all()

       def on_pause(self):
           if self.p_button["text"] == "PAUSE":
               print 'Pause button clicked.'

               self.s_button["text"] = "RESUME"
               self.s_button["state"] = 'normal'
               self.p_button["text"] = "CANCEL"
               self.update_all()
               self.ps.suspend() #pausing command for process

           else:
               self.s_button["text"] = "START"
               self.s_button["state"] = 'normal'
               self.p_button["text"] = "PAUSE"
               self.p_button["state"] = "disabled"
               self.update_all()
               self.ps.terminate() #good to terminate via psutils versus native multiprocessing interface?


if __name__ == '__main__':
    ms = MainScreen()
    ms.mainloop()

Answer 1

问题是，您正在调用p.join（）以等待进程在启动时退出函数：

           p = multiprocessing.Process(None, test_function)
           p.start()
           self.ps = psutil.Process(p.pid) #getting pid of process, how to move self.ps under def __init__(self): ?

           self.s_button["state"] = 'disabled'
           self.p_button["state"] = 'normal'
           self.update_all()

           p.join() # this will block until `p` is complete

这样做可以防止控制返回到您的事件循环，直到进程退出，这意味着在发生这种情况和on_start退出之前，图形用户界面将没有响应。删除对加入的调用，图形用户界面应该会被解除阻塞。

现在，这暴露了设计中的其他问题，因为您只想在流程完成后更新GUI。您可以使用after方法偶尔检查流程是否已完成。通过这种方式，事件循环基本上是未阻塞的，我们只是短暂地阻塞它，以查看流程是否已完成。如果有，我们会更新GUI按钮。如果没有，我们计划检查方法在0.5秒内再次运行。

def check_proc(self):
   if not self.p.is_alive():
       # Process is done. Update the GUI
       self.p.join()
       self.s_button["state"] = 'normal'
       self.p_button["state"] = 'disabled'
       self.update_all()
   else:
       # Not done yet. Check again later.
       self.after(500, self.check_proc)


def on_start(self):
   if self.s_button["text"] == "RESUME":
       self.s_button["text"] = "START"
       self.p_button["text"] = "PAUSE"
       self.ps.resume() #resume command for process
   else:
       str = 'test arg'
       #queue = Queue()
       self.p = multiprocessing.Process(None, test_function)
       self.p.start()
       self.ps = psutil.Process(self.p.pid)

       self.s_button["state"] = 'disabled'
       self.p_button["state"] = 'normal'
       self.update_all()
       self.after(500, self.check_proc)  # Check to see if the process is done in 0.5 seconds

       #p.join() #ending process