Воспроизведение какой-то «общей памяти» в MPI

Question

Я пытаюсь использовать MPI для повторной записи процедуры паралеллизации для пакета моделирования, который я использую. Я пытаюсь реализовать определенную функцию и испытываю проблемы. Я собираюсь проиллюстрировать свою проблему, используя другой более простой пример, который показывает, что я пытаюсь сделать.

Я в основном стараюсь иметь счетчик, который будет использоваться всеми потоками MPI. Каждый раз, когда этот счетчик будет увеличиваться, конкретный поток будет транслировать его всем остальным, чтобы каждый поток имел обновленную версию счетчика, когда он хочет увеличить его. Я понимаю, что это легко выполнимо с использованием OpenMP с общей памятью, но мне интересно, есть ли способ сделать эту работу с MPI более чем одним процессором (например, с помощью 500-ядерного моделирования на суперкомпьютере).

Я пробовал практически любую комбинацию MPI_Bcast, MPI_Send и MPI_Recv, о которых я мог думать, но я думаю, что есть что-то, что я, возможно, не понимаю.

Answer 1

Вы не сможете сделать это с помощью API MPI-1, которые вы предлагаете выше. Однако MPI-2 позволяет выполнять «операции с удаленной памятью», которые позволяют вам делать такие вещи. Я ответил на очень похожий вопрос здесь, основываясь на MPI-2 book и его online examples: Creating a counter that stays synchronized across MPI processes Там реализовано только «приращение счетчика». Это не делает трансляцию; но вам действительно нужна такая операция? Было бы недостаточно, чтобы другие задачи просто проверяли ценность счетчика всякий раз, когда это было необходимо?

Answer 2

Вы не можете инвертировать схему? Создайте выделенный «счетчик-сервер», который любой поток может запросить значение счетчика, когда ему потребуется это значение.

Это может не соответствовать всем сценариям, конечно.