并行计算

开发平台：
Unix_Linux

shortest.c：源码内容
							/**输入邻接矩阵和源顶点，求最短路径。输入邻接矩阵中，位置(x,y)为顶点y到x的边权**/
#include <mpi.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
/**定义M为无穷大**/
#define M 1.7e308
#define BOOL int
#define FALSE 0
#define TRUE  1
#define W(x,y) W[x*nodenum+y]
FILE* fp;
char ch;
char id[20];
int point;
double* W;
double* dist;
BOOL* bdist;
int nodenum = 0;
int S = 0;
/* show err and exit*/
void fatal(char* err)
{
	printf("%s/n", err);
	exit(0);
}
/**从文件中读取字符**/
void GetChar()
{
	fread(&ch,sizeof(char),1,fp);
}
/**读取一个小数，如果为字符M或m，令其值为无穷大**/
double GetNextNum()
{
	double num;
	while(!isdigit(ch) && ch!='M' && ch!='m')
		GetChar();
	if(isdigit(ch))
	{
		point = 0;
		while(isdigit(ch))
		{
			id[point] = ch;
			point ++;
			GetChar();
		}
		id[point] = 0;
		num = atof(id);
	}else{
		num = M;
		GetChar();
	}
	return num;
}
/**读入邻接矩阵**/
void ReadMatrix()
{
	char file[40];
	int i,j;
	double num;
	printf("Begin to read the matrix!n");
	printf("The first integer of the file should be the size of the matrix!n");
	printf("Input the file name of the matrix:");
	scanf("%s",file);
	if((fp = fopen(file,"r")) == NULL)
	{
		fatal("File name input error!");
	}
	num = GetNextNum();
	if(num < 0 || num > 10000)
	{
		fclose(fp);
		fatal("The matrix row input error!");
	}
	nodenum = (int)num;
	printf("Input the start node:");
	scanf("%d",&S);
	if(S >= nodenum) fatal("The start node input too big!n");
	W = (double*)malloc(sizeof(double)*num*num);
	if( W == NULL)
	{
		fclose(fp);
		fatal("Dynamic allocate space for matrix fail!");
	}
	for(i=0;i<nodenum;i++)
		for(j=0;j<nodenum;j++)
		{
			W(i,j) = GetNextNum();
		}
	fclose(fp);
	printf("Finish reading the matrix,the nodenum is: %d;n",nodenum);
}
/**各处理器数据初始化**/
void Init(int my_rank,int group_size,int ep)
{
	int i;
	MPI_Status status;
	if(my_rank == 0)
	{
		for(i=1;i<group_size;i++)
		{
			MPI_Send(&W(ep*(i-1),0),ep*nodenum,MPI_DOUBLE,i,i,MPI_COMM_WORLD);
		}
	}else{
		dist = (double*)malloc(sizeof(double)*ep);
		bdist = (int*) malloc(sizeof(BOOL)*ep);
		W = (double*)malloc(sizeof(double)*ep*nodenum);
		if(W == NULL || dist == NULL || bdist == NULL)
			fatal("Dynamic allocate space for matrix fail!");
		MPI_Recv(W,ep*nodenum,MPI_DOUBLE,0,my_rank,MPI_COMM_WORLD,&status);
		for(i=0;i<ep; i++)
		{
			if(i+(my_rank-1)*ep == S)
			{
				dist[i] = 0;
				bdist[i] = TRUE;
			}else{
				dist[i] = W(i,S);
				bdist[i] = FALSE;
			}
		}
	}
}
/**输出邻接矩阵**/
void OutPutMatrix(int my_rank,int group_size,int ep,int mynum)
{
	int i,j;
	if(my_rank != 0)
	{
		for(i=0;i<mynum;i++)
		{
			printf("Processor %d:t",my_rank);
			for(j=0;j<nodenum;j++)
			{
				if(W(i,j) > 1000000) printf("Mt");
				else printf("%dt",(int)W(i,j));
			}
			printf("n");
		}
	}
}
/**输出结果**/
void OutPutResult(int my_rank,int group_size,int ep,int mynum)
{
	int i,j;
	if(my_rank != 0)
	{
		for(i=0;i<mynum;i++)
		{
			printf("node  %d:t%dn",(my_rank-1)*ep+i,(int)dist[i]);
		}
	}
}
/**算法主循环**/
void FindMinWay(int my_rank,int group_size,int ep,int mynum)
{
	int i,j;
	int index,index2;
	double num,num2;
	int calnum;
	MPI_Status status;
	int p = group_size;
	for(i=0; i<nodenum;i++)
	{
		index = 0;
		num = M;
		/**步骤(3.1)**/
		for(j=0;j<mynum;j++)
		{
			if(dist[j] < num && bdist[j]==FALSE)
			{
				num = dist[j];
				index = ep*(my_rank-1)+j;
			}
		}
		MPI_Barrier(MPI_COMM_WORLD);
		/**步骤(3.2)**/
		calnum = group_size-1;
		while(calnum > 1)
		{
			/**节点数目为偶数时**/
			if(calnum % 2 == 0)
			{
				calnum = calnum/2;
				if(my_rank > calnum)
				{
					MPI_Send(&index,1,MPI_INT,my_rank-calnum,
						my_rank-calnum,MPI_COMM_WORLD);
					MPI_Send(&num,1,MPI_DOUBLE,my_rank-calnum,
						my_rank-calnum,MPI_COMM_WORLD);
				}else if(my_rank!=0){
					MPI_Recv(&index2,1,MPI_INT,my_rank+calnum,my_rank,
						MPI_COMM_WORLD,&status);
					MPI_Recv(&num2,1,MPI_DOUBLE,my_rank+calnum,my_rank,
						MPI_COMM_WORLD,&status);
					if(num2 < num)
					{
						num = num2;
						index = index2;
					}
				}
			}else{
			/**节点数目为奇数时**/
				calnum = (calnum+1)/2;
				if(my_rank > calnum)
				{
					MPI_Send(&index,1,MPI_INT,my_rank-calnum,
						my_rank-calnum,MPI_COMM_WORLD);
					MPI_Send(&num,1,MPI_DOUBLE,my_rank-calnum,
						my_rank-calnum,MPI_COMM_WORLD);
				}else if(my_rank!=0 && my_rank < calnum){
					MPI_Recv(&index2,1,MPI_INT,my_rank+calnum,my_rank,
						MPI_COMM_WORLD,&status);
					MPI_Recv(&num2,1,MPI_DOUBLE,my_rank+calnum,my_rank,
						MPI_COMM_WORLD,&status);
					if(num2 < num)
					{
						num = num2;
						index = index2;
					}
				}
			}
			MPI_Barrier(MPI_COMM_WORLD);
		}
		/**步骤(3.3)**/
		MPI_Bcast(&index,1,MPI_INT,1,MPI_COMM_WORLD);
		MPI_Bcast(&num,  1,MPI_DOUBLE,1,MPI_COMM_WORLD);
		/**步骤(3.4)**/
		for(j=0;j<mynum;j++)
		{
			if((bdist[j]==FALSE)&&(num + W(j,index) < dist[j]))
				dist[j] =num  + W(j,index);
		}
		/**步骤(3.5)**/
		if(my_rank == index/ep+1)
		{
			bdist[index%ep] = TRUE;
		}
		MPI_Barrier(MPI_COMM_WORLD);
	}
}
/**主函数**/
int main(int argc,char** argv)
{
	int group_size,my_rank;
	MPI_Status status;
	int i,j;
	int ep;
	int mynum;
	MPI_Init(&argc,&argv);/*MPI begin*/
	MPI_Comm_size(MPI_COMM_WORLD,&group_size);
	MPI_Comm_rank(MPI_COMM_WORLD,&my_rank);
	/*
	if(group_size <= 1)
	{
		printf("Not enough processor!n");
		exit(0);
	}
	*/
	/**步骤(1)**/
	if(my_rank == 0)
	{
		ReadMatrix();
		for(i=1;i<group_size;i++)
		{
			MPI_Send(&nodenum,1,MPI_INT,i,i,MPI_COMM_WORLD);
			MPI_Send(&S,1,MPI_INT,i,i,MPI_COMM_WORLD);
		}
	}else{
		MPI_Recv(&nodenum,1,MPI_INT,0,my_rank,MPI_COMM_WORLD,&status);
		MPI_Recv(&S,1,MPI_INT,0,my_rank,MPI_COMM_WORLD,&status);
	}
	ep = nodenum/(group_size-1);
	if(ep*group_size-ep < nodenum) ep++;
	if(ep*my_rank <= nodenum)
	{
		mynum = ep;
	}else if(ep*my_rank < nodenum+ep)
	{
		mynum = nodenum - ep*(my_rank-1);
	}
	else mynum = 0;
	if (my_rank == 0) mynum = 0;
    /**步骤(2)**/
	Init(my_rank,group_size,ep);
	OutPutMatrix(my_rank, group_size, ep, mynum);
	/**步骤(3)**/
		FindMinWay(my_rank,group_size,ep,mynum);
	OutPutResult(my_rank,group_size,ep,mynum);
	MPI_Finalize();
	free(W);
	free(dist);
	free(bdist);
	return 0;
}

						