wait_for
是 C++11 标准库 <future>
中的一个函数,它用于等待一个异步操作完成。wait_for
函数接受两个参数:一个是 std::future
对象,另一个是一个时间间隔。当 std::future
对象的状态变为 ready(即异步操作已完成)时,wait_for
将返回 true;否则,它将返回 false。
以下是一个简单的示例,展示了如何使用 wait_for
函数:
#include <iostream>
#include <chrono>
#include <thread>
#include <future>
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 task_thread(std::move(task));
task_thread.detach();
// 等待异步任务完成,最多等待 3 秒
if (std::future_status::ready == std::wait_for(result, std::chrono::seconds(3))) {
// 异步任务已完成,获取结果并输出
int value = result.get();
std::cout << "异步任务返回值: " << value << std::endl;
} else {
// 异步任务未完成,输出提示信息
std::cout << "异步任务未完成,已超时" << std::endl;
}
return 0;
}
在这个示例中,我们创建了一个异步任务,该任务在 2 秒后返回一个值。我们使用 std::packaged_task
来包装任务,然后通过 get_future
获取与任务关联的 std::future
对象。接下来,我们启动一个新线程来执行异步任务,并使用 wait_for
函数等待任务完成。如果任务在 3 秒内完成,我们将获取结果并输出;否则,我们将输出提示信息。