使用多进程模块更新Tkinter GUI

Question

使用多进程模块更新Tkinter GUI

6

我一直在尝试使用多进程模块来更新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()

- sarbjit

1

你不应该从除了创建tk.Tk()窗口的线程/进程之外的其他线程/进程中调用tkinter函数。tkinter不是线程安全的。 - TheLizzard

2个回答

1

# Test Code for Tkinter with threads
import Tkinter as Tk
import multiprocessing
from Queue import Empty, Full
import time

class GuiApp(object):
   def __init__(self,q):
      self.root = Tk.Tk()
      self.root.geometry('300x100')
      self.text_wid = Tk.Text(self.root,height=100,width=100)
      self.text_wid.pack(expand=1,fill=Tk.BOTH)
      self.root.after(100,self.CheckQueuePoll,q)

   def CheckQueuePoll(self,c_queue):
      try:
         str = c_queue.get(0)
         self.text_wid.insert('end',str)
      except Empty:
         pass
      finally:
         self.root.after(100, self.CheckQueuePoll, c_queue)

# 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))


if __name__ == '__main__':
# Queue which will be used for storing Data

   q = multiprocessing.Queue()
   q.cancel_join_thread() # or else thread that puts data will not term
   gui = GuiApp(q)
   t1 = multiprocessing.Process(target=GenerateData,args=(q,))
   t1.start()
   gui.root.mainloop()

   t1.join()
   t2.join()

- user2464430

8

如果您能提供至少一点解释，那么这个答案会更加有用。您改动了哪些代码行，添加或删除了什么内容，为什么要这样做？ - Bryan Oakley

1

同意，一些评论可能对社区有益。不过这个解决方案很好用。我在这里有 @user2464430 的一个类似问题的例子，而且它运行得很好。我要注意一下，在 Windows 上启动多进程线程时，我必须在 main 实例化之后立即添加 multiprocessing.freeze_support()，否则会出现错误并且无法启动该线程。 - Matthew

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- cdarke · Accepted Answer

你错过了一个重要的部分，你应该用一个 __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,))

    ....

请注意，此处将队列作为参数传递，而不是使用全局变量。

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

from multiprocessing import Queue