Python - asynchrone Methoden über Threading verwalten

Question

In meinem Python Script erhalte ich einen konstanten Datenfluss, möchte aber die Daten asynchron durch Aufruf einer asynchronen Methode pushen. Die Daten, die in einem Puffer vorhanden sind, werden immer gepuffert, wenn die Methode verfügbar ist.

Um dies zu erreichen, habe ich einen try/catch, der ständig aufgerufen wird, der ein Thread-Objekt erstellt, das eine Methode ausführt (und ich nehme an, wenn die Methode beendet wird) und wenn der Thread die try/catch Breaks ausführt .

import thread 
import threading 
thr = None 
...  

try: 
    if thr.is_alive(): 
    print "thread running" 
    else: 
    thr.Thread(target=move_current_data, args=(data_buffer)) 
    thr.start() 
    data_buffer.clear() 
except NameError: 
    print "" 
except AttributeError: 
    print "  


def move_current_data(data_buffer): 
...  
    return 

Wäre es einfacher und sauberer, dies zu schreiben?

kann ich weitere Informationen zur Verfügung stellen, wenn

benötigt

Answer 1

Sie eine Warteschlange verwendet werden soll. Ein Thread hat nur die Aufgabe, die Warteschlange zu überwachen und neue Daten auszugeben. Der Haupt-Thread wird nur zur Warteschlange hinzugefügt, wenn neue Daten verfügbar sind.

Beispiel:

import threading 
import queue 

def pusher(q): 
    while True: 
    item = q.get() 
    if item is None: 
     return   # exit thread 
    ...push data... 

def main(): 
    q = Queue.Queue() 
    # start up the pusher thread 
    t = threading.Thread(target = pusher, args=(q)) 
    t.start() 

    # add items 
    q.put(item1) 
    ... 
    q.put(item2) 
    ... 
    ... 
    # tell pusher to shut down when queue is empty 
    # and wait for pusher to complete 
    q.put(None) 
    t.join() 

anzumerken, dass q.put(...) nicht den Haupt-Thread nicht blockiert.