線程內調用協程

Question

是否有可能使線程運行方法異步，因此它可以在其內部執行協程？我意識到我是混合範例 - 我試圖集成使用協同程序的第三方庫，而我的項目使用線程。在考慮更新我的項目來使用協程，而不是我想探索在我的線程中執行協程。

下面是我的示例用例，我有一個線程，但我想從我的線程中調用一個協程。我的問題是功能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