Aufruf Coroutine in Thread

Question

Ist es möglich, einen Thread ausführen Methode async, so dass es Coroutinen in ihm ausführen kann? Mir ist klar, dass ich Paradigmen mische - ich versuche eine 3rd-Party-Bibliothek zu integrieren, die Coroutinen verwendet, während mein Projekt Threads verwendet. Bevor ich in Erwägung ziehe, mein Projekt so zu aktualisieren, dass ich stattdessen Coroutines verwende, möchte ich die Ausführung von Coroutinen in meinen Threads untersuchen.

Unten ist mein Beispiel Usecase, wo ich einen Thread habe, aber ich möchte eine Coroutine aus meinem Thread aufrufen. Mein Problem ist die Funktion MyThread::run() scheint nicht ausgeführt werden (Drucken). Ist das, was ich versuche, möglich ... und ratsam?

Answer 1

Sie müssen eine asyncio Ereignisschleife erstellen und warten, bis die Coroutine abgeschlossen ist.

import asyncio 
from threading import Thread 


class MyThread(Thread): 
    def run(self): 
     loop = asyncio.new_event_loop() 
     loop.run_until_complete(self._run()) 
     loop.close() 

    async def _run(self): 
     while True: 
      print("MyThread::run() sync") 
      await asyncio.sleep(1) 
      # OR 
      # volume = await market_place.get_24h_volume() 


t = MyThread() 
t.start() 
try: 
    t.join() 
except KeyboardInterrupt: 
    pass