我一直在尝试使用多进程模块来更新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()
tk.Tk()
窗口的线程/进程之外的其他线程/进程中调用tkinter
函数。tkinter
不是线程安全的。 - TheLizzard