C++标准库中的std::future和std::promise为异步任务之间的结果传递提供了原生支持,通过组合使用这两个组件,我们可以实现多个异步任务按顺序执行的链式逻辑,让前一个任务的输出作为后一个任务的输入,避免回调嵌套带来的代码复杂度问题。

std::future与std::promise核心概念
std::promise是用来存储异步任务结果的容器,我们可以在异步线程中向promise设置值或者异常。std::future则是用来获取promise中存储结果的通道,调用future的get方法会阻塞当前线程,直到promise中设置了结果或者异常。
二者通常成对使用,一个promise对应一个future,通过共享状态来传递数据,共享状态由标准库自动管理,不需要开发者手动处理生命周期问题。
任务链式异步执行的设计思路
要实现任务链式异步,核心思路是每个任务执行完成后,将其结果通过promise传递给下一个任务的future,同时下一个任务在启动时就等待前一个任务的结果,这样就能保证任务按顺序执行。具体步骤如下:
- 定义任务函数,任务函数接收前一个任务的future作为参数,同时返回自己的promise和对应的future
- 前一个任务执行完成后,将结果设置到自己的promise中
- 后一个任务从传入的future中获取前一个任务的结果,再执行自身的逻辑,最后设置自己的promise结果
- 不断重复上述过程,就能形成任务链
完整源码实现
下面是一个简单的任务链式异步执行示例,包含三个依次执行的异步任务,每个任务都会接收前一个任务的输出作为输入:
#include <iostream>
#include <future>
#include <thread>
#include <chrono>
// 第一个任务,无输入,返回int类型结果
std::pair<std::promise<int>, std::future<int>> task1() {
std::promise<int> pro;
std::future<int> fut = pro.get_future();
// 启动异步线程执行任务
std::thread([p = std::move(pro)]() mutable {
std::this_thread::sleep_for(std::chrono::seconds(1));
std::cout << "任务1执行完成,结果:10" << std::endl;
p.set_value(10); // 设置任务结果
}).detach();
return {std::move(pro), std::move(fut)};
}
// 第二个任务,接收int类型输入,返回int类型结果
std::pair<std::promise<int>, std::future<int>> task2(std::future<int> prev_fut) {
std::promise<int> pro;
std::future<int> fut = pro.get_future();
std::thread([p = std::move(pro), f = std::move(prev_fut)]() mutable {
// 等待前一个任务的结果
int prev_result = f.get();
std::this_thread::sleep_for(std::chrono::seconds(1));
int cur_result = prev_result * 2;
std::cout << "任务2执行完成,输入:" << prev_result << ",结果:" << cur_result << std::endl;
p.set_value(cur_result);
}).detach();
return {std::move(pro), std::move(fut)};
}
// 第三个任务,接收int类型输入,返回string类型结果
std::pair<std::promise<std::string>, std::future<std::string>> task3(std::future<int> prev_fut) {
std::promise<std::string> pro;
std::future<std::string> fut = pro.get_future();
std::thread([p = std::move(pro), f = std::move(prev_fut)]() mutable {
int prev_result = f.get();
std::this_thread::sleep_for(std::chrono::seconds(1));
std::string cur_result = "最终结果:" + std::to_string(prev_result + 5);
std::cout << "任务3执行完成,输入:" << prev_result << ",结果:" << cur_result << std::endl;
p.set_value(cur_result);
}).detach();
return {std::move(pro), std::move(fut)};
}
int main() {
// 启动任务链
auto [pro1, fut1] = task1();
auto [pro2, fut2] = task2(std::move(fut1));
auto [pro3, fut3] = task3(std::move(fut2));
// 获取最终任务结果
std::string final_result = fut3.get();
std::cout << "链式任务最终输出:" << final_result << std::endl;
return 0;
}
实现注意事项
在实际使用这种链式异步逻辑时,需要注意以下几点:
- promise和future的转移需要使用std::move,因为二者都不支持拷贝构造,只能移动
- 如果异步任务中可能抛出异常,需要使用set_exception方法将异常设置到promise中,后续调用future的get方法时会重新抛出该异常
- 不要重复调用promise的set_value或者set_exception,否则会抛出std::future_error异常
- 如果任务链较长,可以考虑封装成通用的链式调用接口,减少重复代码
总结
基于std::future和std::promise实现任务链式异步执行,核心是利用二者的共享状态传递任务结果,让后续任务等待前置任务的结果后再执行。这种方式不需要复杂的回调嵌套,代码结构更清晰,也符合C++标准库的异步编程范式。开发者可以根据实际需求调整任务函数的参数和返回值类型,适配不同的业务场景。
std::futurestd::promise任务链式异步C++异步编程修改时间:2026-06-14 15:57:36