mpi - MPISend および MPIReceive の使用中にマスター ノードでのメモリ使用量が増加する

Question

マスターがタスクをスレーブ ノードに割り当てる MPI を使用してプログラムを作成しています。すべてのスレーブ ノードはタスクをローカルで実行し、結果 (サイズ 100000 の int 配列) をマスター ノードに送信します。

私は正しい結果を得ていますが、メモリの使用は線形ではありません。マスター ノードが N*m メモリを占有していることがわかりました。ここで、N はノードの数、m は通常スレーブ ノードによって使用されるメモリです。

なぜこれが起こっているのか、マスターノードのメモリ使用量を減らす解決策はありますか。

スレーブ ノードがデータ/結果をマスター ノードに送信するサンプル コードを次に示します。マスター ノードでのメモリ使用量が N*m である理由を知りたいです。Linux コマンド top を使用してメモリ使用量を確認しました。

#include<iostream>  
#include <mpi.h>
using namespace std;
int main(int argv, char *argp[256])
{
    int rank,size,master_rank=0,i=0;
    int jc=0,jpt,jobsperthread=0,exjpt=0;;
    int ii=0,index=0,remaining=0,tobesent=0,tobereceived=0;
    int totsendreceivesize=100000,k=0;
    int innodes=11;
    MPI_Status status;
    int *arr_anti_net=(int*)malloc(sizeof(int)*(totsendreceivesize+100));
    MPI_Init (&argv, &argp);
    MPI_Comm_rank (MPI_COMM_WORLD, &rank);
    MPI_Comm_size (MPI_COMM_WORLD, &size);
    for(i=0;i<totsendreceivesize;i++)
       arr_anti_net[i]=i
    if(rank!=master_rank)
    {
       remaining=totsendreceivesize;
       tobesent=256;
       k=0;
       while(remaining!=0)
       {
        if(remaining<256)
            tobesent=remaining;
        MPI_Send(&arr_anti_net[k],tobesent,MPI_INT,0,11,MPI_COMM_WORLD);
        k+=tobesent;
        remaining-=tobesent;
       }
    }
    else
    {
       ii=0;
       index=0;
       for(ii=1;ii<size;ii++)
       {
           jc=0;
           jpt=0;
           jobsperthread=innodes/size;
           jpt=innodes/size;
           exjpt=0;
           if(innodes%size!=0)
           {
            if(ii<innodes%size)
            {
                jobsperthread+=1;
                exjpt=ii;
            }
            else
                exjpt=innodes%size;
           }
           remaining=256;//totsendreceivesize;
           tobereceived=256;
           k=0;
           while(remaining!=0)
           {
            if(remaining<256)
                tobereceived=remaining;
            MPI_Recv(& arr_anti_net[k],tobereceived,MPI_INT,ii,11,MPI_COMM_WORLD,&status);
            k+=tobereceived;
            remaining-=tobereceived;
           }
       }
      }
   MPI_Barrier(MPI_COMM_WORLD);

   MPI_Finalize();
}

どうもありがとうございました