python - 如何将异步函数传递给 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()