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;
}