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
的返回值,我們可以判斷異步操作是否已完成。