【问题标题】:How to correctly implement multithreading using a Tkinter GUI?如何使用 Tkinter GUI 正确实现多线程?
【发布时间】:2020-01-01 20:36:08
【问题描述】:

我正在尝试在 tkinter 中使用 GUI 时实现多线程。我来了this solution,但我没有实现它。

所以基本上我需要知道:

我需要如何更改我的代码以使进度条交互顺畅且顺畅,即当 GUI 失去焦点时不会进入无响应模式?

这是我的代码:

from tkinter import *
import queue
import threading
from tkinter.ttk import *

class ThreadedTask(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.queue = queue  

# Gui class
class MyGui(Frame):
    def __init__(self, parent):
        super().__init__(parent)
        self.parent = parent
        self.queue = queue.Queue() 
        self.init_ui()

    # define a button to fulfill long task
    def init_ui(self):        
        self.frame = Frame(self, relief=RAISED, borderwidth=1)
        self.frame.grid(row=0, column=0, columnspan=1, sticky='ns')
        self.status_frame = Frame(self, relief=RAISED, borderwidth=1, height=20)
        self.status_frame.grid(row=1, column=0, columnspan=3, sticky='nesw')
        self.status_frame.grid_configure(padx=3, pady=3)
        self.button = Button(self.frame, text='do Stuff', command=self.do_stuff)
        self.button.grid(padx=3, pady=3)
        self.progress = Progressbar(self.status_frame, orient="horizontal", length=80, mode="determinate")
        self.progress.grid(row=1, column=0, pady=3, sticky='nesw')
        self.grid()

    # start ThreadedTask here 
    def do_stuff(self):
        ThreadedTask(self.queue).start()
        self.queue_process(DoStuffClass(ui=self))

    def queue_process(self, process, retry_time=10): 
        self.master.after(retry_time, process) 

    def update_status(self):
        self.parent.update_idletasks()

class DoStuffClass:
    def __init__(self, ui=None):
        self.ui = ui
        self.long_task()

    def long_task(self):
        # do stuff here and update the progressbar from MyGui
        self.ui.progress['maximum'] = 10000
        # some lengthy task ...
        for i in range(10000):
            print(i)
            self.ui.progress.step()
            self.ui.parent.update_idletasks()


# main
root = Tk()
root.geometry("150x80+50+50")
MyGui(root)
root.mainloop()
root.quit()

我认为现在我的问题是队列和线程的错误实现,即self.queue_process(DoStuffClass(ui=self))... 行为与我根本不使用队列和多线程一样。进度条工作,只要它保持“焦点”,这意味着我没有点击桌面上的其他任何东西。一旦我单击桌面上的其他位置并且 GUI 失去焦点,GUI 就会进入“无响应”模式,并且进度条不再更新。还有,有时Tcl会关闭错误的线程,导致整个程序崩溃。

【问题讨论】:

  • 你把你的代码简化得太多了。当我尝试运行它时:AttributeError: 'MyGui' object has no attribute 'preview_button' 来自self.preview_button.grid(padx=3, pady=3) 行。顺便说一句,主线程是 Python 解释器首先执行的线程。
  • @martineau 你好,Martineau,我已经更新了我的代码。我对其进行了测试,它一直有效,直到self.queue_process(DoStuffClass(ui=self)) 行,这是我不确定的部分。但是,您确实会在执行冗长的任务时看到进度条在移动,并且当您更改 minigui 的焦点时,它将进入无响应模式(对于我的原始程序 - 有时会崩溃)。
  • 您的问题非常广泛,并且子问题太多(其中一些毫无意义 - 即没有子线程这样的东西)。主线程是 Python 解释器开始运行的第一个代码。你可以在任何你想要的地方实现ThreadedTask 类。线程不是从它产生的,它的实例是个单独的线程。要记住的基本事项是只有一个线程(通常是主线程)应该更新 GUI(通过after())。其他线程需要将东西放入Queues,主线程应该检查它们并根据它找到的内容更新 GUI。
  • 您还可以查看 .after() 方法(在 Tkinter 中),该方法允许您在 Tkinter 中运行函数而无需暂停 GUI。这也将消除使用线程模块的需要。

标签: python python-3.x multithreading user-interface tkinter


【解决方案1】:

所以经过几次尝试后,我想出了该怎么做:

from tkinter import *
import queue
import threading
from tkinter.ttk import *

class ThreadedTask(object):
    def __init__(self, parent):
        self.parent = parent        
        self.queue = queue.Queue()
        self.gui = MyGui(parent, self.queue)
        self.work_queue()

    def work_queue(self):
        """ Check every 100 ms if there is something new in the queue. """
        try:
            self.parent.after(200, self.work_queue)
            print('working queue with task {}...'.format(self.queue.get_nowait()))
        except queue.Empty:
            pass


# Gui class
class MyGui(Frame):
    def __init__(self, parent, queue):
        super().__init__(parent)
        self.parent = parent
        self.queue = queue
        self.init_ui()

    # define a button to fulfill long task
    def init_ui(self):   
        self.frame = Frame(self, relief=RAISED, borderwidth=1)
        self.frame.grid(row=0, column=0, columnspan=1, sticky='ns')
        self.status_frame = Frame(self, relief=RAISED, borderwidth=1, height=20)
        self.status_frame.grid(row=1, column=0, columnspan=3, sticky='nesw')
        self.status_frame.grid_configure(padx=3, pady=3)        
        self.button = Button(self.frame, text='do Stuff', command=self.init_button_loop)
        self.button.grid(padx=3, pady=3)
        self.progress = Progressbar(self.status_frame, orient="horizontal", length=80, mode="determinate")
        self.progress.grid(row=1, column=0, pady=3, sticky='nesw')
        self.grid()


    def start_thread(self, function_name, queue):
        t = threading.Thread(target=function_name, args=(queue,))
        # close thread automatically after finishing task
        t.setDaemon(True)
        t.start()

    # execute button push by spawning a new thread
    def init_button_loop(self):
        self.start_thread(self.exec_button_loop, self.queue)    

    # execute long task
    def exec_button_loop(self, queue):
        self.progress['maximum'] = 10000
        for i in range(10000):
            # update progressbar
            queue.put(self.progress.step())


# main
root = Tk()
root.geometry("150x80+50+50")
client = ThreadedTask(root)
root.mainloop()

困难在于弄清楚如何与队列和线程交互,同时在 gui 中按下按钮。

基本上我的错是在错误的类中声明队列以及错误使用after 函数而不知道从哪里启动线程。

新实现遵循在新线程中填充队列的原则,该线程在按下 gui 按钮时产生。从主线程定期检查队列是否有事情要做。这可以防止由于 gui 和主线程之间的安全通信而导致无响应。

【讨论】:

    猜你喜欢
    • 2015-10-27
    • 2019-06-12
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-12-11
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多