我正在使用asyncio来运行一段类似于以下阻塞代码的程序:
result = await loop.run_in_executor(None, long_running_function)
我的问题是:我能给long_running_function
添加执行超时吗?
基本上我不希望long_running_function
持续时间超过2秒,而且因为该函数来自第三方库,我无法在其中进行适当的超时处理。
loop.run_in_executor()
包装在wait_for()
中,wait_for()
函数接受一个超时参数。 - songololo