c++ wait_for有哪些技巧

wait_for 是 C++11 标准库 <future> 中的一个函数，用于等待一个异步操作完成

使用 std::chrono 进行时间控制：wait_for 接受一个 std::chrono::duration 参数，允许你指定等待的最长时间。例如，如果你想要等待一个异步操作在 5 秒内完成，可以使用 std::chrono::seconds(5) 作为参数。

#include <iostream>
#include <chrono>
#include <future>

int main() {
    std::promise<int> prom;
    std::future<int> fut = prom.get_future();

    std::thread([&]() {
        std::this_thread::sleep_for(std::chrono::seconds(3));
        prom.set_value(42);
    }).detach();

    if (fut.wait_for(std::chrono::seconds(5)) == std::future_status::ready) {
        std::cout << "Async operation completed within the timeout." << std::endl;
    } else {
        std::cout << "Async operation did not complete within the timeout." << std::endl;
    }

    return 0;
}

使用 std::future::wait_until 等待特定时间点：wait_until 接受一个 std::chrono::time_point 参数，允许你指定等待到何时。例如，如果你想要等待一个异步操作在 5 秒后完成，可以使用 std::chrono::system_clock::now() + std::chrono::seconds(5) 作为参数。

#include <iostream>
#include <chrono>
#include <future>

int main() {
    std::promise<int> prom;
    std::future<int> fut = prom.get_future();

    std::thread([&]() {
        std::this_thread::sleep_for(std::chrono::seconds(3));
        prom.set_value(42);
    }).detach();

    if (fut.wait_until(std::chrono::system_clock::now() + std::chrono::seconds(5)) == std::future_status::ready) {
        std::cout << "Async operation completed after the specified time point." << std::endl;
    } else {
        std::cout << "Async operation did not complete after the specified time point." << std::endl;
    }

    return 0;
}

结合 std::future::wait_for 和 std::future::wait_until：你可以同时使用这两个函数来更精确地控制等待时间。例如，你可以先使用 wait_for 等待一个较短的时间，然后使用 wait_until 等待一个特定的时间点。

#include <iostream>
#include <chrono>
#include <future>

int main() {
    std::promise<int> prom;
    std::future<int> fut = prom.get_future();

    std::thread([&]() {
        std::this_thread::sleep_for(std::chrono::seconds(3));
        prom.set_value(42);
    }).detach();

    if (fut.wait_for(std::chrono::seconds(2)) == std::future_status::ready) {
        std::cout << "Async operation completed within the first timeout." << std::endl;
    } else {
        std::cout << "Async operation did not complete within the first timeout." << std::endl;
        if (fut.wait_until(std::chrono::system_clock::now() + std::chrono::seconds(5)) == std::future_status::ready) {
            std::cout << "Async operation completed after the specified time point." << std::endl;
        } else {
            std::cout << "Async operation did not complete after the specified time point." << std::endl;
        }
    }

    return 0;
}

使用 std::future::wait 的替代方案：如果你只需要检查异步操作是否已经完成，而不关心是否超时，可以使用 std::future::wait 代替 wait_for 或 wait_until。但请注意，wait 会阻塞当前线程，直到异步操作完成。

#include <iostream>
#include <future>

int main() {
    std::promise<int> prom;
    std::future<int> fut = prom.get_future();

    std::thread([&]() {
        std::this_thread::sleep_for(std::chrono::seconds(3));
        prom.set_value(42);
    }).detach();

    fut.wait(); // 阻塞当前线程，直到异步操作完成
    std::cout << "Async operation completed." << std::endl;

    return 0;
}

最新问答

相关标签