std::shared_future<T>::wait_for
来自 cppreference.com
< cpp | thread | shared future
template< class Rep, class Period > std::future_status wait_for( const std::chrono::duration<Rep,Period>& timeout_duration ) const; |
(自 C++11) | |
等待结果变为可用。阻塞直到指定的 timeout_duration 已过或结果变为可用,以先发生者为准。返回值标识结果的状态。
如果期货是调用 std::async 时使用的延迟评估的结果,则此函数立即返回而不等待。
由于调度或资源争用延迟,此函数可能会阻塞的时间比 timeout_duration 更长。
标准建议使用稳定时钟来测量持续时间。如果实现使用系统时钟,则等待时间也可能对时钟调整敏感。
如果在调用此函数之前 valid() 为 false,则行为未定义。
内容 |
[编辑] 参数
timeout_duration | - | 最大阻塞时长 |
[编辑] 返回值
常量 | 说明 |
future_status::deferred | 共享状态包含一个使用延迟评估的延迟函数,因此结果将仅在显式请求时计算 |
future_status::ready | 结果已准备好 |
future_status::timeout | 超时已过期 |
[编辑] 异常
在执行期间由时钟、时间点或持续时间抛出的任何异常(标准库提供的时钟、时间点和持续时间从不抛出异常)。
[编辑] 备注
鼓励实现检测 valid == false 在调用之前的情况并抛出一个 std::future_error 具有错误条件的 std::future_errc::no_state.
[编辑] 示例
运行此代码
#include <chrono> #include <future> #include <iostream> #include <thread> using namespace std::chrono_literals; int main() { std::shared_future<int> future = std::async(std::launch::async, []() { std::this_thread::sleep_for(3s); return 8; }); std::cout << "waiting...\n"; std::future_status status; do { switch (status = future.wait_for(1s); status) { case std::future_status::deferred: std::cout << "deferred\n"; break; case std::future_status::timeout: std::cout << "timeout\n"; break; case std::future_status::ready: std::cout << "ready!\n"; break; } } while (status != std::future_status::ready); std::cout << "result is " << future.get() << '\n'; }
可能的输出
waiting... timeout timeout timeout ready! result is 8
[编辑] 另请参见
等待结果变为可用 (公共成员函数) | |
等待结果,如果结果在指定时间点到达之前不可用,则返回 (公共成员函数) |