我有以下代码:
async some_callback(args):
await some_function()
我需要将它作为目标传递给线程:
_thread = threading.Thread(target=some_callback, args=("some text"))
_thread.start()
我得到的错误是“some_callback
永远不会被等待”。
我有什么想法可以解决这个问题吗?
您可以通过在执行异步之间添加函数来做到这一点:
import asyncio
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()
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)