private Thread createSender(final Object send, final int rank,
final int peer) {
return new Thread(new Runnable() {
public void run() {
Communicator c = coll.createCommunicator(rank);
c.send(send, peer);
}
});
}
private Thread createReceiver(final Object recv, final int rank,