concurrent.futures的个别超时

Question

我看到了在concurrent.futures中指定超时的两种方法。

• as_completed()
• wait()

这两种方法都处理N个运行期货。

我想为每个未来指定一个单独的超时。

用例：

• 将来从DB获取数据的超时时间为0.5秒。
• 从HTTP服务器获取数据的未来超时时间为1.2秒。

我如何用concurrent.futures来处理这个问题？还是这个库不是正确的工具？

结论

• AFAIK的解决方案是一个很好的解决方案。
• 我想下次我会用不同的图书馆。也许异步机对此有更好的支持。请参阅：https://docs.python.org/3/library/asyncio-task.html#asyncio.sleep

Answer 1

如何实现自己的：

wait(dbfutures + httpfutures, timeout=0.5)
[fut.cancel() for fut in bdfutures if not fut.done()]
wait(httpfutures, timeout=0.7)
[fut.cancel() for fut in httpfutures if not fut.done()]

(或带睡眠/检查的while循环或超时时间较短的等待)