Python、多处理和 GUI

Question

我有一个带有 GUI 的程序需要进行一些多处理。这样做的目的是避免冻结 GUI，并允许用户在进程运行时使用其他一些按钮。

然后我想定义如下方法：

def start_waiting(self, parent, func, args):

    self.window_waiting.show()

    task=Process(func(*args))
    task.start()

    task.join()

    # Some code to execute at the end of the process
    #
    #...

问题是join() 不起作用，我需要它，因为join() 之后执行的代码表明Process 何时结束。我将使用该代码更新window_waiting 的取消按钮。

然后我想到了另一个避免使用join() 的解决方案，我将其替换为：

while task.is_alive():
    time.sleep(0.5)

但这两个都不起作用，所以我尝试了一个方案 C，即创建一个队列：

def worker(input, output):
    for func, args in iter(input.get, 'STOP'):
        result=func(*args)
        output.put(result)


task_queue = Queue()
done_queue = Queue()
task_queue.put(task)

Process(target=worker, args=(task_queue, done_queue)).start()
done_queue.get()

最后一个代码给了我错误：'Pickling an AuthenticationString object is ' TypeError: Pickling an AuthenticationString object is disallowed for security reasons

这导致我到multiprocessing.Process subclass using shared queue，但我还没有设法解决问题：/

Answer 1

您的第一个示例应如下所示：

def start_waiting(self,parent,func,args):

    ...not relevant code..

    self.window_waiting.show()


    task=Process(target=func, args=args)  # This line is different.
    task.start()


    task.join()

按照你的方式，它实际上并没有在子进程中执行func；它在父进程中执行，然后将返回值传递给Process。当您调用 task.start() 时，它可能会立即失败，因为您传递的是 func 返回的任何内容，而不是函数对象。

请注意，因为您在start_waiting 中调用task.join()，它可能会阻塞您的GUI，因为start_waiting 将在func 完成之前返回，即使它在子进程中运行。它不会阻塞的唯一方法是，如果您在与 GUI 事件循环不同的线程中运行 start_waiting。你可能想要更多这样的东西：

def start_waiting(self,parent,func,args):

    ...not relevant code..

    self.window_waiting.show() # You should interact with the GUI in the main thread only.

    self.task = Process(target=func, args=args)  # This line is different.
    self.thrd = threading.Thread(target=self.start_and_wait_for_task)
    self.thrd.start()


def start_and_wait_for_task(self):
    """ This runs in its own thread, so it won't block the GUI. """
    self.task.start()
    self.task.join()
    # If you need to update the GUI at all here, use GLib.idle_add (see https://wiki.gnome.org/Projects/PyGObject/Threading)
    # This is required to safely update the GUI from outside the main thread.