1、配置PVM

并行计算机（pvm）是用于网络并行计算机上的软件工具。设计它的目的是将异构的计算机网络连接起来，使它使用起来就像一组分布式的并行处理器。

PVM支持多种并行计算模型，用户使用PVM提供的函数库可进行并行程序或分布式程序的设计工作，使用传统的C语言和Fortran语言。系统提供了一组便于使用的通信原语，可实现一个任务向其它任务发消息，向多个任务发消息，以及阻塞和无阻塞收发消息等功能，用户编程与网络接口分离。

麦好的AI乐园博客所有内容是原创，如果转载请注明来源

http://blog.csdn.net/myhaspl/

1)环境

PVM_ROOT=/usr/lib/pvm3为配置根目录

PVM_ARCH=LINUX为配置计算机类型，包括unix

deepfuture-lx@deepfuture-lx-desktop:/usr/lib/jvm$ sudo gedit /etc/environment

PATH="/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/usr/lib/jvm/java-6-sun/bin"

CLASSPATH=.:/usr/lib/jvm/java-6-sun/lib

JAVA_HOME=/usr/lib/jvm/java-6-sun

PVM_ROOT=/usr/lib/pvm3

PVM_ARCH=LINUX

2) PVM环境中的二进制程序的目录和需要使用的用户名

二进制程序目录名默认为$PVM_ROOT/bin/$PVM_ARCH

ep为二进制程序目录名，lo为使用非登录PVM环境用户的用户名，deepfuture-laptop为主机名，&主机名表示PVM环境不自动增加这些主机

例如:

deepfuture@deepfuture-laptop:/usr/lib/pvm3$ sudo gedit hostfile

deepfuture-laptop

&deepfuture-javaeye

&deepfuture-lx lo=deepfuture

ep=/home/deepfuture/private/mytest/pvmtest/

3) 列出希望使用的所有主机

.rhosts文件

deepfuture-laptop

4)启动pvmd程序

deepfuture@deepfuture-laptop:/usr/lib/pvm3$ pvmd hostfile &或者

deepfuture@deepfuture-laptop:/usr/lib/pvm3$ pvmd &

5）通常程序（二进制文件）的缺省目录为：

$HOME/pvm3/bin/

6)启动

deepfuture@deepfuture-laptop:/usr/lib/pvm3$ pvm

pvmd already running.

pvm> quit

quit

如果启动失败，则清除临时文件

deepfuture@deepfuture-laptop:/usr/lib/pvm3$ sudo rm -f /tmp/pvm*.*

7)运行程序,testpro为程序名

$testpro

或

pvm>spawn -> testpro

安装完PVM以后，还需要编辑/ect/hosts文件，来列出你要加入的所有主机名及其对应的IP地址，以便在用add命令来加入主机时，PVM可以根据主机名来寻找相应的IP，从而确定相应的主机。基本格式如下：

hostname1 10.30.13.58(numeric IP)

hostname2 10.30.13.62

… …. ….

每行一个主机。

将激活的消息缓冲区的内容放入一个预定类型的数组中

NAME

pvm_unpack - Unpack the active message buffer into arrays of prescribed data type.

SYNOPSIS

Cint info = pvm_unpackf( const char *fmt, ... )

int info = pvm_upkbyte( char *xp, int nitem, int stride)

int info = pvm_upkcplx( float *cp, int nitem, int stride)

int info = pvm_upkdcplx( double *zp, int nitem, int stride)

int info = pvm_upkdouble( double *dp, int nitem, int stride)

int info = pvm_upkfloat( float *fp, int nitem, int stride)

int info = pvm_upkint( int *ip, int nitem, int stride)

int info = pvm_upkuint( unsigned int *ip, int nitem, int stride )

int info = pvm_upkushort( unsigned short *ip, int nitem, int stride )

int info = pvm_upkulong( unsigned long *ip, int nitem, int stride )

int info = pvm_upklong( long *ip, int nitem, int stride)

int info = pvm_upkshort( short *jp, int nitem, int stride)

int info = pvm_upkstr( char *sp )