wxPython 非阻塞 GUI 线程和多处理？

Question

Python 2.7.3 x64 wxPython 2.8 x64

阅读了大量有关 python 线程和多处理的文章，尤其是 Doug Hellmann 的一些文章，这些文章帮助很大。但是，我对一件事感到困惑......

我认为 Python 多处理模块或多或少是线程模块的替代品，除了 args 必须是可腌制的，但我发现这是为了不阻塞我的 GUI，我必须首先使用 threading.Thread 创建一个新线程，然后使用 multiprocessing.Process 在该线程中创建多进程。这行得通，而且效果很好，但对我来说似乎有点笨拙。

如果我尝试在没有第一个线程的情况下直接进行多处理，那么我的 GUI 仍然会阻塞，直到多处理作业完成。这是否按设计工作，还是我缺少有关多处理模块的一些基本内容？

如果需要示例，我可以提供。

谢谢，

-RMWChaos

要求提供示例...

假设 onProcess() 是由 GUI 中的按钮触发的，这会阻塞 GUI...

import time
import multiprocessing as mp

def myWorker(a, b):
    time.sleep(0.1)
    print '{} * {} = {}'.format(a, b, a*b)

def onProcess(event):
    jobs = mp.cpu_count() * 2
    a = 5
    b = 10

    for job in range(jobs):
        mp.Process(target = myWorker, args = (a, b,)).start()

虽然这不是...

import time
import multiprocessing as mp
import threading as th

def myWorker(a, b):
    time.sleep(0.1)
    print '{} * {} = {}'.format(a, b, a*b)

def onProcess(event):
    a = 5
    b = 10
    th.Thread(target = myThread, args = [a, b,]).start()

def myThread(a, b):
    jobs = mp.cpu_count() * 2

    for job in range(jobs):
        mp.Process(target = myWorker, args = (a, b,)).start()

Answer 1

多线程和多处理是根本不同的。

线程大部分用于 i/o。当您创建一个新线程时，它包含在与您生成该线程的程序相同的进程中。这意味着它与程序共享内存空间，但它们（程序和线程）不能并行运行（还要查找 GIL）。

另一方面，多处理会在操作系统级别产生一个新进程。这个新进程可以与预先存在的进程并行运行，但它不与生成它的程序共享内存空间。当您要加速的代码与 i/o 无关，而是实际的处理器密集型计算时，这会更有用。

对于 gui，您通常希望对 gui 的不同部分使用线程，以便在 gui 的一个部分中运行某些东西不会锁定整个 gui，直到处理结束。

没有代码很难说，但我相信你不应该特别需要在新线程中产生一个进程，而是让那个线程处理处理。但是，如果该线程需要处理密集型计算类型的处理而不是大量 i/o，那么您可能需要启动一个进程来处理它。

我相信您的大部分问题在于对多处理与多线程的误解。

Answer 2

我尝试在以下测试程序中运行您的代码，并且多处理工作正常，没有任何内容被阻止：

import time
import multiprocessing as mp
import wx


def myWorker(a, b):
    time.sleep(10)
    print '{} * {} = {}'.format(a, b, a*b)

def onProcess(event):
    jobs = mp.cpu_count() * 2
    a = 5
    b = 10

    for job in range(jobs):
        mp.Process(target = myWorker, args = (a, b,)).start()

def onGUI(event):
    print 'GUI is not blocked'

class MyFrame(wx.Frame):
    def __init__(self, parent, id, title):
       wx.Frame.__init__(self, parent, id, title)
       buttons = []
       panel = wx.Panel(self, wx.ID_ANY)
       sizer = wx.BoxSizer(wx.VERTICAL)
       gui_proc_btn = wx.Button(panel, wx.ID_ANY, 'GUI Process')
       other_proc_btn = wx.Button(panel, wx.ID_ANY, 'Other process')

       gui_proc_btn.Bind(wx.EVT_BUTTON, onGUI)
       sizer.Add(gui_proc_btn, 0, wx.ALL, 5)
       other_proc_btn.Bind(wx.EVT_BUTTON, onProcess)
       sizer.Add(other_proc_btn, 0, wx.ALL, 5)
       panel.SetSizer(sizer)

class MyApp(wx.App):
    def OnInit(self):
        frame = MyFrame(None, -1, 'test.py')
        frame.Show(True)
        self.SetTopWindow(frame)
        return True

if __name__ == '__main__':

    app = MyApp(0)
    app.MainLoop()

从你的命令行运行这个，按下第二个按钮（这在你的函数上使用multiprocessing，我增加了睡眠时间），然后按下第一个按钮。 您应该注意到按下第一个按钮时会生成输出，因此程序不会被阻塞。