tkinter bevölkern Baumansicht mit Threading Pool

Question

Ich bin auf der Suche nach "beste" Möglichkeit, Treeview mit Threads zu füllen. Ich habe mehrere E-Mail-Konten, die ich auf neue E-Mails überprüfe.

Mein Plan ist Queue zu verwenden Konten zu speichern, die mit check_mail Methode geprüft werden. Diese Methode wird eine Liste von neuen Mails zurückgeben.

Kann ich einen anderen Queue verwenden, den ich mit neuen Mails befüllen werde und irgendwie Schleife, während Threads leben?

Gibt es irgendein fadensicheres, gutes Muster, um das zu lösen?

Answer 1

Ihre Frage ist sehr breit, also wird diese Antwort auch sein.

Im Allgemeinen spielt tkinter nicht gut mit Multithreading. Sie können es tun, müssen aber sicherstellen, dass nur der Haupt-Thread mit der GUI interagiert. Ein üblicher Weg, dies zu tun, besteht darin, die universal widget methodafter() zu verwenden, um die Behandlung von Daten, die zu Hintergrundthreads ausgehen oder von diesen abgerufen werden, typischerweise in regelmäßigen Abständen über Queue s zu planen.

Answer 2

Ich bin mir nicht sicher, ob dies die beste Idee ist, aber es funktioniert

class Main(tk.Frame): 

    def __init__(self, master):  
     tk.Frame.__init__(self, master) 
     self.master = master 
     self.some_service = SomeService() 
     self.some_service.run() 
     self.init_gui() 
     self.after(60000, self.check_for_updates) # Use it to run service 
     self.after(2000, self.update_gui) # Update GUI every 2 seconds. 

    def check_for_updates(self): 
     data = ['a', 'b', 'c', 'd'] 
     self.some_service.populate_job_queue(data) 
     self.after(60000, self.check_for_updates) 

    def update_gui(self): 
     if not self.some_service.update_queue.empty(): 
      update = self.some_service.update_queue.get() 
      ## Do something with update ## 
      self.text.insert(tk.END, update) 
     self.after(2000, self.update_gui) 


class SomeService(object): 

    def __init__(self): 
     self.update_queue = Queue() 
     self.job_queue = Queue() 

    def populate_job_queue(self, jobs): 
     for job in jobs: 
      self.job_queue.put(job) 

    def run(self): 
     for x in range(8): 
      worker = Thread(target=self.do_something, daemon=True) 
      worker.start() 

    def do_something(self): 
     ## Do something with data 
     while True: 
      if not self.job_queue.empty(): 
       job = self.job_queue.get() 
       # Do something 
       self.update_queue.put(some_data)