Wenn asyncio verwenden, wie können Sie alle laufenden Aufgaben vor beenden die Ereignisschleife Abschalten

Question

ich den folgenden Code haben:

@asyncio.coroutine 
def do_something_periodically(): 
    while True: 
     asyncio.async(my_expensive_operation()) 
     yield from asyncio.sleep(my_interval) 
     if shutdown_flag_is_set: 
      print("Shutting down") 
      break 

ich diese Funktion bis zur vollständigen laufen. Das Problem tritt auf, wenn Herunterfahren festgelegt ist - die Funktion wird beendet und alle ausstehenden Aufgaben werden nie ausgeführt. (Sie sehen dies als Fehler

task: <Task pending coro=<report() running at script.py:33> wait_for=<Future pending cb=[Task._wakeup()]>> 

). Wie plane ich ein Herunterfahren korrekt?

Um einen Kontext zu geben, schreibe ich einen Systemmonitor, der alle 5 Sekunden aus/proc/stat liest, die CPU-Nutzung in diesem Zeitraum berechnet und dann das Ergebnis an einen Server sendet. Ich möchte diese Überwachungsjobs so lange planen, bis ich signerm erhalte, wenn ich mit der Planung aufhöre, auf den Abschluss aller aktuellen Jobs warte und elegant aus dem System auschecke.

Answer 1

Sie können nicht abgeschlossene Aufgaben abrufen und die Schleife erneut ausführen, bis sie beendet sind, dann die Schleife schließen oder Ihr Programm beenden.

pending = asyncio.Task.all_tasks() 
loop.run_until_complete(asyncio.gather(*pending)) 

• anhängig ist eine Liste der anstehenden Aufgaben.
• asyncio.gather() erlaubt, auf mehrere Aufgaben gleichzeitig zu warten.

Wenn Sie alle Aufgaben, um sicherzustellen, dass in einem Koroutine (vielleicht haben Sie eine „Haupt“ Koroutine haben) abgeschlossen ist, können Sie es auf diese Weise tun, zum Beispiel:

@asyncio.coroutine 
def do_something_periodically(): 
    while True: 
     asyncio.async(my_expensive_operation()) 
     yield from asyncio.sleep(my_interval) 
     if shutdown_flag_is_set: 
      print("Shutting down") 
      break 

    yield from asyncio.gather(*asyncio.Task.all_tasks()) 

Auch in dieser Fall, da alle Aufgaben in der gleichen Koroutine erstellt werden, haben Sie bereits Zugriff auf die Aufgaben:

@asyncio.coroutine 
def do_something_periodically(): 
    tasks = [] 
    while True: 
     tasks.append(asyncio.async(my_expensive_operation())) 
     yield from asyncio.sleep(my_interval) 
     if shutdown_flag_is_set: 
      print("Shutting down") 
      break 

    yield from asyncio.gather(*tasks)