05Class

基于通信的并行化

MPI2.0

• 单边通信

• 动态进程管理

• I/O文件输入与输出

  接口实现

• MPICH

• Open MPI

• LAM

使用openmpi

安装参考地址 https://github.com/pmodels/mpich

  #源代码安装
  wget -c http://www.mpich.org/static/downloads/3.3.1/mpich-3.3.1.tar.gz
  tar -xvzf mpich-3.3.1.tar.gz 
  cd  mpich-3.3.1.tar.gz 
  mkdir   build
  ./configure --prefix=/public/home/zpliu/scripte/C/mpich-3.3.1/build 2>&1| tee c.txt
  make 2>&1 | tee m.txt
  make install 2>&1 | tee mi.txt
  # 之后程序在build/bin/目录里
  # 加入环境变量
  export PATH="/public/home/zpliu/scripte/C/mpich-3.3.1/build/bin:$PATH"    
   ## 集群直接load
  module load mpi/openmpi/3.1.1rc1

MPI运行实例

  ##  编译
  mpicc -o hello hello.c
  ## 运行启动4个进程
  mpirun -np 4 PATH_to_hello/hello 
  ## 错误用法，MPI编译的可执行程序，只能使用mpirun运行；而使用gcc编译的可执行程序，也可以使用mpirun运行
  ./hello 错误用法

who am I

• 编译mpigcc -o hello test5.c

• 运行mpirun -np 4 ~/ClassTest/05/hello

  获取进程编号和进程数目

• MPI_Comm_rank(MPI_COMM_WORLD,&myid)获取进程编号

• MPI_Comm_size(MPI_COMM_WORLD,&numprocs)获取总的进程数目

  #include <stdio.h>
  #include "mpi.h"
  int main( int argc, char *argv[] )
  {
    int  myid, numprocs;
    MPI_Init( &argc, &argv );
    MPI_Comm_rank( MPI_COMM_WORLD, &myid );
    MPI_Comm_size( MPI_COMM_WORLD, &numprocs );
    printf("I am %d of %d\n", myid, numprocs );
    MPI_Finalize();
  }