c++中std::promise和std::future的配合使用_c++线程间通信与异步结果获取机制

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

c++中std::promise和std::future的配合使用_c++线程间通信与异步结果获取机制

2025-11-18

浏览次数：次

返回列表

std::promise和std::future用于线程间传递异步结果，生产者通过promise设置值，消费者通过future获取结果，实现解耦与同步。

c++中std::promise和std::future的配合使用_c++线程间通信与异步结果获取机制

在C++多线程编程中，std::promise 和 std::future 提供了一种简洁高效的线程间通信方式，用于传递异步操作的结果。一个线程可以通过 std::promise 设置值或异常，另一个线程则通过关联的 std::future 获取该结果，实现解耦与异步等待。

基本概念与配合机制

std::promise 是一个可写的一次性容器，用于设置某个值或异常；std::future 是其对应的只读代理，用于在未来某个时间点获取这个值。两者通过共享状态关联。

典型使用流程如下：

创建一个 std::promise 对象
调用其 get_future() 方法获得对应的 std::future
将 promise 移动到生产者线程，future 移动到消费者线程
生产者调用 promise.set_value() 或 set_exception()
消费者调用 future.get() 阻塞等待并取得结果

简单示例：异步计算返回结果

以下代码展示主线程启动工作线程执行任务，并通过 promise/future 获取结果：

#include <iostream>
#include <thread>
#include <future>

void compute(std::promise<int>&& prom) {
    int result = 42; // 模拟耗时计算
    prom.set_value(result);
}

int main() {
    std::promise<int> prom;
    std::future<int> fut = prom.get_future();

    std::thread t(compute, std::move(prom));

    std::cout << "等待结果...\n";
    int value = fut.get(); // 阻塞直到结果可用
    std::cout << "得到结果: " << value << "\n";

    t.join();
    return 0;
}

注意：必须确保 promise 被正确移动，且只能调用一次 set_value，否则会抛出异常。

异常传递与错误处理

除了正常值，std::promise 还能传递异常，使消费者端能捕获并处理错误：

Whimsical

Whimsical推出的AI思维导图工具

182 查看详情 Whimsical

void may_fail(std::promise<double>&& prom) {
    try {
        // 模拟可能失败的操作
        throw std::runtime_error("计算失败");
    } catch (...) {
        prom.set_exception(std::current_exception());
    }
}

在调用 future.get() 时，若设置了异常，则该异常会被重新抛出，可在 catch 块中处理。