C++ Boost异步编程：Futures与Promises线程协作详解

巷口听风

发布时间：2026-10-16| 6人浏览过

原创

本文详细介绍如何使用C++ Boost库中的Future和Promise机制进行线程间数据传递。通过三个递进的代码示例（promise/future、packaged_task、boost::async），演示如何安全地在不同线程中共享计算结果，掌握异步编程的核心操作与参数配置。

核心概念：线程间数据同步工具

Futures（未来）和 Promises（承诺）是C++标准库及Boost库中用于在多线程环境中安全传递数据的关键组件。它们的出现简化了传统的同步流程，开发者无需手动管理互斥锁或条件变量即可实现一个线程向另一个线程传递值。

#define BOOST_THREAD_PROVIDES_FUTURE
#include 
#include 
#include 
#include 

void accumulate(boost::promise &p)
{
  int sum = 0;
  for (int i = 0; i < 5; ++i)
    sum += i;
  p.set_value(sum);
}

int main()
{
  boost::promise p;
  boost::future f = p.get_future();
  boost::thread t{accumulate, std::ref(p)};
  
  // 阻塞直到accumulate线程完成并设置值
  std::cout << f.get() << '\n';
}

在上述代码中，主线程创建了一个promise对象，并通过get_future()获取关联的future对象。随后，将promise的引用传递给新创建的线程t执行accumulate函数。当子线程计算完总和（0到4的和，结果为10）并通过p.set_value(10)存储结果后，主线程调用f.get()即可获取该值。如果子线程尚未计算完毕，get()会阻塞等待，确保数据一致性。

优化方案二：使用 packaged_task 适配器

在前一示例中，被调用的函数必须修改签名以接受promise作为参数，这破坏了函数的通用性。为解决此问题，Boost提供了boost::packaged_task类，它是一个模板适配器，可以将任何可调用对象（如普通函数）包装起来，使其返回值自动存入关联的future中，而无需修改原函数逻辑。

#define BOOST_THREAD_PROVIDES_FUTURE
#include 
#include 
#include 
#include 

// 普通函数，直接返回结果
int accumulate()
{
  int sum = 0;
  for (int i = 0; i < 5; ++i)
    sum += i;
  return sum;
}

int main()
{
  // 包装accumulate函数
  boost::packaged_task task{accumulate};
  
  // 获取关联的future
  boost::future f = task.get_future();
  
  // 移动task到新线程执行（packaged_task不可复制，需move）
  boost::thread t{std::move(task)};
  
  // 获取结果
  std::cout << f.get() << '\n';
}

注意：boost::packaged_task本身不包含线程启动逻辑，它只是一个任务容器。因此，仍需显式创建boost::thread并将task传入。task被移动（move）到新线程，因为任务是单所有权对象，不可复制。执行完毕后，返回值会自动保存到f中。

最简方案：使用 boost::async

如果不需要精细控制线程创建过程，可以直接使用boost::async()。该函数结合了packaged_task和线程管理的特性，在新线程中异步执行指定函数，并直接返回关联的future对象。

#define BOOST_THREAD_PROVIDES_FUTURE
#include 
#include 
#include 

int accumulate()
{
  int sum = 0;
  for (int i = 0; i < 5; ++i)
    sum += i;
  return sum;
}

int main()
{
  // 自动在新线程中执行accumulate，并返回future
  boost::future f = boost::async(accumulate);
  
  std::cout << f.get() << '\n';
}

boost::async支持第二个可选参数，用于指定启动策略（Launch Policy）：

boost::launch::async：强制在新线程中执行（默认行为）。
boost::launch::deferred：延迟执行，仅在调用get()时于当前线程执行。

注意：在某些旧版本Boost（如1.56.0及之前）中，boost::launch::deferred可能未完全实现或导致程序终止。建议在实际项目中确认Boost版本的兼容性，优先使用默认的boost::launch::async以确保跨平台稳定性。以上就是C++中使用Boost Futures与Promises进行线程协作的详细内容，更多关于C++并发编程的资料请关注本站其它相关文章！