Towords Scalable Java HPC with Hybrid and Native Communication Devices in MPJ Express 内容总结

2.相关工作

Open MPI Java Bindings 只能使用Open MPI 座位底层通信库。
随着处理器核数的增加，需要混合并行计算。
Hybrid MPI 使用单线程MPI进程。
在Hybrid MPI中，单节点的多核处理器通过共享堆内存进行通信。因此需要安装一个自定义堆内存管理器，用来把共享堆内存的分配给MPI进程，这些进程可以相互访问其内存。

举例：发送一个int型数组的10个元素
Java：
- JDK1.4引入NIO，在NIO中，JVM操作一系列buffer类来对文件和socket进行读写。ByteBuffer类实现了一个字节数组，但存储在JVM堆内存外部（所谓的直接字节缓冲区）。
  所以，当用户想传一个int型数组的10个元素时，可将其复制到一个ByteBuffer中，类似的，如果想传递一个派生数据类型，则可以把派生数据类型中的每个基本数据类型打包，存到ByteBuffer中，这样软件的高层个底层就可以通过缓冲层提供的的功能对基本数据类型和高级数据类型进行通信。对于专用网络，NIO可以直接读取直接字节缓冲区，这样可以消除使用JNI带来的额外复制。

通信层中是否有缓冲对Java消息库的性能影响极大

hybrid device 的设计
- 基于现有的device进行设计，这样可以选用任何一个网络device进行节点间通信，同时有利于代码的服用，便于以后维护。
实现hybrid device时，首先遇到的问题：

MPJ Express 运行时系统负责启动计算节点上的进程。
bybdev的设计具有在使用运行时系统的单个计算节点上启动一个或多个网络device实例的灵活性
smpdev是一个多个通信device，在那里，不同的线程代表不同的MPJ Express进程，每一个线程有一个包含UUID的进程ID（PID）
smpdev的一个具有挑战性的需求是：smpdev依赖于xdev层中各线程中的共享变量，而用户程序中的变量禁止共享。
- 解决：smpdev和bybdev用过一种智能的类加载机制来满足这个要求。这个类加载机制是：MPJ Express软件的不同包被分为2组，然后分别用不同的的类加载器进行加载。
用户通过指定进程数和可用节点数来执行并行Java应用。基于此：
1. MPJ Express运行时动态地决定每个节点中运行的线程数
2. hybdev创建一个连接网络中所有JVM的网络device实例
3. 每个节点创建一个smpdev实例
4. smpdev线程共享网络device，以便在网络中进行通信
网络中的每个节点用网络device的PID进行标识，这个PID座位网络ID
网络中的smpdev线程用他们的PID进行标识，这些PID也叫作线程ID
每个节点仅使用一个网络device或固定数量的线程使得MPJ Express 能够利用更多的Java线程而不是进程，这样可以极大地减少device的初始化时间和网络资源开销。

smpdev和niodev实现了RecvQueue以用来保存当前用户发出的Recv()方法请求后还没有完全接受的信息。
ArriveQueue用来保存已经完全接受到的信息，但Recv()方法不是由用户发出的
网络device座位smpdev线程间的共享网络通道。
- 当同一节点中的2个线程想获得一条来自某个远程source的信息时，就会发生接受错误。任何线程都能得到被定向到对等县城的信息。
  - 解决：在key中增加destination线程的UUID，这样，niodev就能区分destination线程。source和destination的UUID在信息的头部
MPJ Express 可以用MPI.ANY_SOURCE来检测通配符信息
- 在hybdev中，首先要解决用哪个device来检索这样的信息
- 解决：在hybdev中启动一个新进程，该进程在smpdev队列和正在被使用的网络device中搜索通配符信息，找到后取出信息。

hybdev通信device利用单个计算节点中的多线程，这些单个计算节点在节点间通信时，共享单个网络通道，在之前的试验中发现，共享单个网络通道会在这个通道上发生拥塞（尤其是在多核节点中）。
- 解决：每个节点引入多个网络通达————>每个节点创建多个bybdev实例，每个实例在单独的JVM中。这样，每个节点有多个hybdev实例，每个bybdev实例有自己的用于多节点通信的网络通道。bybdev的实例数有每个节点创建的的进程数决定，而进程是MPJ Express软件的可配参数。

对于点对点通信，native device 使用叫作mpjbuf的MPJ Express中间缓冲层。
mpjbuf实现类 ————> NIO Buffer
使用NIO Buffer 时，应用数据以字节形式被复制到ByteBuffer中，然后送到mpjdev层，java NIO yong allocateDirect()方法吧ByteBuffer分配到JVM内存外面，这样native device就能直接获取ByteBuffer内存。native device得到地址后，把地址传给底层的本地MPI库。此处要注意，因为正在使用ByteBuffer进行数据通信，MPI_BYTE数据类型被用作所有的点对点通信。