Dasturlarni cmd orqali ishga tushirish usullari
![MPI_Wtick funksiyasi ma'lumotlar tizimida yoki MPI implementatsiyasiga qarab
farqli bo'lishi mumkin, ammo umumiy xususiyatlari MPI dasturlarida parallel vaqt
o'lchash uchun ishlatiladigan barcha funksiyalardan biri hisoblanadi.
Dastur kodi :
#include<iostream>
#include "mpi.h"
#include<math.h>
using namespace std;
int main(int argc,char *argv[]){
int x=1,y=2,z=3,M,len;
int rank;
float a1,a2,a3,b1,b2,b3,c1,c2;
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
if(rank==0){
a1=MPI_Wtick();
x=pow(x,5);
MPI_Send(&x,1,MPI_INT,4,5,MPI_COMM_WORLD);
a2=MPI_Wtick()-a1;
}
if(rank==1){
a3=MPI_Wtick();
y=pow(y,5);
MPI_Send(&y,1,MPI_INT,4,5,MPI_COMM_WORLD);
b1=MPI_Wtick()-a3;
}
if(rank==2){
b2=MPI_Wtick();
z=pow(z,5);
MPI_Send(&z,1,MPI_INT,4,5,MPI_COMM_WORLD);
b3=MPI_Wtick()-b2;
}
if(rank==4){](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_14.png?v=1)
![2) Qabul qiluvchining vazifasi har xil turdagi va turli jo'natuvchilardan xabarlarni
to'plaganida. MPI_Probesiz, foydalanuvchi buferiga xabarlarni olish tartibi
kompilyatsiya vaqtida o'rnatilishi kerak:
MPI_Probe bu dasturda xabar kelayotganligi yoki kelmayotganligi haqida xabar
beradi .MPI_Probe dan asosan ikkita holatlarda foydalanishimiz mumkin .
Dastur kodi MPI_Probdan foydalanishning 1 – usuli :
#include<iostream>
#include "mpi.h"
using namespace std;
int main(int argc,char *argv[]){
int a,b,a1,b1,size;
int rank;
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
if(rank==1){
a=100;
MPI_Send(&a,1,MPI_INT,3,4,MPI_COMM_WORLD);
}
if(rank==2){
b=200;
MPI_Send(&b,1,MPI_INT,3,4,MPI_COMM_WORLD);
}
if(rank==3){
MPI_Probe(MPI_ANY_SOURCE,4,MPI_COMM_WORLD,&status);
if(status.MPI_SOURCE==1){
MPI_Recv(&a1,1,MPI_INT,1,4,MPI_COMM_WORLD,&status);
MPI_Recv(&b1,1,MPI_INT,2,4,MPI_COMM_WORLD,&status);
}
else {
if(status.MPI_SOURCE==2){
MPI_Recv(&b1,1,MPI_INT,2,4,MPI_COMM_WORLD,&status);
MPI_Recv(&a1,1,MPI_INT,1,4,MPI_COMM_WORLD,&status);
}
}](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_16.png?v=1)
![cout<<"procces "<<rank<<" a1 = "<<a1<<" b1 = "<<b1<<endl;
}
MPI_Finalize();
}
Dastur kodi MPI_Probdan foydalanish 2 – usul:
#include<iostream>
#include <mpi.h>
using namespace std;
int main(int argc,char *argv[]){
int a[5],b[5],SIZE;
int rank;
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
if(rank==1){
for(int i=0;i<5;i++){
a[i]=i*10;
}
MPI_Send(&a,5,MPI_INT,3,4,MPI_COMM_WORLD);
}
if(rank==2){
for(int i=0;i<5;i++){
b[i]=i*5;
}
MPI_Send(&b,5,MPI_INT,3,4,MPI_COMM_WORLD);
}](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_17.png?v=1)
![if(rank==3){
MPI_Probe(MPI_ANY_SOURCE,4,MPI_COMM_WORLD,&status);
MPI_Get_count(&status,MPI_INT,&SIZE);
int a1[SIZE],b1[SIZE];
if(status.MPI_SOURCE==1){
MPI_Recv(&a1,SIZE,MPI_INT,1,4,MPI_COMM_WORLD,&status);
MPI_Recv(&b1,SIZE,MPI_INT,2,4,MPI_COMM_WORLD,&status);
}
else {
if(status.MPI_SOURCE==2){
MPI_Recv(&b1,SIZE,MPI_INT,2,4,MPI_COMM_WORLD,&status);
MPI_Recv(&a1,SIZE,MPI_INT,1,4,MPI_COMM_WORLD,&status);
}
}
cout<<"Protsessor : "<<rank<<endl;
for(int i=0;i<SIZE;i++){
cout<<"a1 -> : "<<i+1<<" = "<<a1[i]<<endl;
cout<<"b1 -> : "<<i+1<<" = "<<b1[i]<<endl;
}
}
MPI_Finalize();
}
Blokirovkasiz xabar almashish mohiyati va uning qo llanilish sohalariʻ
• Asinxron ma'lumotlarni uzatish.
• Jarayonlarni to'xtatmasdan, qo'ng'iroqdan keyin darhol qaytadi.](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_18.png?v=1)
![• OUT flag - ayirboshlash operatsiyalarining tugallanganligi
belgisiagar )aloqa hodisasi tugallangan bo’lsa TRUE ( OUT ));
• OUT statuses - xabar parametrlari;
• Belgilangan identifikatorlar bilan bog'liq barcha operatsiyalar bajarilgan
bo'lsa (statuslar massividagi xabar parametrlarini ko'rsatgan holda) flag
parametrida 1 qiymatini qaytaradi. Aks holda, 0 qaytariladi va statuslar
massivining elementlari aniqlanmagan.
• intMPI_Testany(int count, MPI_Request*requests, int*index, int*flag,
MPI_Status*status)
• OUT index - tugallangan almashinuv operatsiyalari soni
• OUT status - xabar parametrlari
• Agar pastki dastur chaqirilganda, xabar almashish operatsiyalaridan kamida
bittasi tugallangan bo'lsa, u holda flag parametrida 1 qiymati qaytariladi,
indeks requests massividagi mos keladigan elementning raqamini o'z ichiga
oladi , status esa xabar parametrlari hisoblanadi. .
• intMPI_Testsome( int incount, MPI_Request*requests, int*outcount,
int*indexes, MPI_Status*statuses)
• incount - identifikatorlar soni
• OUT outcount - yakunlangan ayirboshlash operatsiyalari identifikatorlari
soni
• OUT indexes - yakunlangan almashinuv operatsiyalari raqamlari massivi
• OUT statuses - tugallangan operatsiyalar parametrlari
• Quyidastur MPI_Waitsome kabi ishlaydi, ammo qaytish darhol bo'ladi. Agar
ko'rsatilgan operatsiyalarning hech biri bajarilmagan bo'lsa, u holda
outcount qiymati nolga teng.
Blokirovkasiz xabar almashish holatini tekshirish funksiyalari va ularni
amalda qo llanilishiʻ
Blokirovkasiz xabar almashishning MPI_Test funksiyasi dastur kodi va natijasi .
#include<iostream>
#include<mpi.h>
using namespace std;
int main(int argc,char *argv[]){
int rank , a , b , flag ;
MPI_Request reqs1,reqs;
MPI_Status status;](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_23.png?v=1)
![Blokirovkasiz xabar almashishning MPI_Testall funksiyasi dastur kodi va natijasi
#include<iostream>
#include<mpi.h>
using namespace std;
int main(int argc, char *argv[]){
int rank,flag;
float a,b,c;
MPI_Request reqs[3];
MPI_Status status[3];
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
a = 0.0 ;
b = 0.0 ;
c = 0.0 ;
if(rank == 0){
a = 28.06;
b = 20.05;
c = 20.23 ;
MPI_Isend(&a,1,MPI_FLOAT,1,5,MPI_COMM_WORLD,&reqs[0]);
MPI_Isend(&b,1,MPI_FLOAT,1,6,MPI_COMM_WORLD,&reqs[1]);
MPI_Isend(&c,1,MPI_FLOAT,1,7,MPI_COMM_WORLD,&reqs[2]);
}
if(rank==1){
MPI_Irecv(&a,1,MPI_FLOAT,0,5,MPI_COMM_WORLD,&reqs[0]);
MPI_Irecv(&b,1,MPI_FLOAT,0,6,MPI_COMM_WORLD,&reqs[1]);](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_25.png?v=1)
![MPI_Irecv(&c,1,MPI_FLOAT,0,17,MPI_COMM_WORLD,&reqs[2]);
// MPI_Waitall(2,reqs,status);
MPI_Wait(&reqs[0],&status[0]);
MPI_Wait(&reqs[1],&status[1]);
MPI_Testall(2,reqs,&flag,status);
cout<<"Flag = "<<flag<<endl;
}
cout<<"Jarayon_raqam "<<rank<<" a = "<<a<<" b = "<< b <<" c =
"<<c<<endl;
MPI_Finalize();
return 0;
}
Blokirovkasiz xabar almashishning MPI_Testany funksiyasi dastur kodi va natijasi
#include<iostream>
#include<mpi.h>
using namespace std;
int main(int argc, char *argv[]){
int rank,index,flag;
int a;
double b;
float c;
MPI_Request reqs[3];
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_26.png?v=1)
![a=0;
b=0.0;
c=0.0;
if(rank==0){
a = 2806;
b = 20.05;
c = 20.23;
MPI_Isend(&a,1,MPI_INT,1,5,MPI_COMM_WORLD,&reqs[0]);
MPI_Isend(&b,1,MPI_DOUBLE,1,6,MPI_COMM_WORLD,&reqs[1]);
MPI_Isend(&c,1,MPI_FLOAT,1,7,MPI_COMM_WORLD,&reqs[2]);
}
if(rank==1){
MPI_Irecv(&a,1,MPI_INT,0,5,MPI_COMM_WORLD,&reqs[0]);
MPI_Irecv(&b,1,MPI_DOUBLE,0,16,MPI_COMM_WORLD,&reqs[1]);
MPI_Irecv(&c,1,MPI_FLOAT,0,7,MPI_COMM_WORLD,&reqs[2]);
MPI_Waitany(1,reqs,&index,&status);
MPI_Testany(3,reqs,&index,&flag,&status);
cout<<"index = "<<index<<" flag : "<<flag<<endl;
}
cout<<"jarayon : "<<rank<<" a = "<<a <<" b = "<<b<<" c = "<<c<<endl;
MPI_Finalize();
return 0;
}](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_27.png?v=1)
![Blokirovkasiz xabar almashishning MPI_Testsome funksiyasi dastur kodi va
natijasi
#include<iostream>
#include<mpi.h>
using namespace std;
int main(int argc, char *argv[]){
int rank,index[3],flag ,outcount;
int a;
double b;
float c;
MPI_Request reqs[3];
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
a=0;
b=0.0;
c=0.0;
if(rank==0){
a = 2806;
b = 20.05;
c = 20.23;
MPI_Isend(&a,1,MPI_INT,1,5,MPI_COMM_WORLD,&reqs[0]);
MPI_Isend(&b,1,MPI_DOUBLE,1,6,MPI_COMM_WORLD,&reqs[1]);
MPI_Isend(&c,1,MPI_FLOAT,1,7,MPI_COMM_WORLD,&reqs[2]);
}
if(rank==1){
MPI_Irecv(&a,1,MPI_INT,0,5,MPI_COMM_WORLD,&reqs[1]);
MPI_Irecv(&b,1,MPI_DOUBLE,0,6,MPI_COMM_WORLD,&reqs[2]);
MPI_Irecv(&c,1,MPI_FLOAT,0,7,MPI_COMM_WORLD,&reqs[0]);
MPI_Waitsome(3,reqs,&outcount,index,&status);
MPI_Testsome(3,reqs,&outcount,index,&status);
for (int i = 0 ; i<outcount; i++){
cout<<"index = "<<index[i]<<" outcount : "<<outcount<<endl;
}
}](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_28.png?v=1)
![sendbuf [in]
Yuborilayotgan ma’lumot manzili.
sendcount
Yuboriladigan ma’lumotlar soni.
sendtype
Yuborilayotgan ma’lumot turi
Dest
Qabul qiluvchi jarayon raqami
sendtag
Jo’natiluvchi xabar identifikatori
recvbuf [out]
Ma’lumot qabul qilish uchun bufer manzili.
recvcount
Qabul qilinayotgan ma’lumotlar soni
recvtype
Qabul qilinayotgan ma’lumot turi
source
Xabar jo’natuvchi jarayon raqami
recvtag
Qabul qilinayotgan xabar identifikatori
Comm
Kommunikator nomi
status [out]
Qabul qilinayotgan xabar haqidagi ma’lumotlarni saqlovchi tuzilma.
MPI_Sendrecv() funksiyasi
#include<iostream>
#include<mpi.h>
using namespace std;
int main(int argc,char**argv){
int rank;
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
int a;
int b ;](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_31.png?v=1)
![datatype
Xabar almashinuvidagi ma’lumotlar soni.
Dest
Xabarni qabul qiluvchi jarayon manzili.
sendtag
Jo’natiluvchi xabar identifikatori.
source
Xabar jo’natuvchi jarayon raqami.
recvtag
qabul qilinuvchi xabar identifikatori.
Comm
Kommunikator nomi.
status [out]
Qabul qilinayotgan xabar haqidagi ma’lumotlarni saqlovchi tuzilma.
Agar xabar uzatish va qabul qilish muvofaqqiyatli amalga oshirilsa , funksiya
MPI_SUCCESS (0 qiymat) qaytaradi aks holda xatolik kodini.
#include<iostream>
#include<string>
#include<mpi.h>
using namespace std;
int main(int argc,char**argv){
string send;
int rank ;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
if (rank==5){
send = "w";
MPI_Sendrecv_replace(&send,1,MPI_CHAR,7,12,7,13,MPI_COMM_WOR
LD,MPI_STATUS_IGNORE);
cout<<"jarayon_raqam : "<<rank<<" Qiymat = "<<send<<endl;
}
if (rank==7){
send = "t";
MPI_Sendrecv_replace(&send,1,MPI_CHAR,5,13,5,12,MPI_COMM_WOR
LD,MPI_STATUS_IGNORE);](https://docx.uz/documents/4d255e0f-53ae-4e23-8c1f-268441183edc/page_33.png?v=1)
Dasturlarni cmd orqali ishga tushirish usullari