wait_for
是 C++11 标准库
中的一个函数,用于等待一个异步操作完成
-
使用
std::chrono
进行时间控制:wait_for
接受一个std::chrono::duration
参数,允许你指定等待的最长时间。例如,如果你想要等待一个异步操作在 5 秒内完成,可以使用std::chrono::seconds(5)
作为参数。#include
#include #include int main() { std::promise prom; std::future 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
#include #include int main() { std::promise prom; std::future 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
#include #include int main() { std::promise prom; std::future 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
#include int main() { std::promise prom; std::future 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; }