使用MPI_Allgather分发结构

#include<stdio.h>
#include <stdlib.h>
#include <mpi.h>

typedef struct {
    int id;
    float value;
} Data;

int main(int argc, char *argv[]) {
    int rank, size;
    Data data;
    Data *all_data;

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

    data.id = rank;
    data.value = (float)rank;

    all_data = (Data *)malloc(size * sizeof(Data));

    MPI_Allgather(&data, sizeof(Data), MPI_BYTE, all_data, sizeof(Data), MPI_BYTE, MPI_COMM_WORLD);

    printf("Rank %d received %d data elements:\n", rank, size);
    for (int i = 0; i< size; i++) {
        printf("Rank %d: id = %d, value = %f\n", rank, all_data[i].id, all_data[i].value);
    }

    free(all_data);
    MPI_Finalize();

    return 0;
}