wait_for
是 C++11 标准库 <future>
中的一个函数,用于等待一个异步操作完成。它接受两个参数:一个是 std::future
对象,另一个是表示等待时间的 std::chrono
对象。当异步操作完成时,wait_for
返回 std::future_status::ready
。如果等待时间到了但异步操作还没有完成,它将返回 std::future_status::timeout
。如果发生错误,它将返回 std::future_status::deferred
。
下面是一个使用 wait_for
的示例:
#include <iostream>
#include <chrono>
#include <future>
#include <thread>
int main() {
// 创建一个异步操作
std::packaged_task<int()> task([]() {
std::this_thread::sleep_for(std::chrono::seconds(2));
return 42;
});
// 获取与异步操作关联的 future 对象
std::future<int> result = task.get_future();
// 在一个新线程中运行异步操作
std::thread(std::move(task)).detach();
// 等待异步操作完成,最多等待 1 秒
std::chrono::seconds timeout(1);
std::future_status status = result.wait_for(timeout);
if (status == std::future_status::ready) {
// 异步操作已完成,获取结果
int value = result.get();
std::cout << "异步操作返回值: " << value << std::endl;
} else if (status == std::future_status::timeout) {
std::cout << "异步操作超时" << std::endl;
} else {
std::cout << "异步操作发生错误" << std::endl;
}
return 0;
}
在这个示例中,我们创建了一个异步任务,该任务在 2 秒后返回一个值。我们使用 wait_for
函数等待这个任务完成,但最多只等待 1 秒。因为任务需要 2 秒才能完成,所以 wait_for
返回 std::future_status::timeout
。