python - 使用多处理模块更新 Tkinter GUI

Question

我一直在尝试使用 Multiprocessing 模块来更新 Tkinter GUI，但是当我运行此代码时，它给出了 Pickling 错误。

# Test Code for Tkinter with threads
import Tkinter
from multiprocessing import Queue
import multiprocessing
import time

# Data Generator which will generate Data
def GenerateData():
    global q
    for i in range(10):
        print "Generating Some Data, Iteration %s" %(i)
        time.sleep(2)
        q.put("Some Data from iteration %s \n" %(i))

def QueueHandler():
    global q, text_wid
    while True:
        if not q.empty():
            str = q.get()
            text_wid.insert("end", str)

# Main Tkinter Application
def GUI():
    global text_wid
    tk = Tkinter.Tk()
    text_wid = Tkinter.Text(tk)
    text_wid.pack()
    tk.mainloop()

if __name__ == '__main__':
# Queue which will be used for storing Data
    tk = Tkinter.Tk()
    text_wid = Tkinter.Text(tk)
    q = multiprocessing .Queue()
    t1 = multiprocessing.Process(target=GenerateData,args=(q,))
    t2 = multiprocessing.Process(target=QueueHandler,args=(q,text_wid))
    t1.start()
    t2.start()
    text_wid.pack()
    tk.mainloop()

错误:

PicklingError: Can't pickle <type 'thread.lock'>: it's not found as thread.lock

如果我删除参数 text_wid ，则不会报告错误，但不会使用队列中的数据更新文本小部件。

更新:

我修改了代码，以便在队列中有值时调用函数来更新 GUI，从而防止 Tkinter 小部件被传递给单独的进程。现在，我没有收到任何错误，但小部件未使用数据更新。但是，如果我使用 Threading 的混合和 Multiprocessing模块，即创建一个单独的线程来处理队列中的数据，然后它就可以正常工作。我的问题是为什么当我在单独的进程中运行处理程序代码时它不起作用。我是否没有正确传递数据。下面是修改后的代码:

# Test Code for Tkinter with threads
import Tkinter
import multiprocessing
from multiprocessing import Queue
import time
import threading

# Data Generator which will generate Data
def GenerateData(q):
    for i in range(10):
        print "Generating Some Data, Iteration %s" %(i)
        time.sleep(2)
        q.put("Some Data from iteration %s \n" %(i))

def QueueHandler(q):
    while True:
        if not q.empty():
            str = q.get()
            update_gui(str)
            #text_wid.insert("end", str)

# Main Tkinter Application
def GUI():
    global text_wid
    tk = Tkinter.Tk()
    text_wid = Tkinter.Text(tk)
    text_wid.pack()
    tk.mainloop()

def update_gui(str):
    global text_wid
    text_wid.insert("end", str)

if __name__ == '__main__':
# Queue which will be used for storing Data
    tk = Tkinter.Tk()
    text_wid = Tkinter.Text(tk)
    q = multiprocessing.Queue()
    t1 = multiprocessing.Process(target=GenerateData,args=(q,))
    t2 = multiprocessing.Process(target=QueueHandler,args=(q,))
    t1.start()
    t2.start()
    text_wid.pack()
    tk.mainloop()

Answer 1

你错过了一个重要的部分，你应该用 __main__ 保护你的电话。陷阱:

if __name__ == '__main__': 
    q = Queue.Queue()
    # Create a thread and run GUI & QueueHadnler in it
    t1 = multiprocessing.Process(target=GenerateData,args=(q,))
    t2 = multiprocessing.Process(target=QueueHandler,args=(q,))

    ....

请注意，队列是作为参数传递的，而不是使用全局的。

编辑:刚刚发现另一个问题，您应该使用 Queue来自 multiprocessing模块，不是来自 Queue :

from multiprocessing import Queue