c++

c++ wait_for有哪些技巧

小樊
81
2024-11-24 11:59:58
栏目: 编程语言

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

  1. 使用 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;
    }
    
  2. 使用 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;
    }
    
  3. 结合 std::future::wait_forstd::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;
    }
    
  4. 使用 std::future::wait 的替代方案:如果你只需要检查异步操作是否已经完成,而不关心是否超时,可以使用 std::future::wait 代替 wait_forwait_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;
    }
    

0
看了该问题的人还看了