在MPI中发送动态分配的二维数组的列

int** array;
array = new int*[rows];
for (int i = 0; i < rows; i++) {
    array[i] = new int[cols];
}

MPI_Datatype column_type;
MPI_Type_vector(rows, 1, cols, MPI_INT, &column_type);
MPI_Type_commit(&column_type);

int* column = new int[rows];
// 填充列数据

int destination_rank = 1; // 目标进程的排名
int tag = 0; // 消息标签

MPI_Send(column, 1, column_type, destination_rank, tag, MPI_COMM_WORLD);

// 或者使用非阻塞发送
// MPI_Request request;
// MPI_Isend(column, 1, column_type, destination_rank, tag, MPI_COMM_WORLD, &request);
// MPI_Request_free(&request);

MPI_Datatype column_type;
MPI_Type_vector(rows, 1, cols, MPI_INT, &column_type);
MPI_Type_commit(&column_type);

int* received_column = new int[rows];

int source_rank = 0; // 源进程的排名
int tag = 0; // 消息标签

MPI_Recv(received_column, 1, column_type, source_rank, tag, MPI_COMM_WORLD, MPI_STATUS_IGNORE);

// 或者使用非阻塞接收
// MPI_Request request;
// MPI_Irecv(received_column, 1, column_type, source_rank, tag, MPI_COMM_WORLD, &request);
// MPI_Wait(&request, MPI_STATUS_IGNORE);

for (int i = 0; i < rows; i++) {
    delete[] array[i];
}
delete[] array;

delete[] column;
delete[] received_column;