wait_for
是 C++11 标准库 <future>
中的一个函数,用于等待一个异步操作完成
下面是一个简单的示例,展示了如何使用 wait_for
:
#include <iostream>
#include <chrono>
#include <future>
int calculate_sum(int a, int b) {
std::this_thread::sleep_for(std::chrono::seconds(2)); // 模拟一个耗时操作
return a + b;
}
int main() {
// 创建一个异步任务
std::packaged_task<int(int, int)> task(calculate_sum);
std::future<int> result = task.get_future();
// 在一个新线程中运行异步任务
std::thread(std::move(task), 5, 3).detach();
// 等待异步任务完成,最多等待 3 秒
if (result.wait_for(std::chrono::seconds(3)) == std::future_status::ready) {
std::cout << "Sum is: " << result.get() << std::endl;
} else {
std::cout << "Task did not complete within the timeout period." << std::endl;
}
return 0;
}
在这个示例中,我们创建了一个名为 calculate_sum
的函数,它接受两个整数参数并返回它们的和。为了模拟一个耗时操作,我们让函数休眠 2 秒。
在 main
函数中,我们创建了一个 std::packaged_task
对象,将 calculate_sum
函数作为其目标。然后,我们通过调用 get_future
函数获取一个 std::future
对象,该对象将存储异步任务的结果。
接下来,我们在一个新线程中运行异步任务,并将其与 std::packaged_task
对象一起移动到新线程。
最后,我们使用 wait_for
函数等待异步任务完成,最多等待 3 秒。如果异步任务在 3 秒内完成,我们将从 std::future
对象中获取结果并输出。否则,我们将输出一条消息,指示任务未在超时时间内完成。