循环长度不一致导致MPI_Get在循环中挂起的问题如何解决

你遇到的卡死问题核心原因是MPI_Win_fence是通信域全局集合操作，要求通信子MPI_COMM_WORLD内的所有进程必须严格对应调用相同次数，才能完成同步流程。
你的代码中rank 0的循环次数是5，每次循环调用2次fence，总共需要调用10次fence；rank 1的循环次数是4，总共只调用8次fence就直接进入MPI_Finalize退出，导致rank 0第9、10次调用fence时没有对应进程响应，永远阻塞等待。

下面提供两种常用的可行修复方式：

方案一：统一全局循环次数，保持fence同步逻辑不变 #

适合需要保持全局步调一致的场景，所有进程都执行相同次数的循环，不需要实际业务操作的进程只执行同步指令即可：

// 计算全局最大循环次数，所有进程统一按该次数循环
int max_loop = N;
for (int i=0; i<max_loop; i++){
    MPI_Win_fence(0, windowX);
    // 仅当当前进程还需要执行业务逻辑时才调用MPI_Get
    if (i < N - rank) {
        MPI_Get(&a, 1, MPI_DOUBLE, 0, 2, 1, MPI_DOUBLE, windowX);
    }
    MPI_Win_fence(0, windowX);
    if (i < N - rank) {
        std::cout <<"rank="<< rank << " got a =" << a <<"\n";
    }
}

方案二：替换全局fence为主动目标锁同步，无需全局对齐 #

适合各进程执行逻辑独立、不需要全局同步的场景，用MPI_Win_lock/MPI_Win_unlock替代fence，仅和目标进程做局部同步：

// 不需要修改循环次数，仅替换循环内的同步逻辑
for (int i=0; i<N-rank; i++){
    // 仅对目标进程rank 0加共享锁，不需要其他进程参与
    MPI_Win_lock(MPI_LOCK_SHARED, 0, 0, windowX);
    MPI_Get(&a, 1, MPI_DOUBLE, 0, 2, 1, MPI_DOUBLE, windowX);
    MPI_Win_unlock(0, windowX);
    std::cout <<"rank="<< rank << " got a =" << a <<"\n";
}

你原代码中的MPI_Win_create参数存在内存越界风险：第二个参数是窗口的总字节数，你当前传的N仅对rank 0正确，rank≥1时Array的实际长度是N-rank，小于N，会导致窗口覆盖非法内存区域，建议修改为：

MPI_Win_create(&Array[0], (N-rank)*sizeof(double), sizeof(double), MPI_INFO_NULL, MPI_COMM_WORLD, &windowX);

内容的提问来源于stack exchange，提问作者WhatsupAndThanks