Şimdi Ara

C ile MPI non blocking

Sıcak Fırsatlarda Tıklananlar

Editörün Seçtiği Fırsatlar

Samsung Galaxy S25: Yapay Zeka Parmaklarınızın Ucunda https://www.amazon.com.tr/stores/page/92F263DE-74F5-45CA-B8EE-2FA578898A76?ref_=s25dh

MERRELL AGILITY REMIX Spor AyakkabıKadın : Amazon.com.tr: Moda https://www.amazon.com.tr/gp/product/B0CNH5XYB8 13 sa. önce paylaşıldı

ONLY ONLDOLLY SHORT PUFFER JACKET OTW NOOS Dış Giyim Kadın : Amazon.com.tr: Moda https://www.amazon.com.tr/dp/B0BMDFDQBQ 13 sa. önce paylaşıldı

Daha Fazla

Bu Konudaki Kullanıcılar: Daha Az

1 Misafir - 1 Masaüstü

5 sn

1
Cevap

0
Favori

664
Tıklama

Daha Fazla
İstatistik

Konu İstatistikleri Yükleniyor

Konuya Özel

0 oy

Öne Çıkar

Cevapla

Sayfa: 1

Giriş

Mesaj

hungrywolf

Yüzbaşı

472 Mesaj

Tüm Başarılarını Gör

İyi akşamlar arkadaşlar benim C ile MPI paralel programlama üzerine sizlerden yardım isteyecektim. Elimde mpi ile paralelleştirilmiş bir C kodu var.

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

int main(int argc, char *argv[])
{
int rank, size, next, prev, message, tag = 201;

/* Start up MPI */

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

next = (rank + 1) % size;
prev = (rank + size - 1) % size;

if (0 == rank) {
message = 10;

printf("Process 0 sending %d to %d, tag %d (%d processes in ring)\n",
message, next, tag, size);
MPI_Send(&message, 1, MPI_INT, next, tag, MPI_COMM_WORLD);
printf("Process 0 sent to %d\n", next);
}

while (1) {
MPI_Recv(&message, 1, MPI_INT, prev, tag, MPI_COMM_WORLD,
MPI_STATUS_IGNORE);

if (0 == rank) {
--message;
printf("Process 0 decremented value: %d\n", message);
}

MPI_Send(&message, 1, MPI_INT, next, tag, MPI_COMM_WORLD);
if (0 == message) {
printf("Process %d exiting\n", rank);
break;
}
}

if (0 == rank) {
MPI_Recv(&message, 1, MPI_INT, prev, tag, MPI_COMM_WORLD,
MPI_STATUS_IGNORE);
}

/* All done */

MPI_Finalize();
return 0;
}

Bu kod üzerine elimden geldiğince bir çalışma yaptım ve alttaki kodu hazırladım fakat hata veriyor.

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

int main(int argc, char *argv[])
{
int rank, size, next, prev, message, tag = 201;

/* Start up MPI */

MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Request myRequest[4];
MPI_Status myStatus[4];

next = (rank + 1) % size;
prev = (rank + size - 1) % size;

if (0 == rank) {
message = 10;

printf("Process 0 sending %d to %d, tag %d (%d processes in ring)\n",
message, next, tag, size);
MPI_Status myStatus;

MPI_Isend(&message, 1, MPI_INT, next, tag, MPI_COMM_WORLD, &myRequest[0]);
printf("Process 0 sent to %d\n", next);
MPI_Wait(&myRequest[0], &myStatus[0]);
MPI_Wait(&myRequest[1], &myStatus[1]);

}

while (1) {

MPI_Irecv(&message, 1, MPI_INT, prev, tag, MPI_COMM_WORLD,
MPI_STATUS_IGNORE, &myRequest[1]);

MPI_Wait(&myRequest, &myStatus);

if (0 == rank) {
--message;
printf("Process 0 decremented value: %d\n", message);
}

MPI_Isend(&message, 1, MPI_INT, next, tag, MPI_COMM_WORLD[2]);
MPI_Wait(&myRequest[2], &myStatus[2]);
MPI_Wait(&myRequest[3], &myStatus[3]);
if (0 == message) {
printf("Process %d exiting\n", rank);
break;
}
}

if (0 == rank) {

MPI_Irecv(&message, 1, MPI_INT, prev, tag, MPI_COMM_WORLD,
MPI_STATUS_IGNORE, &myRequest[3]);

MPI_Wait(&myRequest, &myStatus);
}

/* All done */

MPI_Finalize();
return 0;
}

Hatalarımı düzeltmeme yardımcı olabilirseniz çok teşekkür ederim şimdiden.

Sayfa: 1

Benzer içerikler

Ip işlemleri

Bu mesaj IP'si ile atılan mesajları ara Bu kullanıcının son IP'si ile atılan mesajları ara Bu mesaj IP'si ile kullanıcı ara Bu kullanıcının son IP'si ile kullanıcı ara

KAPAT X

%40
Kazan

%2,8
Kazan

%6,5
Kazan

%25
Kazan

%1,6
Kazan

%3,2
Kazan

%5,5
Kazan

%3,2
Kazan

%5
Kazan

%3,2
Kazan

%5
Kazan

%2
Kazan

Alışveriş Yaptıkça Para Kazan Harekete Geç »