Python Tkinter 多线程函数

Question

我目前正在使用来自 python 的 tkinter 库开发电子邮件发件人和接收程序。我正在使用线程模块使程序每 60 秒刷新一次未读电子邮件，同时您仍然可以继续在程序中执行操作。

threading 模块在执行 print("something") 命令时就可以工作，我仍然可以继续在程序中做一些事情。但是，当我让线程登录到 gmail 并获取未读电子邮件计数时，整个程序卡住并崩溃。

下面是我的代码片段。我不会发布完整的代码，我做了一个简短的版本来展示它的外观。

编辑:在功能上犯了一个小错误。 get_credentials() 已删除。

import tkinter, re, threading, time, imaplib, too many to list here.
class Application(Frame):

def __init__(self, parent):
        ... Start some functions
        ... Create some widgets
        ... Create some global stringvars for entry fields

def threadrefresh(self):#I want to start this function when a button is clicked

        def multithreading():

            usernamevar = "Username"
            passwordvar = "Password"

            obj = imaplib.IMAP4_SSL('imap.gmail.com', '993') #connect to gmail
            obj.login(usernamevar, passwordvar) #log in
            obj.select() #select the inbox
            unread = str(len(obj.search(None, 'UnSeen')[1][0].split())) #get the total unread
            print(unread)
            obj.close()

            time.sleep(3)
            multi = threading.Thread(target=multithreading)
            multi.start()

        multi = threading.Thread(target=multithreading)
        multi.start()

def other_functions_that_do_not_matter_in_this_case():
    ... Creating GUI
    ... Sending mail
    ... Etc.
    ... Create a button with function call self.threadrefresh


def main():
    root = Tk()
    app = Application(root)
    root.mainloop()

if __name__ == '__main__':
    main() 

Answer 1

这段代码真的正确吗？

你在多线程中调用它:

time.sleep(3)
multi = threading.Thread(target=multithreading)
multi.start()

你基本上是在告诉每个线程在 3 秒后创建自己的副本......我认为你错过了线程的要点。您可能应该有一个(单个)线程在 while 循环中运行，该线程从 Queue 获取数据。 .

每当您希望线程对某事进行操作时，您将其添加到队列中。

编辑:示例代码

import threading
import Queue
import time

def f(q):
    while True:
        print q.get() #block thread until something shows up

q = Queue.Queue()
t = threading.Thread(target=f,args=[q])
t.daemon = True #if parent dies, kill thread
t.start()
for x in range(0,1000):
    q.put(x)
    time.sleep(1)