wait_for
是 C++11 標準庫 <future>
中的一個函數,用于等待一個異步操作完成
下面是一個簡單的示例,展示了如何使用 wait_for
:
#include <iostream>
#include <chrono>
#include <future>
int calculate_sum(int a, int b) {
std::this_thread::sleep_for(std::chrono::seconds(2)); // 模擬一個耗時操作
return a + b;
}
int main() {
// 創建一個異步任務
std::packaged_task<int(int, int)> task(calculate_sum);
std::future<int> result = task.get_future();
// 在一個新線程中運行異步任務
std::thread(std::move(task), 5, 3).detach();
// 等待異步任務完成,最多等待 3 秒
if (result.wait_for(std::chrono::seconds(3)) == std::future_status::ready) {
std::cout << "Sum is: " << result.get() << std::endl;
} else {
std::cout << "Task did not complete within the timeout period." << std::endl;
}
return 0;
}
在這個示例中,我們創建了一個名為 calculate_sum
的函數,它接受兩個整數參數并返回它們的和。為了模擬一個耗時操作,我們讓函數休眠 2 秒。
在 main
函數中,我們創建了一個 std::packaged_task
對象,將 calculate_sum
函數作為其目標。然后,我們通過調用 get_future
函數獲取一個 std::future
對象,該對象將存儲異步任務的結果。
接下來,我們在一個新線程中運行異步任務,并將其與 std::packaged_task
對象一起移動到新線程。
最后,我們使用 wait_for
函數等待異步任務完成,最多等待 3 秒。如果異步任務在 3 秒內完成,我們將從 std::future
對象中獲取結果并輸出。否則,我們將輸出一條消息,指示任務未在超時時間內完成。