スレッド内でコルーチンを呼び出す

Question

スレッド実行メソッドasyncをコルーチンを内部で実行できるようにすることはできますか？私はパラダイムを混在させていることを認識しています。私はプロジェクトでスレッドを使用しているのに対し、コルーチンを使用するサードパーティのライブラリを統合しようとしています。代わりにコルーチンを使用するようにプロジェクトを更新する前に、スレッド内でコルーチンを実行する方法を調べたいと思います。

私はスレッドを持っていますが、私のスレッド内からコルーチンを呼びたい私の例usecaseです。私の問題は、関数MyThread::run()は実行されていないようです（印刷中）。私は可能なことをしようとしています...そしてお勧めですか？

from threading import Thread 

class MyThread(Thread): 

    def __init__(self): 
     Thread.__init__(self) 

     self.start() 

    # def run(self): 
    # while True: 
    #  print("MyThread::run() sync") 

    async def run(self): 
     while True: 
      # This line isn't executing/printing 
      print("MyThread::run() sync") 

      # Call coroutine... 
      # volume = await market_place.get_24h_volume() 


try: 
    t = MyThread() 

    while True: 
     pass 
except KeyboardInterrupt: 
    pass 

Answer 1

asyncioイベントループを作成し、コルーチンが完了するまで待つ必要があります。

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