如何将异步线与Python中的其他线程一起运行？

Question

我正在尝试与其他线程一起运行异步Run_forever。但是我只从永远的线程中获得输出，让我认为第二个线程甚至没有启动。

代码 - class.py：code

import asyncio

class Class1:
    def __init__(self):
        self.loop = asyncio.get_event_loop()

    async def _funcClass1(self):
        while True:
            await asyncio.sleep(5)
            print('Hello async/threading world')

    def funcClass1(self):
        asyncio.ensure_future(self._funcClass1())
        self.loop.run_forever()

class Class2:
    def __init__(self):
        self.loop = asyncio.get_event_loop()
    
    async def _funcClass2(self, name):
        print(f'Hello {name}')
    
    def funcClass2(self):
        self.loop.run_until_complete(self._funcClass2())

-main.py：

from Classes import Class1, Class2
import threading
import asyncio

class1 = Class1()
class2 = Class2()

if __name__ == "__main__":
    t1 = threading.Thread(target=asyncio.run, args=(class1.funcClass1(), ))
    t2 = threading.Thread(target=class2.funcClass2, args=('john', ))

    t1.start()
    t2.start()

    t1.join()
    t2.join()

输出：

Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world
Hello async/threading world

Answer 1

在播放@danangjoyoo的答案之后。我想到了这一点（两个功能都需要以target = asyncio.run>）：

class.py.py：

import asyncio

class Class1:
    def __init__(self):
        self.loop = asyncio.get_event_loop()

    async def _funcClass1(self):
        while True:
            await asyncio.sleep(5)
            print('Hello async/threading world')

    def funcClass1(self):
        asyncio.ensure_future(self._funcClass1())

class Class2:
    def __init__(self):
        self.loop = asyncio.get_event_loop()
    
    async def _funcClass2(self, name):
        print(f'Hello {name}')
    
    def funcClass2(self, name):
        asyncio.ensure_future(self._funcClass2(name))

main.py.py：

from Classes import Class1, Class2
import threading
import asyncio

class1 = Class1()
class2 = Class2()

if __name__ == "__main__":
    t1 = threading.Thread(target=asyncio.run, args=(class1.funcClass1()))
    t2 = threading.Thread(target=asyncio.run, args=(class2.funcClass2('john')))

    class1.loop.run_forever()
    class2.loop.run_until_complete()

    t1.start()
    t2.start()

    t1.join()
    t2.join()

Answer 2

run_forever（）将阻止代码的下一行。

运行第二个线程

class.py

import asyncio

class Class1:
    def __init__(self):
        self.loop = asyncio.get_event_loop()

    async def _funcClass1(self):
        while True:
            await asyncio.sleep(5)
            print('Hello async/threading world')

    def funcClass1(self):
        asyncio.ensure_future(self._funcClass1())

class Class2:
    def __init__(self):
        self.loop = asyncio.get_event_loop()
    
    async def _funcClass2(self, name):
        print(f'Hello {name}')
    
    def funcClass2(self):
        self.loop.run_until_complete(self._funcClass2())

main.py.py之后，请尝试将其放置。

from Classes import Class1, Class2
import threading
import asyncio

class1 = Class1()
class2 = Class2()

if __name__ == "__main__":
    t1 = threading.Thread(target=asyncio.run, args=(class1.funcClass1(), ))
    t2 = threading.Thread(target=class2.funcClass2, args=('john', ))

    t1.start()
    t2.start()

    class1.loop.run_forever()

    t1.join()
    t2.join()