淘宝客的网站怎么做的,网站建设论文开题报告范文,微信小程序官网首页登录入口,wordpress后台打开太慢搭建MPI并行计算环境#xff0c;编写 MPI程序#xff0c;求和 1 23....1 0000。 要求: 1.使用100个进程; 2.进程0计算1 2...100, 进程1计算101 102... 200, ..... 进程99计算9901 9902... 10000; 3.调用计时函数,分别输出每个进程的计算时间; 4.需使用MPI集群通信函数和同…搭建MPI并行计算环境编写 MPI程序求和 1 23....1 0000。 要求: 1.使用100个进程; 2.进程0计算1 2...100, 进程1计算101 102... 200, ..... 进程99计算9901 9902... 10000; 3.调用计时函数,分别输出每个进程的计算时间; 4.需使用MPI集群通信函数和同步函数
基本概念
解释的很好MPI 与并行计算入门 - 知乎 (zhihu.com)
安装
下载Downloads | MPICH
配置文件设置 ./configure --disable-fortran
编译安装 make -j 8; 设置8个进程进行编译会快一些sudo make install
相关执行脚本mpic mpicc mpirun mpichversion mpiexec mpicxx mpifort mpivars
确保已安装环境gcc 、cmake、gfortran如下操作 下载mpi压缩包解压后进行配置 配置完后执行编译安装 添加环境变量注意这里的路径一定是前面配置时设置的路径这里踩坑了
vim ~./bashrc 修改后source启用 测试安装完成 代码编写
#include stdio.h
#include mpi.hint main(int argc, char *argv[]) {int rank, size;MPI_Init(argc, argv); // 初始化MPI环境MPI_Comm_rank(MPI_COMM_WORLD, rank); // 获取进程编号MPI_Comm_size(MPI_COMM_WORLD, size); // 获取进程总数if (size ! 100) {if (rank 0) {printf(需要100个进程请确保启动时指定了100个进程。\n);}MPI_Finalize();return 1;}// 每个进程计算的起点和终点int start rank * 100 1;int end (rank 1) * 100;// 计时开始double start_time MPI_Wtime();// 计算部分和long long local_sum 0;for (int i start; i end; i) {local_sum i;}// 计时结束double end_time MPI_Wtime();double elapsed_time end_time - start_time;// 输出每个进程的计算时间printf(进程 %d 计算时间: %f 秒\n, rank, elapsed_time);// 使用MPI_Reduce收集所有部分和结果存储在进程0long long total_sum 0;MPI_Reduce(local_sum, total_sum, 1, MPI_LONG_LONG, MPI_SUM, 0, MPI_COMM_WORLD);// 进程0输出最终总和if (rank 0) {printf(1 2 ... 10000 的总和为: %lld\n, total_sum);}MPI_Finalize(); // 结束MPI环境return 0;
}代码分析 MPI初始化 MPI_Init: 初始化MPI环境所有进程开始运行。MPI_Comm_rank: 获取当前进程的编号rank。MPI_Comm_size: 获取总进程数size。 计时函数 使用MPI_Wtime()计算每个进程的运行时间。 进程间通信 MPI_Reduce: 将所有进程的部分和累加到进程0。MPI_SUM: 指定归约操作为求和。 同步 MPI中的MPI_Reduce隐含了同步因为它会等待所有进程计算完成。
运行方法
假设代码文件名为mpi_sum.c在终端中执行以下命令
mpicc mpi_sum.c -o mpi_sum # 编译代码
mpirun -np 100 ./mpi_sum # 使用100个进程运行程序运行结果
