0

0

如何使用HPX库在c++中进行大规模并行计算? (分布式运行时)

穿越時空

穿越時空

发布时间:2026-01-14 12:47:21

|

773人浏览过

|

来源于php中文网

原创

HPX不是MPI替代品,而是需插件支持的分布式运行时;开箱仅支持单机NUMA并行,跨节点需手动配置TCP parcelport、hpx_run启动、locality显式声明及远程async调用。

如何使用hpx库在c++中进行大规模并行计算? (分布式运行时)

HPX 是分布式运行时,不是 MPI 替代品

HPX 本身不直接提供跨节点的网络通信层;它默认只在单机多核上调度 hpx::futurehpx::async 任务。所谓“分布式”,是指它支持通过插件(如 hpx::parcelport)对接底层传输,但生产级跨节点能力需额外配置和验证——多数用户实际用的是本地 NUMA-aware 并行,而非真正分布式。

  • 开箱即用的 HPX 构建(cmake -DHPX_WITH_PARCELPORT_TCP=ON)仅启用 TCP parcelport,但默认不自动启用跨节点调度
  • 节点间任务迁移需显式调用 hpx::find_here() + hpx::create_component + 远程 hpx::async,且组件必须是 hpx::components::component_base 派生并导出
  • 没有类似 MPI 的 MPI_Init 全局初始化;每个节点启动独立 hpx::init,靠 parcelport 发现彼此

启动多节点 HPX 应用的关键命令

必须用 hpx_run(或手动拼 ssh + hpx::init 参数),不能靠普通 mpirun。节点发现依赖 --hpx:node--hpx:localities

hpx_run -l 2 --hpx:node=0,1 --hpx:localities=2 \
  --hpx:config=node0.cfg \
  ./my_app --hpx:node=0 --hpx:localities=2 &
hpx_run -l 2 --hpx:node=1 --hpx:localities=2 \
  --hpx:config=node1.cfg \
  ./my_app --hpx:node=1 --hpx:localities=2
  • --hpx:node=N 告诉当前进程它是第 N 个 locality,必须全局唯一
  • --hpx:localities=K 声明整个拓扑共 K 个 locality,所有节点必须一致
  • hpx_run 自动设置 HPX_PARCEL_DESTINATIONS 环境变量,漏掉会导致 parcelport 连接失败
  • 若用 TCP parcelport,需确保各节点防火墙放行 --hpx:parcelport-port 指定端口(默认 7910)

远程任务执行必须绕过本地调度器

直接写 hpx::async(f, args...) 总是在当前 locality 执行。要发到远端,得用 hpx::async 的重载版本,传入目标 locality ID 或 hpx::id_type

hpx::id_type target = hpx::find_here(1); // 获取 locality 1 的 ID
auto f = []() { return 42; };
auto fut = hpx::async(target, f); // 显式指定目标 locality
int result = fut.get();
  • hpx::find_here(N) 返回 locality N 的 hpx::id_type,N 必须在 --hpx:localities 范围内
  • 不能对任意函数指针做远程调用:lambda 必须无捕获,或捕获内容可序列化(需 HPX_WITH_CXX17_STD_FILESYSTEM 等支持)
  • 参数和返回值类型必须注册序列化(HPX_SERIALIZATION_REGISTER),否则运行时报 hpx::exception: unsupported type

常见崩溃点:资源泄漏与 parcelport 超时

HPX 分布式模式下最常遇到的不是计算错误,而是连接卡死或 std::bad_alloc —— 根本原因是 parcelport 缓冲区未及时 flush 或 locality 间心跳失败。

BlessAI
BlessAI

Bless AI 提供五个独特的功能:每日问候、庆祝问候、祝福、祷告和名言的文本生成和图片生成。

下载

立即学习C++免费学习笔记(深入)”;

  • 避免在循环中高频创建 hpx::async 远程任务:改用批量 hpx::dataflow 或预分配 hpx::lcos::local::channel
  • 检查 hpx::get_config_entry("hpx.parcel.max_message_size"),默认 1MB,大数组传参需调大并重启
  • --hpx:dump-config 启动看是否加载了 tcp parcelport;若输出含 no parcelport available,说明构建时没开 -DHPX_WITH_PARCELPORT_TCP=ON
  • 调试时加 --hpx:debug-parcel,但会显著拖慢速度;生产环境禁用

真正的大规模分布式 HPX 部署,往往要配合 Slurm 或 Kubernetes 做 locality 生命周期管理,而不仅是写几个 hpx::async 调用——网络拓扑感知、故障转移、负载均衡这些都得自己补全。

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

323

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

231

2023.10.07

lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

204

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

190

2025.11.08

Python lambda详解
Python lambda详解

本专题整合了Python lambda函数相关教程,阅读下面的文章了解更多详细内容。

45

2026.01.05

Golang channel原理
Golang channel原理

本专题整合了Golang channel通信相关介绍,阅读专题下面的文章了解更多详细内容。

244

2025.11.14

golang channel相关教程
golang channel相关教程

本专题整合了golang处理channel相关教程,阅读专题下面的文章了解更多详细内容。

342

2025.11.17

Golang云原生微服务Kubernetes_Golang怎么集成Kubernetes开发云原生服务
Golang云原生微服务Kubernetes_Golang怎么集成Kubernetes开发云原生服务

Golang云原生微服务Kubernetes (K8s) 是指 使用 Go 语言(Golang)编写的云原生微服务,并利用 Kubernetes 平台进行容器化部署、自动化管理、弹性伸缩和高效编排的一整套现代应用架构方案。

24

2025.12.22

Java 桌面应用开发(JavaFX 实战)
Java 桌面应用开发(JavaFX 实战)

本专题系统讲解 Java 在桌面应用开发领域的实战应用,重点围绕 JavaFX 框架,涵盖界面布局、控件使用、事件处理、FXML、样式美化(CSS)、多线程与UI响应优化,以及桌面应用的打包与发布。通过完整示例项目,帮助学习者掌握 使用 Java 构建现代化、跨平台桌面应用程序的核心能力。

36

2026.01.14

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
HTML5/CSS3/JavaScript/ES6入门课程
HTML5/CSS3/JavaScript/ES6入门课程

共102课时 | 6.7万人学习

前端基础到实战(HTML5+CSS3+ES6+NPM)
前端基础到实战(HTML5+CSS3+ES6+NPM)

共162课时 | 18.8万人学习

第二十二期_前端开发
第二十二期_前端开发

共119课时 | 12.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号