温馨提示×

c++ wait_for如何达成

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

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 <thread>
#include <future>

int main() {
    // 创建一个异步操作
    std::packaged_task<int()> task([]() {
        std::this_thread::sleep_for(std::chrono::seconds(2)); // 模拟耗时操作
        return 42;
    });

    // 获取异步操作的结果包装器
    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;
}

在这个示例中,我们创建了一个异步操作 task,它会在 2 秒后返回一个值。然后我们使用 get_future 获取异步操作的结果包装器 result,并启动一个新线程执行 task。接下来,我们使用 wait_for 等待异步操作完成,最多等待 1 秒。根据 wait_for 的返回值,我们可以判断异步操作是否已完成。

0