使用MPI在c ++中的BubbleSort

Question

我是MPI的初学者，正在尝试编写排序代码（BubbleSort）该代码有效，但似乎我缺少了一些]

代码在这里：--->

#define N 10`
#include <iostream>
#include <stdio.h>
#include <math.h>
#include <time.h>
#include <stdlib.h>
#include <stddef.h>
#include "mpi.h"
using namespace std;


int main(int argc, char* argv[])
{
    int i, j, k, rank, size;
    int a[N] = { 10,9,8,7,6,5,4,3,2,1 };
    int c[N];
    int aa[N], cc[N];

    MPI_Init(&argc, &argv);
    MPI_Comm_size(MPI_COMM_WORLD, &size);
    MPI_Comm_rank(MPI_COMM_WORLD, &rank);

    MPI_Scatter(a, N/size, MPI_INT, aa, N/size , MPI_INT, 0, MPI_COMM_WORLD);

    MPI_Barrier(MPI_COMM_WORLD);

    int n = N/size;
    for (int i = 0; i < n - 1; i++) {
        for (int j = 0; j < n - i - 1; j++) {
            if (aa[j] > aa[j + 1]) {
                int temp = aa[j];
                aa[j] = aa[j + 1];
                aa[j + 1] = temp;
            }
        }
    }
    for (int i = 0; i < n; i++) {
        cc[i] = aa[i];
    };

    MPI_Barrier(MPI_COMM_WORLD);
    MPI_Gather(cc, N/size , MPI_INT, c, N/size, MPI_INT, 0, MPI_COMM_WORLD);

    MPI_Barrier(MPI_COMM_WORLD);
    MPI_Finalize();
    cout << cc[9];
    if (rank == 0) {
        cout << "C is look like : " << endl;
        for (int i = 0; i < N; i++) {
            cout << c[i] << "   ";

        }
    }
}

程序输出：->最后我们得到了错误通常，我的MPI被配置为4个处理器

-858993460 C is look like :
-858993460
-858993460
-858993460
9   10   7   8   5   6   3   4   -858993460   -858993460

Answer 1

程序中有几个问题：

• cc[9]未初始化使用
• 您仅对(N/size)*size)个元素进行操作，在您的情况下为N=10, size=4，这意味着仅对8个元素进行操作。解决方法是使用MPI_Scatterv()和MPI_Gatherv()
• 假设您的冒泡排序是正确的（我没有检查那部分），您的程序收集了排序的（子）数组，并且您不能天真地期望结果是（完整大小的）排序的数组。