我看到两种指定超时的方法concurrent.futures.

• as_completed()
• wait()

两种方法都处理N运行期货.

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

使用案例:

• 从数据库获取数据的未来超时为0.5秒.
• 从HTTP服务器获取数据的未来超时为1.2秒.

我该如何处理concurrent.futures？或者这个库不是正确的工具吗？

结论

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

我正在玩concurrent.futures.

目前我未来的电话time.sleep(secs).

似乎Future.cancel()比我想象的要少.

如果未来已经在执行,那么time.sleep()就不会取消它.

对于wait()的timeout参数也是如此.它不会取消我的time.sleep().

如何取消time.sleep()在concurrent.futures中执行哪些？

为了测试我使用ThreadPoolExecutor.