python - 如何组织线程化 GUI 应用程序 (Python)

Question

我在使用 Tkinter(和 ttk)和 Python 将我的代码组织成一个可用且没有 super 错误的程序时遇到了麻烦。基本上，它现在只是从网上下载图像，但我什至连一个简单的 GUI 都遇到了麻烦。虽然一切都在控制台中运行，但制作 GUI 是一场噩梦，更不用说让它运行了。好吧，现在我可以正常工作了，但它经常崩溃，很明显我做错了，导致 GUI 中的变量错误没有被正确访问(即使是我自己放置的控制台中的错误消息也可以确保事情正常进行)正确运行)和不断的崩溃。

基本上我有这样的东西。

发生和需要处理的主要事情是:用户输入字符串从 entrytext 发送到程序的密集部分(当前包含在一个线程中)，密集部分步进 GUI 的进度条，密集部分发送文本在没有 GUI 和密集部分崩溃的情况下向文本框/记录器发送消息。此外，密集部分应在 GUI 完全加载后立即开始，并在准备就绪时将启动消息发送到文本框。

密集部分处理其他事情，但不会干扰 GUI，例如实际下载和保存图像、浏览和文件 I/O，无论如何我都没有遇到任何问题。

我还阅读了有关队列和线程以及教程的内容，但我似乎还是不明白。特别是我将如何让程序不断地在 GUI 中步进进度条，同时也向 GUI 发送文本消息(例如，我什至如何从队列中接近而不必做非常缓慢和 CPU 密集型的 While 和 If 循环和多个queues 这让它变得更加疯狂。在简单的例子中，有一个简单的 while 和 queue.get() wait 是很好的，因为它消耗的资源很少)。所以我的问题是，我需要为此实现什么样的结构，如果可能的话，我能得到一两个例子吗(我从例子中学到的东西比阅读文档更好)？非常感谢。

from Tkinter import *
import ttk
import Threading
import #a bunch of other stuff

class myHardWorkerThread (threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self.setDaemon(True)
        self.myClass = ModifiedConsoleClass()

    def run(self):
            #thread needs to wait at least a little otherwise the thread begins too
            #fast and causes even more errors, probably due to it sending text to
            #the textbox upon startup among other things and just overall no
            #organization
            time.sleep(3)
            self.myClass.BeginDoingStuff()

class ApplyMyGuiAndStartThread():
    def __init__(self, root, thread):

        root.geometry('500x500')
        root.resizable(0,0)

        #Put backgrounds or images or logos  here
        self.canvas = Canvas(root)
        self.canvas.pack()

        #My textbox that acts like a Log/Console output
        self.txtLogger = Text(root,state="disabled",wrap="word")
        self.txtLogger.place()
        self.scrollbar = Scrollbar(root)
        self.scrollbar.place()

        #Progressbar
        self.myVal = IntVar()
        self.TProgressbar = ttk.Progressbar(root, orient=HORIZONTAL, variable = self.myVal, mode='determinate')
        self.TProgressbar.place()

        #Entrybox for user input
        self.txbEntryText = StringVar()
        self.txtbEntry = ttk.Entry (root, textvariable=self.txbEntryText)
        self.txtbEntry.place()
        self.txtbEntry.bind("<Return>", self.SendFromGUItoThread)

        self.thread = thread
        self.thread.start()

    def SendFromGUItoThread(self,arg=None):

        myentry = str(self.txtbEntry.get())
        self.txtbEntry.delete(0, END)
        self.thread.myClass.entryBoxValueCopy = myentry


    def SendFromThreadToGUI(self,msg):
        try:
            self.txtLogger['state'] = 'normal'
            self.txtLogger.insert('end', msg)
            self.txtLogger['state'] = 'disabled'
        except:
            print "Could not be printed"


class ModifiedConsoleCode():
    def __init__(self):
        #constants here like
        self.entryBoxValueCopy = None

    def BeginDoingStuff():
        #Thread does the bulk of work  here, includes connecting to websites,
        #collecting info, sending text messages to GUI, downloading images and
        #stepping the progressbar by a calculated amount by file size

    def OneOfManyFunctionsUsedInsideBeginDoingStuff():
        #Breaks things down like looping time.sleep waits for user input in the entry box
        #showing up in entryBoxValueCopy, and using the user input to surf websites and
        #collect images

if __name__ == '__main__':

        root = Tk()
        root.title(titleOfTheProgram)

        worker = myHardWorkerThread()

        w = ApplyMyGuiAndStartThread(root,worker)

        root.mainloop()
        os._exit(0)

Answer 1

简短的回答是，您无法与工作线程中的小部件进行交互。您唯一的选择是让您的工作线程将某些内容推送到线程安全队列中，然后让主线程对其进行轮询。

您不需要任何 while 循环来轮询队列。您已经有一个无限循环——事件循环(例如:mainloop)——所以不需要再添加一个。

从主线程轮询队列的方式是这样的:

def pollQueue(self):
    <look at the queue, act on the results>
    self.after(100, self.pollQueue)

它的作用是安排每 100 毫秒轮询一次队列。当然，您可以将轮询间隔设置为您想要的任何值。