温馨提示×

c++ wait_for如何运用

c++
小樊
81
2024-11-24 12:02:51
栏目: 编程语言

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 对象中获取结果并输出。否则,我们将输出一条消息,指示任务未在超时时间内完成。

0