如何将异步函数传递给 Python 中的线程目标？

Question

我有以下代码：

async some_callback(args):
    await some_function()

我需要将它作为目标提供给一个线程：

_thread = threading.Thread(target=some_callback, args=("some text"))
_thread.start()

我得到的错误是“some_callback从未等待”。
任何想法如何解决这个问题？

Answer 1

您可以通过在执行异步之间添加函数来实现：

async def some_callback(args):
    await some_function()

def between_callback(args):
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)

    loop.run_until_complete(some_callback(args))
    loop.close()

_thread = threading.Thread(target=between_callback, args=("some text"))
_thread.start()

Answer 2

从 Python 3.7 开始，您可以使用asyncio.run()比loop.run_until_complete()以下更简单的方法：

_thread = threading.Thread(target=asyncio.run, args=(some_callback("some text"),))
_thread.start()