在C++中,要实现类似于JavaScript中的Promise的then
链式调用,你可以使用C++11的std::future
和std::promise
,以及一些模板函数来封装这些功能。下面是一个简单的示例:
#include<iostream>
#include <future>
#include<functional>
#include<vector>
template<typename T, typename Func>
auto then(std::future<T>& future, Func&& func) -> std::future<decltype(func(std::declval<T>()))> {
auto promise = std::make_shared<std::promise<decltype(func(std::declval<T>()))>>();
auto nextFuture = promise->get_future();
std::thread([promise, &future, func]() {
try {
auto result = future.get();
promise->set_value(func(result));
} catch (...) {
promise->set_exception(std::current_exception());
}
}).detach();
return nextFuture;
}
int main() {
// 创建一个异步任务并返回一个std::future对象
std::future<int> future = std::async(std::launch::async, []() {
// 模拟长时间运行的任务
std::this_thread::sleep_for(std::chrono::seconds(1));
return 42;
});
// 使用then链式调用
auto resultFuture = then(future, [](int value) {
std::cout << "Task 1 completed with value: "<< value<< std::endl;
return value * 2;
});
// 获取最终结果
int result = resultFuture.get();
std::cout << "Final result: "<< result<< std::endl;
return 0;
}
在这个示例中,我们定义了一个名为then
的模板函数,它接受一个std::future
对象和一个函数作为参数。这个函数将在前一个异步任务完成后被调用,并将其结果传递给下一个任务。通过这种方式,你可以实现链式调用,就像在JavaScript中使用then
一样。
请注意,这个示例仅用于演示目的,实际应用中可能需要更复杂的错误处理和资源管理。此外,这个示例使用了std::thread
来执行异步任务,但在实际项目中,你可能会使用更高级的线程池或任务队列来管理并发任务。